‫استفاده از Polly برای مدیریت خطاهای موقتی در ASP.NET Core

• افزایش قابلیت اطمینان برنامه: با تلاش مجدد خودکار برای درخواست‌های شکست‌خورده یا قطع مدار در صورت شکست‌های مداوم، از بروز خرابی‌های بیشتر جلوگیری می‌شود.
• بهبود تجربه کاربری: Polly می‌تواند پاسخ‌های بازگشتی (مثل داده‌های پیش‌فرض یا نتایج کش‌شده) هنگام بروز خطا ارائه دهد.
• مقاومت در برابر خطا در سیستم‌های توزیع‌شده: Polly کمک می‌کند تا درخواست‌ها به خدمات خارجی یا پایگاه داده‌ها با مدیریت خطا انجام شود.

• Retry Policy: تلاش می‌کند تا یک عملیات شکست‌خورده را چندین بار با یک فاصله مشخص بین هر تلاش، دوباره اجرا کند.
• Circuit Breaker Policy: پس از تعداد مشخصی از شکست‌ها، مدار قطع می‌شود و عملیات به طور موقت متوقف می‌شود.
• Timeout Policy: اگر یک عملیات بیش از مدت زمان مشخصی طول بکشد، آن را متوقف می‌کند.
• Fallback Policy: وقتی عملیات شکست می‌خورد، یک اقدام یا پاسخ جایگزین را ارائه می‌دهد.
• Bulkhead Isolation: تعداد عملیات همزمانی را که به یک منبع خاص دسترسی پیدا می‌کنند، محدود می‌کند تا از بار اضافی جلوگیری شود.

dotnet add package Polly

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .WaitAndRetryAsync(3, attempt => TimeSpan.FromSeconds(2)));  // Retry 3 times with a 2 second delay

• <Handle<T: نوع استثناهایی را که باید مدیریت شوند مشخص می‌کند. می‌توانید چندین نوع استثنا را با زنجیره‌سازی <Handle<T مدیریت کنید.
• WaitAndRetryAsync: سیاست Retry را پیکربندی می‌کند، که در این مثال 3 بار تلاش مجدد انجام می‌دهد و هر بار با فاصله 2 ثانیه بین تلاش‌ها.

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .CircuitBreakerAsync(3, TimeSpan.FromSeconds(30)));  // Circuit breaker after 3 failures for 30 seconds

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.TimeoutAsync<HttpResponseMessage>(TimeSpan.FromSeconds(10)));  // Timeout after 10 seconds

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .FallbackAsync(new HttpResponseMessage(HttpStatusCode.OK) { Content = new StringContent("Fallback data") }));

public void ConfigureServices(IServiceCollection services)
{
    services.AddHttpClient("MyHttpClient")
        .AddTransientHttpErrorPolicy(policyBuilder => 
            policyBuilder.WaitAndRetryAsync(3, _ => TimeSpan.FromSeconds(2))) // Retry 3 times with a 2 second delay
        .AddTransientHttpErrorPolicy(policyBuilder => 
            policyBuilder.CircuitBreakerAsync(3, TimeSpan.FromSeconds(30))); // Circuit breaker after 3 failures for 30 seconds
}

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.WrapAsync(
        Policy.Handle<HttpRequestException>()
            .WaitAndRetryAsync(3, _ => TimeSpan.FromSeconds(2)),   // Retry Policy
        Policy.Handle<HttpRequestException>()
            .CircuitBreakerAsync(3, TimeSpan.FromSeconds(30)),   // Circuit Breaker Policy
        Policy.TimeoutAsync<HttpResponseMessage>(TimeSpan.FromSeconds(10)))); // Timeout Policy

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.BulkheadAsync<HttpResponseMessage>(maxParallelRequests: 10));

public void ConfigureServices(IServiceCollection services)
{
    services.AddHttpClient("MyHttpClient")
        .AddTransientHttpErrorPolicy(policy => policy.WaitAndRetryAsync(3, _ => TimeSpan.FromSeconds(2)))
        .AddTransientHttpErrorPolicy(policy => policy.CircuitBreakerAsync(3, TimeSpan.FromSeconds(30)));
}

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .OrResult<HttpResponseMessage>(r => r.StatusCode == HttpStatusCode.RequestTimeout)
        .WaitAndRetryAsync(3, _ => TimeSpan.FromSeconds(5)));

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .WaitAndRetryAsync(3, attempt => 
        {
            _logger.LogWarning("Retry attempt #{Attempt}", attempt);
            return TimeSpan.FromSeconds(2);
        }));

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .WaitAndRetryAsync(5, attempt => 
            TimeSpan.FromSeconds(Math.Pow(2, attempt))));  // Exponential backoff

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(Policy.Handle<HttpRequestException>()
        .OrResult<HttpResponseMessage>(r => r.StatusCode == HttpStatusCode.RequestTimeout)
        .WaitAndRetryAsync(5, _ => TimeSpan.FromSeconds(2)));

var cacheProvider = new MemoryCacheProvider(new MemoryCache(new MemoryCacheOptions()));
var cachePolicy = Policy.CacheAsync<HttpResponseMessage>(
    cacheProvider.AsyncFor<HttpResponseMessage>(),
    TimeSpan.FromMinutes(5));

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(cachePolicy);

var rateLimitPolicy = Policy.RateLimitAsync(10, TimeSpan.FromSeconds(1)); 

services.AddHttpClient("MyHttpClient")
    .AddPolicyHandler(rateLimitPolicy);

public class MyApiService
{
    private readonly HttpClient _httpClient;
    private readonly ILogger<MyApiService> _logger;

    public MyApiService(IHttpClientFactory httpClientFactory, ILogger<MyApiService> logger)
    {
        _httpClient = httpClientFactory.CreateClient("MyHttpClient");
        _logger = logger;
    }

    public async Task<string> GetApiDataAsync()
    {
        try
        {
            var response = await _httpClient.GetAsync("https://api.example.com/data");

            response.EnsureSuccessStatusCode();

            return await response.Content.ReadAsStringAsync();
        }
        catch (Exception ex)
        {
            _logger.LogError(ex, "Error occurred while calling the API.");
            throw;
        }
    }
}