Domine a Comunicação Entre Serviços: RabbitMQ e gRPC

// Produtor
using var channel = connection.CreateModel();
channel.QueueDeclare("pedidos", durable: true, exclusive: false);
var body = Encoding.UTF8.GetBytes("Novo pedido #1234");
channel.BasicPublish(exchange: "", routingKey: "pedidos", body: body);
// Consumidor
var consumer = new EventingBasicConsumer(channel);
consumer.Received += (model, ea) => {
    var message = Encoding.UTF8.GetString(ea.Body.ToArray());
    Console.WriteLine($"Processando: {message}");
};
channel.BasicConsume(queue: "pedidos", autoAck: true, consumer: consumer);

syntax = "proto3";
service InventoryService {
  rpc CheckStock (StockRequest) returns (StockResponse);
}
message StockRequest {
  int32 product_id = 1;
}
message StockResponse {
  int32 quantity = 1;
}

// Servidor
public class InventoryService : InventoryServiceBase {
    public override Task<StockResponse> CheckStock(StockRequest request, ServerCallContext context) {
        return Task.FromResult(new StockResponse { Quantity = GetStockFromDB(request.ProductId) });
    }
}
// Cliente
using var channel = GrpcChannel.ForAddress("https://localhost:5001");
var client = new InventoryService.InventoryServiceClient(channel);
var response = await client.CheckStockAsync(new StockRequest { ProductId = 123 });
Console.WriteLine($"Estoque: {response.Quantity}");

dotnet add package RabbitMQ.Client

using RabbitMQ.Client;
using System.Text;
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare(queue: "minha_fila",
                         durable: false,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);
    string mensagem = "Olá, RabbitMQ!";
    var body = Encoding.UTF8.GetBytes(mensagem);
    channel.BasicPublish(exchange: "",
                         routingKey: "minha_fila",
                         basicProperties: null,
                         body: body);
    Console.WriteLine("Mensagem enviada: {0}", mensagem);
}

using RabbitMQ.Client;
using RabbitMQ.Client.Events;
using System.Text;
var factory = new ConnectionFactory() { HostName = "localhost" };
using (var connection = factory.CreateConnection())
using (var channel = connection.CreateModel())
{
    channel.QueueDeclare(queue: "minha_fila",
                         durable: false,
                         exclusive: false,
                         autoDelete: false,
                         arguments: null);
    var consumer = new EventingBasicConsumer(channel);
    consumer.Received += (model, ea) =>
    {
        var body = ea.Body.ToArray();
        var mensagem = Encoding.UTF8.GetString(body);
        Console.WriteLine("Mensagem recebida: {0}", mensagem);
    };
    channel.BasicConsume(queue: "minha_fila",
                         autoAck: true,
                         consumer: consumer);
    Console.WriteLine("Aguardando mensagens...");
    Console.ReadLine();
}

syntax = "proto3";
service Calculator {
  rpc Add (AddRequest) returns (AddResponse);
}
message AddRequest {
  int32 number1 = 1;
  int32 number2 = 2;
}
message AddResponse {
  int32 result = 1;
}

dotnet add package Grpc.Tools

using Grpc.Core;
using Calculator;
public class CalculatorService : Calculator.CalculatorBase
{
    public override Task<AddResponse> Add(AddRequest request, ServerCallContext context)
    {
        return Task.FromResult(new AddResponse
        {
            Result = request.Number1 + request.Number2
        });
    }
}
class Program
{
    static void Main(string[] args)
    {
        var server = new Server
        {
            Services = { Calculator.BindService(new CalculatorService()) },
            Ports = { new ServerPort("localhost", 50051, ServerCredentials.Insecure) }
        };
        server.Start();
        Console.WriteLine("Servidor gRPC rodando na porta 50051...");
        Console.ReadLine();
    }
}

using Grpc.Core;
using Calculator;
class Program
{
    static async Task Main(string[] args)
    {
        var channel = new Channel("localhost:50051", ChannelCredentials.Insecure);
        var client = new Calculator.CalculatorClient(channel);
        var response = await client.AddAsync(new AddRequest { Number1 = 5, Number2 = 10 });
        Console.WriteLine("Resultado: " + response.Result);
        await channel.ShutdownAsync();
    }
}