Оффлайн
- Регистрация
- 1 Мар 2015
- Сообщения
- 1,481
- Баллы
- 155
Introdução ao RabbitMQ
O RabbitMQ é um dos brokers de mensagens mais utilizados, implementando o Advanced Message Queuing Protocol (AMQP) para garantir entrega confiável de mensagens. Desenvolvido na linguagem Erlang, oferece alta escalabilidade e tolerância a falhas, sendo ideal para sistemas distribuídos. O RabbitMQ age como intermediário que aceita mensagens de produtores e as entrega a consumidores, desacoplando serviços em arquiteturas de microserviços.
Requisitos
Antes de configurar o RabbitMQ, vamos revisar conceitos básicos do Brighter:
Mensagens (Comandos/Eventos)
Defina mensagens usando IRequest:
public class Greeting : Event(Guid.NewGuid())
{
public string Name { get; set; } = string.Empty;
}
Converte entre mensagens do Brighter e objetos da aplicação:
public class GreetingMapper : IAmAMessageMapper<Greeting>
{
public Message MapToMessage(Greeting request)
{
var header = new MessageHeader
{
Id = request.Id,
TimeStamp = DateTime.UtcNow,
Topic = "greeting.topic",
MessageType = MessageType.MT_EVENT
};
var body = new MessageBody(JsonSerializer.Serialize(request));
return new Message(header, body);
}
public Greeting MapToRequest(Message message)
{
return JsonSerializer.Deserialize<Greeting>(message.Body.Bytes)!;
}
}
Manipulador de Requisições(Request Handler)
Processa as mensagens recebidas:
public class GreetingHandler(ILogger<GreetingHandler> logger) : RequestHandler<Greeting>
{
public override Greeting Handle(Greeting command)
{
logger.LogInformation("Olá, {Name}!", command.Name);
return base.Handle(command);
}
}
Configuração do Brighter com RabbitMQ
1. Configuração da Conexão
Defina os detalhes de conexão com o RabbitMQ:
var connection = new RmqMessagingGatewayConnection
{
AmpqUri = new AmqpUriSpecification(new Uri("amqp://guest:guest@localhost:5672")),
Exchange = new Exchange("paramore.brighter.exchange"),
};
2. Inscrição no RabbitMQ
Inscreva-se em uma fila/tópico:
.AddServiceActivator(opt =>
{
opt.Subscriptions = [
new RmqSubscription<Greeting>(
new SubscriptionName("kafka.greeting.subscription"),
new ChannelName("greeting.queue"),
new RoutingKey("greeting.topic"),
makeChannels: OnMissingChannel.Create
),
];
opt.ChannelFactory = new ChannelFactory(
new RmqMessageConsumerFactory(connection)
);
})
3. Configuração do Produtor RabbitMQ
Publique eventos em um tópico:
.UseExternalBus(new RmqProducerRegistryFactory(connection, new[]
{
new RmqPublication
{
Topic = new RoutingKey("greeting.topic"),
MakeChannels = OnMissingChannel.Create
}
}).Create());
Melhores Práticas
A integração do Brighter com o RabbitMQ permite construir sistemas de mensageria robustos e escaláveis em aplicações .NET. Ao combinar o protocolo AMQP do RabbitMQ com a camada de abstração do Brighter, você pode:
Para uso em produção, valide as configurações contra a documentação mais recente do Brighter, pois recursos como priorização de mensagens ou exchanges com atraso podem evoluir.
Referências
O RabbitMQ é um dos brokers de mensagens mais utilizados, implementando o Advanced Message Queuing Protocol (AMQP) para garantir entrega confiável de mensagens. Desenvolvido na linguagem Erlang, oferece alta escalabilidade e tolerância a falhas, sendo ideal para sistemas distribuídos. O RabbitMQ age como intermediário que aceita mensagens de produtores e as entrega a consumidores, desacoplando serviços em arquiteturas de microserviços.
Requisitos
- .NET 8 ou superior
- Projeto .NET com os seguintes pacotes NuGet:
- : Habilita integração com RabbitMQ.
- : Permite registrar o Brighter com DI do Microsoft.
- : Hospeda o Brighter como serviço em segundo plano.
- : Para logs estruturados (opcional, mas recomendado).
Antes de configurar o RabbitMQ, vamos revisar conceitos básicos do Brighter:
Mensagens (Comandos/Eventos)
Defina mensagens usando IRequest:
public class Greeting : Event(Guid.NewGuid())
{
public string Name { get; set; } = string.Empty;
}
- Comandos: Operações direcionadas a um único destinatário (ex: SendEmail).
- Eventos: Notificações broadcast (ex: OrderShipped).
Converte entre mensagens do Brighter e objetos da aplicação:
public class GreetingMapper : IAmAMessageMapper<Greeting>
{
public Message MapToMessage(Greeting request)
{
var header = new MessageHeader
{
Id = request.Id,
TimeStamp = DateTime.UtcNow,
Topic = "greeting.topic",
MessageType = MessageType.MT_EVENT
};
var body = new MessageBody(JsonSerializer.Serialize(request));
return new Message(header, body);
}
public Greeting MapToRequest(Message message)
{
return JsonSerializer.Deserialize<Greeting>(message.Body.Bytes)!;
}
}
Manipulador de Requisições(Request Handler)
Processa as mensagens recebidas:
public class GreetingHandler(ILogger<GreetingHandler> logger) : RequestHandler<Greeting>
{
public override Greeting Handle(Greeting command)
{
logger.LogInformation("Olá, {Name}!", command.Name);
return base.Handle(command);
}
}
Configuração do Brighter com RabbitMQ
1. Configuração da Conexão
Defina os detalhes de conexão com o RabbitMQ:
var connection = new RmqMessagingGatewayConnection
{
AmpqUri = new AmqpUriSpecification(new Uri("amqp://guest:guest@localhost:5672")),
Exchange = new Exchange("paramore.brighter.exchange"),
};
2. Inscrição no RabbitMQ
Inscreva-se em uma fila/tópico:
.AddServiceActivator(opt =>
{
opt.Subscriptions = [
new RmqSubscription<Greeting>(
new SubscriptionName("kafka.greeting.subscription"),
new ChannelName("greeting.queue"),
new RoutingKey("greeting.topic"),
makeChannels: OnMissingChannel.Create
),
];
opt.ChannelFactory = new ChannelFactory(
new RmqMessageConsumerFactory(connection)
);
})
3. Configuração do Produtor RabbitMQ
Publique eventos em um tópico:
.UseExternalBus(new RmqProducerRegistryFactory(connection, new[]
{
new RmqPublication
{
Topic = new RoutingKey("greeting.topic"),
MakeChannels = OnMissingChannel.Create
}
}).Create());
Melhores Práticas
- Filas de Cartas Mortas(DLQ): Configure DLQs no RabbitMQ para tratar mensagens problemáticas. Use deadLetterChannelName e deadLetterRoutingKey nas declarações de filas.
- Monitoramento: Utilize o plugin de gerenciamento do RabbitMQ para acompanhar saúde e desempenho das filas.
- Tratamento de Erros: Implemente retentativas e circuit breakers para falhas transitórias (o Brighter suporta isso via atributos, abordarei em outro artigo).
A integração do Brighter com o RabbitMQ permite construir sistemas de mensageria robustos e escaláveis em aplicações .NET. Ao combinar o protocolo AMQP do RabbitMQ com a camada de abstração do Brighter, você pode:
- Desacoplar serviços com padrões de publish-subscribe.
- Garantir ordenação e confiabilidade nas mensagens.
- Simplificar o tratamento de erros com DLQs e retentativas.
Para uso em produção, valide as configurações contra a documentação mais recente do Brighter, pois recursos como priorização de mensagens ou exchanges com atraso podem evoluir.
Referências
- Código Completo:
- Documentação Oficial: