MemoryEventBus.InMemory 1.0.0

MemoryEventBus - High-Performance In-Memory Event Bus

Visão Geral

Uma implementação customizada de Event Bus baseada em System.Threading.Channels que oferece performance superior ao MediatR para cenários de alta throughput, com funcionalidades opcionais avançadas.

Funcionalidades Implementadas

Versão Básica (Funcional)

• Event Channel Manager - Gerenciamento de channels com ConcurrentDictionary
• Producers/Consumers - Publicação e consumo assíncrono de eventos
• Domain Events - Implementação baseada em DDD
• Performance Otimizada - Usando Channel.CreateUnbounded para alta performance

Funcionalidades Avançadas (Opcionais)

• Error Handling Centralizado - IEventBusErrorHandler e DefaultEventBusErrorHandler
• Retry Policies - ExponentialBackoffRetryPolicy e LinearRetryPolicy
• Metrics/Observability - Usando System.Diagnostics.Metrics (.NET 8)
• Backpressure Handling - Suporte a bounded channels

Como Usar

Configuração Básica (Recomendada para começar)

No appsettings.json:

{
  "EventBus": {
    "UseEnhancedFeatures": false
  }
}

Configuração Avançada (Com todas as funcionalidades)

No appsettings.json:

{
  "EventBus": {
    "UseEnhancedFeatures": true,
    "DefaultChannelCapacity": 1000,
    "UseBoundedChannels": false,
    "DefaultMaxRetryAttempts": 3,
    "DefaultRetryBaseDelayMs": 100,
    "DefaultRetryMaxDelayMs": 30000
  }
}

Arquitetura

???????????????????    ????????????????????    ???????????????????
?   Producer      ??????  EventChannel    ??????   Consumer      ?
?                 ?    ?   Manager        ?    ?                 ?
???????????????????    ????????????????????    ???????????????????
        ?                        ?                        ?
        ?                        ?                        ?
???????????????????    ????????????????????    ???????????????????
? Error Handler   ?    ?    Metrics       ?    ? Retry Policy    ?
?                 ?    ?                  ?    ?                 ?
???????????????????    ????????????????????    ???????????????????

Performance vs MediatR

Exemplo de Uso

1. Publicar um Evento

[HttpPost("process-payment")]
public async Task<IActionResult> ProcessPaymentAsync([FromQuery] decimal amount)
{
    var order = await _payUseCase.ExecuteAsync(amount);
    return order is null ? BadRequest("Payment processing failed.") : Ok(order);
}

2. Implementar um Consumer

public class StockReducerConsumer : BackgroundService
{
    private readonly Channel<DomainEvent> _channel;

    public StockReducerConsumer(IEventChannelManager channelManager)
    {
        _channel = channelManager.GetOrCreateChannel<OrderPaidEvent>();
    }

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {
        await foreach (var domainEvent in _channel.Reader.ReadAllAsync(stoppingToken))
        {
            if (domainEvent is OrderPaidEvent orderPaidEvent)
            {
                // Processar evento
                await ProcessEventAsync(orderPaidEvent, stoppingToken);
            }
        }
    }
}

Melhorias Implementadas

1. Error Handling Centralizado

public async Task HandleErrorAsync<TEvent>(TEvent @event, Exception exception, int attemptNumber, CancellationToken cancellationToken = default)

2. Retry Policies

• ExponentialBackoffRetryPolicy: Delay exponencial entre tentativas
• LinearRetryPolicy: Delay fixo entre tentativas

3. Metrics/Observability

• Contadores de eventos publicados/consumidos/falhados
• Histograma de tempo de processamento
• Gauge de profundidade dos channels

4. Backpressure Handling

public Channel<DomainEvent> GetOrCreateBoundedChannel<TEvent>(int capacity) where TEvent : DomainEvent

Conclusão

Esta implementação oferece uma alternativa de alta performance ao MediatR, especialmente adequada para:

• Microsserviços de alta throughput
• Sistemas com requisitos rigorosos de latência
• Cenários onde controle fino sobre o processamento é necessário
• Aplicações que precisam de observabilidade detalhada

Para projetos que requerem funcionalidades mais complexas de pipeline (validação, autorização, etc.), o MediatR ainda pode ser mais apropriado.