Nuuvify.CommonPack.BackgroundService 2.1.0-test.25092903

Nuuvify.CommonPack.BackgroundService

Biblioteca para criação de serviços de background que processam mensagens do Azure Service Bus de forma robusta e com telemetria integrada.

Características

• ✅ Classe base abstrata para implementação de workers
• ✅ Integração completa com Azure Service Bus
• ✅ Telemetria e observabilidade com OpenTelemetry
• ✅ Tratamento robusto de erros
• ✅ Configuração flexível via connection strings ou Azure credentials
• ✅ Suporte a dead letter queue e message abandonment
• ✅ Logging estruturado
• ✅ Testes unitários incluídos

Instalação

dotnet add package Nuuvify.CommonPack.BackgroundService

Uso Básico

1. Implementação da Classe Concreta

public class OrderProcessingService : BackgroundServiceAbstract<OrderProcessingService>
{
    public OrderProcessingService(
        ILogger<OrderProcessingService> logger,
        IConfigurationCustom configurationCustom,
        RequestConfiguration requestConfiguration,
        ActivitySource activitySource)
        : base(logger, configurationCustom, requestConfiguration, activitySource,
               maxConcurrentCalls: 10, maxAutoLockRenewalDuration: TimeSpan.FromMinutes(10))
    {
        // Configurar comportamento em caso de falha
        AbandonMessageIfFailed = true; // ou false para usar dead letter queue
    }

    public override async Task<bool> ExecuteRule(
        ServiceBusReceivedMessage message,
        ActivitySource activitySource,
        CancellationToken cancellationToken)
    {
        using var activity = activitySource.StartActivity("ProcessOrder");

        try
        {
            // Sua lógica de processamento aqui
            var messageBody = message.Body.ToString();
            var orderData = JsonSerializer.Deserialize<OrderData>(messageBody);

            // Adicionar telemetria
            activity?.SetTag("order.id", orderData.OrderId);

            Logger.LogInformation("Processando pedido {OrderId}", orderData.OrderId);

            // Processar o pedido
            await ProcessOrderAsync(orderData, cancellationToken);

            return true; // Sucesso
        }
        catch (Exception ex)
        {
            Logger.LogError(ex, "Erro ao processar mensagem {MessageId}", message.MessageId);
            activity?.SetStatus(ActivityStatusCode.Error, ex.Message);
            return false; // Falha
        }
    }

    private async Task ProcessOrderAsync(OrderData orderData, CancellationToken cancellationToken)
    {
        // Implementar lógica de negócio
        await Task.Delay(1000, cancellationToken);
    }
}

2. Configuração no appsettings.json

{
  "AppConfig": {
    "ServiceBus": {
      "Cnn": "ServiceBusConnection",
      "Topic": "orders-topic",
      "Subscription": "order-processing-subscription"
    }
  },
  "ConnectionStrings": {
    "ServiceBusConnection": "Endpoint=sb://your-namespace.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=your-key"
  }
}

3. Registro no DI Container

public void ConfigureServices(IServiceCollection services)
{
    // Registrar dependências
    services.AddSingleton<IConfigurationCustom, ConfigurationCustom>();
    services.AddScoped<RequestConfiguration>();
    services.AddSingleton(new ActivitySource("YourApp"));

    // Registrar o background service
    services.AddHostedService<OrderProcessingService>();
}

Configuração com Azure Credentials

Para ambientes de produção, recomenda-se usar Azure Managed Identity:

public override void ConfigureServiceBus(
    ServiceBusClientOptions serviceBusClientOptions,
    TokenCredential credential,
    ServiceBusProcessorOptions serviceBusProcessorOptions)
{
    base.ConfigureServiceBus(serviceBusClientOptions, credential, serviceBusProcessorOptions);
}

Configure no appsettings.json:

{
  "AppConfig": {
    "ServiceBus": {
      "FullyQualifiedNamespace": "your-namespace.servicebus.windows.net",
      "Topic": "orders-topic",
      "Subscription": "order-processing-subscription"
    }
  }
}

Interface IBackgroundServiceAbstract

A biblioteca fornece uma interface que define o contrato:

public interface IBackgroundServiceAbstract<T>
{
    Task<bool> ExecuteRule(
        ServiceBusReceivedMessage message,
        ActivitySource activitySource,
        CancellationToken cancellationToken);

    bool AbandonMessageIfFailed { get; set; }
}

Tratamento de Erros

A classe base trata automaticamente diferentes tipos de erros:

• ServiceBusException: Erros específicos do Service Bus (lock perdido, quota excedida, etc.)
• OperationCanceledException: Cancelamento de operação
• Exception: Erros gerais

Comportamento de Falhas

Configure o comportamento quando uma mensagem falha:

// Abandonar mensagem (retorna para a fila)
AbandonMessageIfFailed = true;

// Enviar para dead letter queue (padrão)
AbandonMessageIfFailed = false;

Telemetria e Observabilidade

A classe integra automaticamente com OpenTelemetry:

• Traces: Cada processamento de mensagem gera um trace
• Tags: CorrelationId, dados da mensagem
• Status: Success/Error com detalhes

Logs Estruturados

A biblioteca gera logs estruturados em vários níveis:

• Information: Início/fim do processamento
• Warning: Operações canceladas
• Error: Falhas no processamento
• Debug: Detalhes internos (quando habilitado)

Configurações Avançadas

Parâmetros do Construtor

protected BackgroundServiceAbstract(
    ILogger<BackgroundServiceAbstract<T>> logger,
    IConfigurationCustom configurationCustom,
    RequestConfiguration requestConfiguration,
    ActivitySource activitySourceCustom,
    int maxConcurrentCalls = 10,                    // Máximo de mensagens processadas simultaneamente
    TimeSpan maxAutoLockRenewalDuration = TimeSpan.FromMinutes(5)) // Tempo de renovação do lock

Propriedades Protegidas

• Logger: Instância do logger
• ConfigurationCustom: Configuração da aplicação
• RequestConfiguration: Configuração da requisição
• ActivitySourceCustom: Source para telemetria

Exemplo Completo

Veja o arquivo Examples/OrderProcessingBackgroundService.cs para um exemplo completo de implementação.

Testes

A biblioteca inclui testes unitários abrangentes. Para executar:

dotnet test test/Nuuvify.CommonPack.BackgroundService.xTest/

Dependências

• Azure.Messaging.ServiceBus
• Microsoft.Extensions.Hosting.Abstractions
• Azure.Monitor.OpenTelemetry.AspNetCore
• Nuuvify.CommonPack.Middleware.Abstraction

Licença

Este projeto está licenciado sob a licença MIT. Veja o arquivo LICENSE para detalhes.

Contribuição

Contribuições são bem-vindas! Por favor, veja o arquivo CONTRIBUTING.md para diretrizes.

Changelog

Veja o arquivo CHANGELOG.md para histórico de versões e mudanças.