Brighter V10: Utilizando PostgreSQL como Gateway de Mensagens Leve

Em artigos anteriores, abordei o Brighter V10 RC1. Uma adição notável é o suporte ao Postgres como gateway de mensagens, ideal para aplicações pequenas ou protótipos devido à simplicidade e configuração leve.

Requisitos

• .NET 8 ou superior
• Um projeto .NET com estes pacotes NuGet:
  • Paramore.Brighter.MessagingGateway.Postgres: Permite integração com Postgres para filas de mensagens.
  • Paramore.Brighter.ServiceActivator.Extensions.DependencyInjection: Registra o Brighter com Microsoft DI.
  • Paramore.Brighter.ServiceActivator.Extensions.Hosting: Hospeda o Brighter como serviço em segundo plano.
  • Serilog.AspNetCore: Para logs estruturados (opcional, mas recomendado).

Recapitulação do Brighter

Antes de continuar com a configuração do Postgres, vamos recapitular o que já sabemos sobre o Brighter.

Request (Command/Event)

Defina mensagens usando IRequest:

public class Greeting() : Event(Guid.NewGuid())
{
    public string Name { get; set; } = string.Empty;
}

• Commands: Operações com único destinatário (ex: SendEmail).
• Events: Notificações de broadcast (ex: OrderShipped).

Message Mapper (Opcional)

Converte entre mensagens do Brighter e objetos da aplicação. Por padrão, o Brighter usa serialização JSON.

Request Handler

Processa mensagens recebidas:

public class GreetingHandler(ILogger<GreetingHandler> logger) : RequestHandler<Greeting>
{
    public override Greeting Handle(Greeting command)
    {
        logger.LogInformation("Hello {Name}", command.Name);
        return base.Handle(command);
    }
}

Configurando Brighter com Postgres

1. Configuração de Conexão

Defina os detalhes da conexão Postgres:

var config = new RelationalDatabaseConfiguration(
  "<connection-string>", 
   queueStoreTable: "QueueData" // Criada automaticamente se ausente
);

Observação: Se a tabela de fila não existir, o Brighter a criará automaticamente.

2. Assinatura Postgres

Inscreva-se em um tópico:

 .AddServiceActivator(opt =>
 {
     opt.Subscriptions =
     [
         new PostgresSubscription<Greeting>(
             subscriptionName: new SubscriptionName("greeting.subscription"),
             channelName: new ChannelName("greeting.topic"),
             makeChannels: OnMissingChannel.Create,
             messagePumpType: MessagePumpType.Reactor,
             timeOut:  TimeSpan.FromSeconds(10)
           ),
     ];

     opt.DefaultChannelFactory = new PostgresChannelFactory(new PostgresMessagingGatewayConnection(config));
})

3. Configuração de Produtor Postgres

Publique eventos em um tópico:

.UseExternalBus(opt =>
{
    opt.ProducerRegistry = new PostgresMessagingGatewayConnection(config, [
        new PostgresPublication<Greeting>
        {
            Topic = new RoutingKey("greeting.topic"),
            MakeChannels = OnMissingChannel.Create
        }]).Create();
})

Conclusão

Integrar o Brighter com Postgres simplifica a criação de sistemas escaláveis baseados em mensagens para casos de uso leves. Aproveitando os padrões aprimorados do V10 e a confiabilidade do Postgres, desenvolvedores podem focar na lógica de negócio sem a complexidade de infraestruturas pesadas.

Benefícios-chave

• Consistência transacional: Aproveita garantias ACID do Postgres
• Infraestrutura simplificada: Banco único para dados da aplicação + mensagens
• Prototipagem rápida: Elimina dependências de brokers de mensagens dedicados

Observação: Para cargas de produção com alto throughput, considere brokers dedicados como Kafka ou RabbitMQ.

Para um exemplo completo, consulte o repositório de amostra no GitHub.