一、Polly介紹

官方對 Polly 的介紹是這樣的：

Polly is a .NET resilience and transient-fault-handling library that allows developers to express policies such as Retry, Circuit Breaker, Timeout, Bulkhead Isolation, and Fallback in a fluent and thread-safe manner.

翻譯過來大概意思是：Polly 是一個 .NET 彈性和瞬態(tài)故障處理庫，允許開發(fā)人員以 Fluent 和線程安全的方式來實現(xiàn)重試、斷路、超時、隔離和回退策略。

二、Polly 的七種策略

Polly 可以實現(xiàn)重試、斷路、超時、隔離、回退和緩存策略

1、重試（Retry）

出現(xiàn)故障自動重試

//捕捉到錯誤，自動重試三次
Policy.Handle<Exception>()
 .Retry(3, (exception, retryCount) =>
 {
     Console.WriteLine(DateTime.Now + $"代碼異常: {exception},開始第 {retryCount} 次重試。");
 });

2、 斷路（Circuit-breaker）

當系統(tǒng)遇到嚴重問題時，快速回饋失敗比讓用戶/調用者等待要好，限制系統(tǒng)出錯的體量，有助于系統(tǒng)恢復。比如，當我們去調一個第三方的 API，有很長一段時間 API 都沒有響應，可能對方服務器癱瘓了。如果我們的系統(tǒng)還不停地重試，不僅會加重系統(tǒng)的負擔，還會可能導致系統(tǒng)其它任務受影響。所以，當系統(tǒng)出錯的次數(shù)超過了指定的閾值，就要中斷當前線路，等待一段時間后再繼續(xù)。

//捕捉到同一個異常兩次時，就停下來，等待 1 分鐘后再繼續(xù)
Policy.Handle<SomeException>()    
.CircuitBreaker(2, TimeSpan.FromMinutes(1));

3、 超時（Timeout）

當系統(tǒng)超過一定時間的等待，我們就幾乎可以判斷不可能會有成功的結果。比如平時一個網(wǎng)絡請求瞬間就完成了，如果有一次網(wǎng)絡請求超過了 30 秒還沒完成，我們就知道這次大概率是不會返回成功的結果了。因此，我們需要設置系統(tǒng)的超時時間，避免系統(tǒng)長時間做無謂的等待。

//這里設置了超時時間不能超過 30 秒，否則就認為是錯誤的結果，并執(zhí)行回調
Policy.Timeout(30, onTimeout: (context, timespan, task) => 
{   
    Console.WriteLine("30秒無響應，需要執(zhí)行的邏輯");
});

4、 隔離（Bulkhead Isolation）

當系統(tǒng)的一處出現(xiàn)故障時，可能促發(fā)多個失敗的調用，很容易耗盡主機的資源(如 CPU)。下游系統(tǒng)出現(xiàn)故障可能導致上游的故障的調用，甚至可能蔓延到導致系統(tǒng)崩潰。所以要將可控的操作限制在一個固定大小的資源池中，以隔離有潛在可能相互影響的操作。

//這個策略是最多允許 10 個線程并發(fā)執(zhí)行，如果執(zhí)行被拒絕，則執(zhí)行回調
Policy.Bulkhead(10, context => 
{   
     Console.WriteLine("當前線程超過10個，需要執(zhí)行的邏輯");
});

5、 回退（Fallback）

有些錯誤無法避免，就要有備用的方案。這個就像瀏覽器不支持一些新的 CSS 特性就要額外引用一個 polyfill 一樣。一般情況，當無法避免的錯誤發(fā)生時，我們要有一個合理的返回來代替失敗。

//當用戶沒有填寫名稱時，我們就給他一個默認名稱，這種策略可以這樣定義：
Policy.Handle<Whatever>()   
.Fallback<User>(() => User.GetDefaultName())

6、 緩存（Cache）

一般我們會把頻繁使用且不會怎么變化的資源緩存起來，以提高系統(tǒng)的響應速度。如果不對緩存資源的調用進行封裝，那么我們調用的時候就要先判斷緩存中有沒有這個資源，有的話就從緩存返回，否則就從資源存儲的地方（比如數(shù)據(jù)庫）獲取后緩存起來，再返回，而且有時還要考慮緩存過期和如何更新緩存的問題。Polly 提供了緩存策略的支持，使得問題變得簡單。

//這是官方的一個使用示例用法，
//它定義了緩存 5 分鐘過期的策略，然后把這個策略應用在指定的 Key（即 `FooKey`）上。
var memoryCacheProvider = new MemoryCacheProvider(myMemoryCache); 
var cachePolicy = Policy.Cache(memoryCacheProvider, TimeSpan.FromMinutes(5)); 
TResult result = cachePolicy.Execute(context => getFoo(), new Context("FooKey"));

7、 策略包（Policy Wrap）

一種操作會有多種不同的故障，而不同的故障處理需要不同的策略。這些不同的策略必須包在一起，作為一個策略包，才能應用在同一種操作上。也就是 Polly 的彈性，即各種不同的策略能夠靈活地組合起來。

//先是把預先定義好的多種不同的策略包在一起，作為一個整體策略，然后應用在同一個操作上。
var policyWrap = Policy  
.Wrap(fallback, cache, retry, breaker, timeout, bulkhead); 
policyWrap.Execute(() =>
{
    Console.WriteLine("多種策略共同執(zhí)行的邏輯");
});

三、簡單代碼示例

備注：先引入Nuget包（Polly）

 //創(chuàng)建一個策略，用于處理異常,并進行重試
 public static Policy policy = Policy.Handle<Exception>()
 .Retry(3, (exception, retryCount) =>
 {
     Console.WriteLine(DateTime.Now + $"代碼異常: {exception},開始第 {retryCount} 次重試。");
 });
 
 
  public async Task Execute()
  {
     //重試機制
     policy.Execute(() =>  //這里接收一個委托方法，也就是捕捉到異常之后要執(zhí)行的業(yè)務邏輯
     {
         Console.WriteLine("重試");
     });
  }
  

以上就是C#調用Polly庫實現(xiàn)捕捉異常處理的操作代碼的詳細內容，更多關于C# Polly庫捕捉異常的資料請關注腳本之家其它相關文章！

最新評論