DEV Community

Cover image for Migração para Brighter V10 com Microsoft SQL Server
Rafael Andrade
Rafael Andrade

Posted on Edited on

Migração para Brighter V10 com Microsoft SQL Server

#csharp #dotnet #sqlserver #brighter

Em artigos anteriores, abordei a integração do Brighter com o MS SQL Server e o Brighter V10 RC1. Este guia foca na migração para o Brighter V10, destacando mudanças de configuração do MS SQL Server e atualizações que quebram compatibilidade.

Requisitos

Recapitulação do Brighter

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

Request (Comando/Evento)

Defina mensagens usando IRequest:

public class Greeting() : Event(Guid.NewGuid())
{
    public string Name { get; set; } = string.Empty;
}
Enter fullscreen mode Exit fullscreen mode
  • Comandos: Operações com único destinatário (ex: SendEmail).
  • Eventos: Notificações de broadcast (ex: OrderShipped).

Message Mapper (Opcional)

Traduz entre mensagens Brighter e objetos do seu app. Para fluxos assíncronos, mappers agora requerem IAmAMessageMapperAsync.

Request Handler

Processa 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);
    }
}
Enter fullscreen mode Exit fullscreen mode

Configurando Brighter com SQL Server

1. Criando tabela de filas

O Brighter não cria a tabela automaticamente. Use este script:

IF NOT (EXISTS (SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_SCHEMA = 'dbo' AND  TABLE_NAME = 'QueueData'))
BEGIN
    CREATE TABLE [dbo].[QueueData](
        [Id] [bigint] IDENTITY(1,1) NOT NULL,
        [Topic] [nvarchar](255) NOT NULL,
        [MessageType] [nvarchar](1024) NOT NULL,
        [Payload] [nvarchar](max) NOT NULL,
        CONSTRAINT [PK_QueueData] PRIMARY KEY CLUSTERED ([Id] ASC)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
     ) ON [PRIMARY] TEXTIMAGE_ON [PRIMARY]

     CREATE NONCLUSTERED INDEX [IX_Topic] ON [dbo].[QueueData]([Topic] ASC) WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, SORT_IN_TEMPDB = OFF, DROP_EXISTING = OFF, ONLINE = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]
END;
Enter fullscreen mode Exit fullscreen mode

2. Configuração de conexão

Defina detalhes da conexão SQL Server:

var config = new RelationalDatabaseConfiguration("<string-de-conexão>", queueStoreTable: "QueueData");
Enter fullscreen mode Exit fullscreen mode

3. Assinatura SQL

Inscreva-se em um tópico:

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

    opt.DefaultChannelFactory = new ChannelFactory(new MsSqlMessageConsumerFactory(config));
})
Enter fullscreen mode Exit fullscreen mode

4. Configuração do Produtor SQL

Publique eventos em um tópico:

.UseExternalBus(opt =>
{
    opt.ProducerRegistry = new MsSqlProducerRegistryFactory(config, [
        new Publication<Greeting>
        {
            Topic = new RoutingKey("greeting.topic"),
            MakeChannels = OnMissingChannel.Create
        }]).Create();
})
Enter fullscreen mode Exit fullscreen mode

Mudanças Incompatíveis no Brighter V10

O Brighter V10 introduz atualizações na integração SQL. Principais mudanças:

Reformulação do Message Mapper

Serialização JSON Padrão:

Na V9, mappers eram obrigatórios. Na V10, a serialização JSON é nativa, a menos que lógica customizada seja necessária. Você também pode alterar a serialização padrão do Brighter.

Assinaturas

Duas mudanças principais:

Tipos de Message Pump Explícitos

O campo runAsync/isAsync (booleano) foi substituído por messagePumpType do tipo MessagePumpType (Reactor, Proactor, Unknown).

Renomeação de Propriedade

Em AddServiceActivator, a propriedade ChannelFactory foi renomeada para DefaultChannelFactory.

Publicação

Use ExternalBusConfiguration para configurar produtores e padrões de outbox:

// V10
.UseExternalBus(opt => { ... })

// V9
.UseExternalBus(new RmqProducerRegistryFactory(...))
Enter fullscreen mode Exit fullscreen mode

Conclusão

O Brighter V10 simplifica a integração com SQL Server enquanto introduz mudanças incompatíveis para melhorar clareza e flexibilidade. Principais atualizações incluem serialização integrada, tipos explícitos de message pumps e APIs de configuração otimizadas. Para detalhes completos, consulte o repositório de exemplo no GitHub.

Top comments (0)