一、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 是一個(gè) .NET 彈性和瞬態(tài)故障處理庫，允許開發(fā)人員以 Fluent 和線程安全的方式來實(shí)現(xiàn)重試、斷路、超時(shí)、隔離和回退策略。

二、Polly 的七種策略

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

1、重試（Retry）

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

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

2、 斷路（Circuit-breaker）

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

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

3、 超時(shí)（Timeout）

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

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

4、 隔離（Bulkhead Isolation）

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

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

5、 回退（Fallback）

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

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

6、 緩存（Cache）

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

//這是官方的一個(gè)使用示例用法，
//它定義了緩存 5 分鐘過期的策略，然后把這個(gè)策略應(yīng)用在指定的 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）

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

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

三、簡單代碼示例

備注：先引入Nuget包（Polly）

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

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

最新評論