Rafael Andrade

Posted on May 19

Brighter + Redis/Valkey: Como configurar o Brighter com Redis/Valkey

#braziliandevs #brigther #redis #csharp

Introdução ao Brighter e Redis

O Redis é um armazenamento de estruturas de dados em memória, frequentemente usado como broker de mensagens, cache ou banco de dados. Ele possui suporte a filas (queues), e é possível integrar com o Brighter usando o pacote Paramore.Brighter.MessagingGateway.Redis.

Requisitos

.NET 8 ou superior
Projeto .NET com os seguintes pacotes NuGet:
- Paramore.Brighter.MessagingGateway.Redis: Habilita integração com Redis.
- Paramore.Brighter.ServiceActivator.Extensions.DependencyInjection: Integra o Brighter com a injeção de dependência do Microsoft.
- 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 configurar o Redis, 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: EnviarEmail).
Eventos: Notificações broadcast (ex: PedidoEnviado).

Mapeador de Mensagens (Message Mapper)

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 Redis

1. Configuração da Conexão

Defina os detalhes de conexão com o Redis:

var connection = new RedisMessagingGatewayConfiguration
{
    RedisConnectionString = "localhost:6379?connectTimeout=1000&sendTimeout=1000&",
    MaxPoolSize = 10,
    MessageTimeToLive = TimeSpan.FromMinutes(10)
};

2. Inscrição no Redis (Consumer)

Assine uma fila Redis:

.AddServiceActivator(opt =>
{
    opt.Subscriptions = [
        new RedisSubscription<Greeting>(
            new SubscriptionName("kafka.greeting.subscription"),
            new ChannelName("greeting.queue"),
            new RoutingKey("greeting.topic"),
            makeChannels: OnMissingChannel.Create
        ),
    ];

    opt.ChannelFactory = new ChannelFactory(
        new RedisMessageConsumerFactory(connection)
    );
})

3. Publicação no Redis (Producer)

Publique eventos em uma fila:

.UseExternalBus(new RedisProducerRegistryFactory(connection, new[]
{
    new RedisMessagePublication
    {
        Topic = new RoutingKey("greeting.topic"),
        MakeChannels = OnMissingChannel.Create
    }
}).Create());

Limitações e Considerações Importantes

1. Licenciamento do ServiceStack.Redis

A integração do Brighter com Redis depende do ServiceStack.Redis.Core, que limita o consumo simultâneo de mensagens sem uma licença comercial. Isso pode ser um gargalo para sistemas de alto throughput.

2. Falta de Suporte a Redis Streams (por enquanto)

Atualmente, o Brighter usa listas Redis para filas, não aproveitando os Redis Streams (mais modernos e com persistência). Uma atualização futura deve adicionar suporte a Streams para maior escalabilidade.

Conclusão

A integração do Brighter com Redis permite mensageria leve e escalável em aplicações .NET, aproveitando a velocidade do Redis em memória e a abstração do Brighter.

Para uso em produção, valide as configurações contra a documentação mais recente do Brighter, pois recursos como Redis Streams e clientes alternativos podem evoluir.

Referências

Código Completo: Repositório GitHub
Documentação do Redis Queue: Glossário Redis

DEV Community