Polly简单使用

(相关资料图)

简介

Polly 是一个针对 .NET 应用程序的库，提供了一系列经过优化的故障处理策略，帮助开发人员实现重试、断路器、超时和熔断机制等。通过 Polly 库，开发人员可以更容易地编写鲁棒性更强、更可靠的应用程序。

Retry 策略

当出现异常或错误时，自动重试指定次数。

static void Main(){try{//捕获DivideByZeroException异常会重试三次var retryTwoTimesPolicy = Policy//处理多个异常类型通过OR即可 .Handle().Or() .Retry(3, (ex, count) => { Console.WriteLine("执行失败! 重试次数 {0}", count); Console.WriteLine("异常来自 {0}", ex.GetType().Name); });retryTwoTimesPolicy.Execute(() =>{var a = 0;return 1 / a;});}catch (Exception ex){//第四次异常不做处理，抛出异常Console.WriteLine($"catch {ex.GetType().Name}");}finally{Console.WriteLine($"finally");}}

static void Main(){try{//捕获DivideByZeroException异常会重试三次var retryTwoTimesPolicy = Policy //处理多个异常类型通过OR即可 .Handle().Or() //添加重新间隔 .WaitAndRetry(new[] {TimeSpan.FromSeconds(1),TimeSpan.FromSeconds(3),TimeSpan.FromSeconds(5), }, (ex, TimeSpan) => { Console.WriteLine($"执行失败! 执行间隔 {TimeSpan} {DateTime.Now}"); Console.WriteLine($"异常来自 {ex.GetType().Name}"); });retryTwoTimesPolicy.Execute(() =>{var a = 0;return 1 / a;});}catch (Exception ex){Console.WriteLine($"catch {ex.GetType().Name}");}finally{Console.WriteLine($"finally");}}

Timeout 策略

在规定时间内未获取到响应时，自动取消请求并抛出超时异常。

static async Task Main(){// 创建超时策略，等待最多 1 秒钟// 如果在等待时间内未完成操作，则会抛出 TimeoutRejectedException 异常。var timeoutPolicy = Policy.TimeoutAsync(TimeSpan.FromSeconds(1), TimeoutStrategy.Pessimistic);try{// 在超时策略中执行操作await timeoutPolicy.ExecuteAsync(async (ct) =>{using (HttpClient httpClient = new HttpClient()){var response = await httpClient.GetAsync("https://www.example.com", ct);// 处理响应结果response.EnsureSuccessStatusCode();var content = await response.Content.ReadAsStringAsync(ct);Console.WriteLine(content);}}, CancellationToken.None);/* * 最后，我们使用 ExecuteAsync 方法，在组合策略中执行异步操作，并在 CancellationToken 参数中传递 CancellationToken.None 来允许取消操作。 * 如果在指定的等待时间内没有得到响应，则会抛出 TimeoutRejectedException 异常。如果操作失败，则会捕获异常并输出相应的信息。 */}catch (TimeoutRejectedException){Console.WriteLine("The operation timed out.");}catch (Exception ex){Console.WriteLine($"Exception caught: {ex.GetType().Name}");}}

Circuit Breaker 策略

当某个远程服务发生异常或错误时，自动跳闸断路，避免进一步请求对该服务造成负载压力和损害。

static async Task Main(){//连续失败 5 次，那么断路器会被打开，并保持 5 秒钟的打开状态时间，防止继续执行相同的操作var circuitBreakerPolicy = Policy.Handle().CircuitBreaker(5, TimeSpan.FromSeconds(5));// 对多个操作使用相同的断路器策略for (int i = 0; i < 20; i++){try{await Task.Delay(TimeSpan.FromSeconds(1));// 尝试执行某些可能会抛出异常的操作circuitBreakerPolicy.Execute(() =>{// TODO: 执行某些操作，可能会抛出异常throw new Exception($"异常");});}catch (Exception ex){// 断路器开启，操作被拒绝Console.WriteLine($"time:{DateTime.Now} Num:{i} failed: {ex.Message}");}}}

Microsoft.Extensions.Http.Polly

是基于 Polly 的一个 ASP.NET Core HttpClient 工厂的扩展库，它能够为应用程序提供简单易用的、可扩展的 HTTP 客户端工厂，并且可以很容易地实现重试、熔断、超时等策略。

var retryPolicy = HttpPolicyExtensions   .HandleTransientHttpError()   .Or() // thrown by Polly"s TimeoutPolicy if the inner execution times out   .RetryAsync(3);var timeoutPolicy = Policy.TimeoutAsync(10);//更方便的使用polliyservices.AddHttpClient("example.com", c => c.BaseAddress = new Uri("http://example.com"))  .AddPolicyHandler(retryPolicy)  .AddPolicyHandler(timeoutPolicy);

参考

https://github.com/App-vNext/Pollyhttps://github.com/App-vNext/Polly.Extensions.Http/blob/master/README.md