如何使用polly在.Net内核中进行动态抖动等待和重试

var delay = Backoff.DecorrelatedJitterBackoffV2(medianFirstRetryDelay: TimeSpan.FromSeconds(1), retryCount: 3);
var retryPolicy = Policy.Handle<FooException>().WaitAndRetryAsync(delay);

public class Startup : FunctionsStartup
    public override void Configure(IFunctionsHostBuilder builder)
        var configuration = builder.GetContext().Configuration;
        builder.Services.RegisterService(configuration);
}

public static IHttpClientBuilder RegisterService(this IServiceCollection serviceCollection,IConfiguration configuration)
    return serviceCollection.AddHttpClient<IService, Service()
               .AddPolicyHandler(RetryPolicyHandler.GetRetryPolicy())
public static IAsyncPolicy<HttpResponseMessage> GetRetryPolicy(IConfiguration configuration)
    var delay =Backoff.DecorrelatedJitterBackoffV2(medianFirstRetryDelay: TimeSpan.FromSeconds(1), retryCount: 3);
    return HttpPolicyExtensions.HandleTransientHttpError().WaitAndRetryAsync(delay);
}

var sleepDurations = delay.ToArray();

await client.GetAsync("http://httpstat.us/408");
await client.GetAsync("http://httpstat.us/408");

.WaitAndRetryAsync(Backoff.DecorrelatedJitterBackoffV2(medianFirstRetryDelay: TimeSpan.FromSeconds(1), retryCount: 3),
    onRetry: (dr, ts) => {
        Console.WriteLine($"Delay: {ts}"); //Replace this with ILogger                     
    })

Delay: 00:00:00.4752054
Delay: 00:00:01.2825508
Delay: 00:00:03.1409815

如何使用polly在.Net内核中进行动态抖动等待和重试

1 个回答