.NET Core 微服務之Polly重試策略

接着上一篇說，正好也是最近項目裏用到了，正好拿過來整理一下,園子裏也有一些文章介紹比我詳細。

簡單介紹一下紹輕量的故障處理庫 Polly  Polly是一個.NET彈性和瞬態故障處理庫

容許咱們以很是順暢和線程安全的方式來執行諸如重試、斷路器、超時、隔離、緩存、後退等策略， 能爲咱們在微服務架構提供更穩定的服務。固然，目前的 Service Mesh 顯得更高大上，並且更強大，它更偏向從運維層面解決以上問題，不過這仍是的看具體項目中怎麼去使用和決定了。

 

在微服務架構下，咱們可能會遇到相似如下問題：

1. 某些接口異常，最終形成應用程序池奔潰；
2. 某些接口不穩定、偶爾超時，數據獲取異常；
3. 某些服務不穩定，調用方鏈接不上；
4. 某些服務異常，最終主服務掛掉（雪崩效應）；

 

 固然在實際狀況下，咱們可能只須要確保提供給用戶的服務是可用狀態，不出現 「Service Unavailable」 這樣的畫面就好。至於接口偶爾異常，可能對某些類型的項目來講並不太關鍵，用戶可能經過從新請求、刷新頁面就能夠解決，固然咱們還能夠在代碼層面作兼容，滿滿的try/catch、for/while 循環解決重試來保證更高的可靠性。

 這個時候Polly就能很好的起來做用，Polly 的使用相對比較簡單，固然仍是得看項目結構。咱們的主項目在調用微服務接口時使用了AOP，相似這種狀況下，因此調用微服務的接口都是統一入口，因此咱們只須要在AOP內加上 Polly 的一些策略，其餘代碼不用作任何修改，就能夠解決一些問題了。

安裝

Install-Package Polly

使用步驟說明

1. 定義策略
2. 執行方法

能夠看一下代碼，咱們項目主要使用的是Grpc這個框架，其餘的微服務框架，使用起來大體差很少

public void Intercept(IInvocation invocation)
{
    // some code 
    try
    {
        // 建立一個策略，若是 invocation.Proceed 的執行出現 Grpc.Core.RpcException 異常，而且 StatusCode == Grpc.Core.StatusCode.Unavailable，則重試一次
        var policy = Policy
        .Handle<Grpc.Core.RpcException>(t => t.Status.StatusCode == Grpc.Core.StatusCode.Unavailable)
        .Retry(); // 默認一次

        // 將策略應用到 invocation.Proceed 方法上
        policy.Execute(invocation.Proceed);
    }
    catch (Exception ex)
    {
        // some code 
        Console.WriteLine($"{ ex.Message},{ex.StackTrace}");
    }
}

 

 

策略條件定義

策略的執行須要依賴於條件，Polly 支持對異常與結果進行策略條件定義。

異常

// 指定某個異常
Policy
  .Handle<SomeExceptionType>();

// 指定某個異常條件
Policy
  .Handle<SomeExceptionType>(ex => ex.xxx == "xxx")

// 指定多個異常
Policy
  .Handle<SomeExceptionType1>()
  .Or<SomeExceptionType2>()

// 指定多個可能異常條件
Policy
  .Handle<SomeExceptionType1>(ex => ex.xxx1 == "xxx")
  .Or<SomeExceptionType2>(ex => ex.xxx2 == "xxx")

返回結果

// 指定某個結果
Policy
  .HandleResult<ResponseMessage>(r => r.xxx == "xxx")

// 指定多個可能的結果
Policy
  .HandleResult<ResponseMessage>(r => r.xxx1 == "xxx")
  .OrResult<ResponseMessage>(r => r.xxx2 == "xxx")

重試策略（Retry ）

// 指定異常下重試一次
Policy
  .Handle<SomeExceptionType>()
  .Retry();

// 指定異常下重試3次
Policy
  .Handle<SomeExceptionType>()
  .Retry(3);

// 指定異常下無限重試
Policy
  .Handle<SomeExceptionType>()
  .RetryForever();

// 每次重試之間等待指定的時間間隔
Policy
  .Handle<SomeExceptionType>()
  .WaitAndRetry(new[]
  {
    TimeSpan.FromSeconds(1),
    TimeSpan.FromSeconds(3),
    TimeSpan.FromSeconds(7)
  });

Retry 能夠指定一個要執行的 Action。Action 參數：exception 當前異常信息，retryCount 當前執行第幾回，context 當前執行上下文信息。

測試一下：

private static int times = 0;

public static void TestPolicy()
{
    var policy = Policy
        .Handle<Exception>()
        .Retry(3, (exception, retryCount, context) => // 出異常會執行如下代碼
        {
            Console.WriteLine($"exception:{ exception.Message}, retryCount:{retryCount}, id:{context["id"]}, name:{context["name"]}");
        });

    try
    {
        // 經過 new Context 傳遞上下文信息
        var result = policy.Execute(Test, new Context("data", new Dictionary<string, object>() { { "id", "1" }, { "name", "beck" } }));
        Console.WriteLine($"result:{result}");
    }
    catch (Exception ex)
    {
        Console.WriteLine(ex.Message);
    }
}

private static string Test()
{
    // 每執行一次加1
    times++;

    // 前2次都拋異常
    if (times < 3)
    {
        throw new Exception("exception message");
    }
    return "success";
}

測試結果：

 

能夠看到獲得了我們想要的效果，具體項目能夠具體去實施，下一篇我們接着說Polly的熔斷策略。感興趣能夠自行搜索Polly的相關文檔看看。

參考連接

• Polly
• Polly Project
• PollySamples

 

沒有彩蛋