弹性和瞬态故障处理

polly项目是一个基于.NET开发的用来处理瞬态故障的库,我们可以借助这个库以线程安全的形式实现重试、断路、超时、隔离和回退策略.

polly的安装

在Nuget中下载Polly安装包,安装成功即可使用

  1. Install-Package Polly
  • 异常重试是最常使用的一个策略,其功能是当我们执行的方法体发生异常时,可以按照我们指定的次数进行重试

polly的使用

1、指定需要处理的异常

可以指定捕获执行的任务的异常类型,若执行任务的异常类型满足指定异常,那么重试机制将会生效

  1. var policy = Policy.Handle<Exception>()

2、指定重试次数和监控重试

指定整个执行过程中需要重试多少次,且可以监控每次的重试信息,比如重试次数 异常以及重试的上下文信息

  1. .WaitAndRetryAsync(3, retryAttempt => TimeSpan.FromSeconds(2), (exception, retryCount) =>

3、指定执行的任务

指定执行的任务是整个异常重试的核心和监控对象,Execute支持多种重载.。

  1. var result = policy.ExecuteAsync(() => Test());
  2. class Program
  3. {
  4. private static void Main(string[] args)
  5. {
  6. //var policy = Policy.Handle<Exception>()
  7. // .WaitAndRetryAsync(3, retryAttempt => TimeSpan.FromSeconds(2), (exception, retryCount) =>
  8. // {
  9. // NLogger.Error(exception.ToString()+"------"+ $"第{retryCount}次重试");
  10. // });
  11. var policy = Policy
  12. .Handle<Exception>()
  13. .RetryAsync(2, async (exception, retryCount) =>
  14. {
  15. Console.WriteLine("333333:" + exception.Message + "------" + $"第{retryCount}次重试");
  16. });
  17. var result = policy.ExecuteAsync(() => Test());
  18. //string r = result.ToString();
  19. Console.WriteLine("444444:");
  20. Console.ReadKey();
  21. }
  22. private static async Task Test()
  23. {
  24. //try
  25. //{
  26. Convert.ToInt32("w");
  27. using (var httpClient = new HttpClient())
  28. {
  29. var response = httpClient.GetAsync("http://news.cnblogs.com/Category/GetCategoryList?bigCateId=11&loadType=0").Result;
  30. var s= await response.Content.ReadAsStringAsync();
  31. Console.WriteLine("111111:"+s);
  32. }
  33. // return "url";
  34. //}
  35. //catch (Exception ex)
  36. //{
  37. // throw new Exception();
  38. // Console.WriteLine("222222:" + ex.Message);
  39. // return null;
  40. //}
  41. //
  42. }
  43. }
  44. }