关于c#:容错熔断的使用与扩展

@[toc]

概念
当客户端调用微服务的时候，呈现了故障，可能进行故障转移，就是容错机制。
如图：
目标
保障微服务的高可用。

二、为什么应用容错机制
故障转移机制
如图：

实现条件
- while

实现步骤

    int count = 0;
    // 故障转移
    for(int i=0;i<=3;i++)
    {
         // 判断是否达到阀值
         if (count == 3)
         {
           // 退出循环，返回异样信息
           throw  Exception("微服务重试操作超出阀值");
         } 
         // 业务代码
         try
         {
            // HttpClient 申请微服务代码
            ...................
         }
         catch(Exception  ex)
         {
             // 捕捉异样信息 
             count ++;   
         }
    }

缺点
- 性能低，耗资源
- 解决方案
  - 设置固定的次数
  - 应用熔断机制
    
    五、如何在微服务零碎中应用 Polly
熔断
- 概念
  熔断的是一个申请。
  当申请到服务器的时候，该申请重试了 3 次【测试次数】，没有申请胜利，间接熔断该申请，下次申请进来，不用再去重试，间接返回异样信息。
条件
- Polly

代码实现

条件
- 装置 Polly

步骤

装置
```
 Microsoft.Extensions.Http.Polly
```

在 Startup.cs 文件中注册

办法名 ConfigureServices

   // 异样降级信息 
     var fallBack = new HttpResponseMessage(){Content = new StringContent("零碎忙！"),
         StatusCode = 504
     };
   //5：断路器阀值
   //10：熔断工夫
   //ExecutionRejectedException: 捕捉熔断的所有异样信息
   //10：应用的线程总数
    services.AddHttpClient("micro[申请复用：自定义名称]")
        .AddPolicyHandler(Policy<HttpResponseMeaage>.Handle<ExecutionRejectedException>().Fallback(fallBack))  // 异样信息降级
        .AddPolicyHandler(Policy<HttpResponseMeaage>.Handle<Exception>().CircuitBreakerAsync(5,TimeSpan.FromSeconds(10))) // 断路器
        .AddPolicyHandler(Policy.TimeoutAsync<HttpResponseMeaage>(60))// 设置超时工夫
        .AddPolicyHandler(Policy<HttpResponseMeaage>.Handle<Exception>().RetryAsync(1))// 重试次数
        .AddPolicyHandler(Policy.BulkheadAsync<HttpResponseMeaage>(10,100));// 资源（线程）隔离  //10：应用的线程总数  100: 申请缓存总数

业务代码

    private HttpClientFactory _httpClientFactory;
    // 构造函数中注入
    构造函数(HttpClientFactory httpClientFactory)
    {_httpClientFactory = httpClientFactory;}      
    
  int count = 0;
  // 故障转移
  for(int i=0;i<=3;i++)
  {
       // 判断是否达到阀值
       if (count == 3)
       {
         // 退出循环，返回异样信息
         throw  Exception("微服务重试操作超出阀值");
       } 
       // 业务代码 
       try
       {
         // 微服务申请
         HttpClient client = _httpClientFactory.CreateClient("micro");
         .........
       }
       catch(HttpRequestException  ex)
       {  
           // 捕捉异样信息 
           count ++;   
       }
  }

如果在聚合微服务中同时调用了两个微服务，当第一个服务挂掉，为了不影响前面的服务调用，咱们要做服务隔离，代码如下：

在 Startup.cs 文件中注册

办法名 ConfigureServices

    services.AddHttpClient("依据不同的服务定义不同的名称")
              .AddPolicyHandler(Policy<HttpResponseMeaage>.Handle<ExecutionRejectedException>().Fallback(fallBack))  // 异样信息降级
              .AddPolicyHandler(Policy<HttpResponseMeaage>.Handle<Exception>().CircuitBreakerAsync(5,TimeSpan.FromSeconds(10))) // 断路器
              .AddPolicyHandler(Policy.TimeoutAsync<HttpResponseMeaage>(60))// 设置超时工夫
              .AddPolicyHandler(Policy<HttpResponseMeaage>.Handle<Exception>().RetryAsync(1))// 重试次数
              .AddPolicyHandler(Policy.Bulkhead<HttpResponseMeaage>(10,100));// 资源隔离

== 留神：当 http 申请的时候，申请各自服务的名称必须和注册名称统一。==

调用方代码

  HttpClient client = _httpClientFactory.CreateClient("依据不同的服务定义不同的名称");

关于c#:容错熔断的使用与扩展

一、容错机制的介绍

二、为什么应用容错机制

三、如何在微服务中利用容错机制

四、容错机制的缺点

五、如何在微服务零碎中应用 Polly

六、微服务容错机制 Polly 扩大