JonjubNet.Resilience

Una biblioteca de resiliencia para aplicaciones .NET que implementa patrones como Circuit Breaker, Retry, Timeout, Bulkhead y Fallback usando Polly.

Características

• Circuit Breaker: Protege contra fallos en cascada
• Retry: Reintentos automáticos con diferentes estrategias de backoff
• Timeout: Control de tiempo de espera para operaciones
• Bulkhead: Aislamiento de recursos
• Fallback: Estrategias de respaldo cuando las operaciones fallan
• Configuración flexible: Configuración por servicio y operación
• Logging estructurado: Integración con sistemas de logging

Instalación

dotnet add package JonjubNet.Resilience

Uso Básico

1. Configuración en appsettings.json

{
  "Resilience": {
    "Enabled": true,
    "ServiceName": "MiAplicacion",
    "Environment": "Development",
    "CircuitBreaker": {
      "Enabled": true,
      "FailureThreshold": 5,
      "SamplingDurationSeconds": 30,
      "MinimumThroughput": 2,
      "DurationOfBreakSeconds": 60
    },
    "Retry": {
      "Enabled": true,
      "MaxRetryAttempts": 3,
      "BaseDelayMilliseconds": 1000,
      "MaxDelayMilliseconds": 30000,
      "BackoffStrategy": "Exponential"
    },
    "Timeout": {
      "Enabled": true,
      "DefaultTimeoutSeconds": 30,
      "DatabaseTimeoutSeconds": 15,
      "ExternalApiTimeoutSeconds": 10
    }
  }
}

2. Registro en Program.cs

using JonjubNet.Resilience;

var builder = WebApplication.CreateBuilder(args);

// Agregar infraestructura de resiliencia
builder.Services.AddResilienceInfrastructure(builder.Configuration);

3. Uso en servicios

public class MiServicio
{
    private readonly IResilienceService _resilienceService;

    public MiServicio(IResilienceService resilienceService)
    {
        _resilienceService = resilienceService;
    }

    public async Task<string> ObtenerDatosAsync()
    {
        return await _resilienceService.ExecuteWithResilienceAsync(
            async () =>
            {
                // Tu lógica de negocio aquí
                var httpClient = new HttpClient();
                var response = await httpClient.GetAsync("https://api.ejemplo.com/datos");
                return await response.Content.ReadAsStringAsync();
            },
            "ObtenerDatos",
            "ApiExterna"
        );
    }

    public async Task<string> ObtenerDatosConFallbackAsync()
    {
        return await _resilienceService.ExecuteWithFallbackAsync(
            async () =>
            {
                // Operación principal
                var httpClient = new HttpClient();
                var response = await httpClient.GetAsync("https://api.ejemplo.com/datos");
                return await response.Content.ReadAsStringAsync();
            },
            async () =>
            {
                // Operación de fallback
                return "Datos por defecto";
            },
            "ObtenerDatosConFallback",
            "ApiExterna"
        );
    }
}