.NET 開源項目 Polly 介紹

来源:https://www.cnblogs.com/88223100/archive/2020/03/16/polly.html
-Advertisement-
Play Games

本文先是對 Polly 做了一個簡單介紹,通過一個例子讓大家知道了 Polly 的基本用法和步驟,然後分別介紹了 Polly 的七種策略。其實 Polly 遠比本文講的要強大,但由於篇幅的限制和精力有限,只能籠統地給大家做個介紹,更多的應用場景還需要結合實際的例子才能講清楚。要深入研究,可以前往查看... ...


今天介紹一個 .NET 開源庫:Polly,它是支持 .NET Core 的,目前在 GitHub 的 Star 數量已經超過 7 千,它是一個強大且實用的 .NET 庫。

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 彈性和瞬態故障處理庫,允許開發人員以 Fluent 和線程安全的方式來實現重試、斷路、超時、隔離和回退策略。

這個描述有點抽象,我們一起來理解一下。

首先這裡的說的瞬態故障包含了程式發生的異常和出現不符合開發者預期的結果。所謂瞬態故障,就是說故障不是必然會發生的,而是偶然可能會發生的,比如網路偶爾會突然出現不穩定或無法訪問這種故障。至於彈性,就是指應對故障 Polly 的處理策略具有多樣性和靈活性,它的各種策略可以靈活地定義和組合。

下麵來演示一個例子,大家就更清楚了。

故障處理策略示例

安慣例,創建一個空的 Console 項目,和安裝 NuGet 包:

Install-Package Polly

Polly 的異常處理策略的基本用法可以分為三個步驟,步驟說明包含在下麵代碼中:

static void Main(string[] args)
{
   Policy
       // 1. 指定要處理什麼異常
       .Handle<HttpRequestException>()
       //    或者指定需要處理什麼樣的錯誤返回
       .OrResult<HttpResponseMessage>(r => r.StatusCode == HttpStatusCode.BadGateway)
       // 2. 指定重試次數和重試策略
       .Retry(3, (exception, retryCount, context) =>
       {
           Console.WriteLine($"開始第 {retryCount} 次重試:");
       })
       // 3. 執行具體任務
       .Execute(ExecuteMockRequest);

   Console.WriteLine("程式結束,按任意鍵退出。");
   Console.ReadKey();
}

static HttpResponseMessage ExecuteMockRequest()
{
   // 模擬網路請求
   Console.WriteLine("正在執行網路請求...");
   Thread.Sleep(3000);
    // 模擬網路錯誤
   return new HttpResponseMessage(HttpStatusCode.BadGateway);
}

從例子中可以看到,Polly 的 API 支持流式(Fluent)調用,使用起來很方便。這個示例對錯誤處理的策略很簡單,當發生請求異常或網路錯誤時,就重試 3 次。我們可以從下麵的運行結果圖看到這個策略的執行過程:

下麵具體來看 Polly 支持的各種故障處理策略。

Polly 的七種策略

Polly 可以實現重試、斷路、超時、隔離、回退和緩存策略,下麵給出這些策略的應用場景說明和基本使用方法。

重試(Retry)

出現故障自動重試,這個是很常見的場景,上面也已經給出例子了,這裡不再細述。

斷路(Circuit-breaker)

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

下麵是一個基本的斷路策略的使用方式:

Policy.Handle<SomeException>()
   .CircuitBreaker(2, TimeSpan.FromMinutes(1));

這句代碼設定的策略是,當系統出現兩次某個異常時,就停下來,等待 1 分鐘後再繼續。這是基本的用法,你還可以在斷路時定義中斷的回調和重啟的回調。

超時(Timeout)

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

下麵是超時策略的一個基本用法:

Policy.Timeout(30, onTimeout: (context, timespan, task) =>
{
   // do something
});

這裡設置了超時時間不能超過 30 秒,否則就認為是錯誤的結果,並執行回調。

隔離(Bulkhead Isolation)

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

下麵是隔離策略的一個基本用法:

Policy.Bulkhead(12, context =>
{
   // do something
});

這個策略是最多允許 12 個線程併發執行,如果執行被拒絕,則執行回調。

回退(Fallback)

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

比如很常見的一個場景是,當用戶沒有上傳頭像時,我們就給他一個預設頭像,這種策略可以這樣定義:

Policy.Handle<Whatever>()
  .Fallback<UserAvatar>(() => UserAvatar.GetRandomAvatar())

緩存(Cache)

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

var memoryCacheProvider = new MemoryCacheProvider(myMemoryCache);
var cachePolicy = Policy.Cache(memoryCacheProvider, TimeSpan.FromMinutes(5));
TResult result = cachePolicy.Execute(context => getFoo(), new Context("FooKey"));

這是官方的一個使用示例用法,它定義了緩存 5 分鐘過期的策略,然後把這個策略應用在指定的 Key(即 FooKey)上。

這一塊內容值得用一整篇的內容來講,下次有機會再詳細講講 Polly 的緩存策略。

策略包(Policy Wrap)

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

策略包的基本用法是這樣的:

var policyWrap = Policy
 .Wrap(fallback, cache, retry, breaker, timeout, bulkhead);
policyWrap.Execute(...);

先是把預先定義好的多種不同的策略包在一起,作為一個整體策略,然後應用在同一個操作上。

總結

本文先是對 Polly 做了一個簡單介紹,通過一個例子讓大家知道了 Polly 的基本用法和步驟,然後分別介紹了 Polly 的七種策略。其實 Polly 遠比本文講的要強大,但由於篇幅的限制和精力有限,只能籠統地給大家做個介紹,更多的應用場景還需要結合實際的例子才能講清楚。要深入研究,可以前往查看 Polly 的 GitHub 主頁和 Wiki 文檔。

參考:

 

http://www.thepollyproject.org

https://github.com/App-vNext/Polly

https://github.com/App-vNext/Polly/wiki

 

原文鏈接:https://www.cnblogs.com/willick/p/polly.html

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 2020Python作業八——文件處理3—b模式的文件讀寫操作 @2020.3.16 #1、通用文件copy工具實現 #2、基於seek控制指針移動,測試r+、w+、a+模式下的讀寫內容 r(預設的操作模式):只讀模式,當文件不存在時報錯,當文件存在時文件指針跳到開始位置 w:只寫模式,當文件不存在 ...
  • 本人免費整理了Java高級資料,涵蓋了Java、Redis、MongoDB、MySQL、Zookeeper、Spring Cloud、Dubbo高併發分散式等教程,一共30G,需要自己領取。傳送門:https://mp.weixin.qq.com/s/osB-BOl6W-ZLTSttTkqMPQ 前 ...
  • 記錄一下 之坑 。 今早部署代碼到測試環境之後,測試需求的時候出現了 ,發現是獲取字體路徑的時候報錯了,很奇怪,在本地調試的時候並未發現此問題。 錯誤日誌: 問題代碼如下: 排查發現問題如下: 這是因為打包後Spring試圖訪問文件系統路徑,但無法訪問JAR中的路徑。 解決辦法: 使用 解決問題。 ...
  • 作為程式員界的一枚小菜鳥,可謂是,從大量的 CRUD 業務中,練就了一身複製粘貼即可用的本領。 因為大家不是都說:程式 = 複製 + 百度 嗎,再高級一點的就是複製 + 谷歌嘍。(我不禁想,難道科學^上網就高級了?) 反正都是拿來主義嘛,代碼能跑起來就完事,實在不行,刪庫跑路也很輕鬆呀 ^_^。 但 ...
  • 上篇文章中我們梳理了ChannelPipeline中入站事件的傳播,這篇文章中我們看下出站事件的傳播,也就是ChannelOutboundHandler介面的實現。 1、出站事件的傳播示例 我們對上篇文章中的示例代碼進行改造,在ChannelPipeline中加入ChannelOutboundHan ...
  • 結合此篇參考 "Spring框架學習筆記(9)——API介面設計相關知識及具體編碼實現" 在使用Spring Boot進行接收參數的時候,發現了許多問題,之前一直都很忙,最近才稍微有空研究一下此問題。 網上的大多數文章,只講Spring Boot如何實現接受參數,卻不講如何在客戶端調用, 本篇使用J ...
  • 概要: C#中將數據類型分為值類型(value type)和引用類型(reference type) 值類型: 值類型變數直接包含其本身的數據。在定義一個值類型變數後,將直接為該變數分配空間,可以直接賦值和使用。 列舉值類型: eg: 用變數“a”為變數“b”賦值,是將“a”所在記憶體的值複製給“b” ...
  • 最近在學習C# Socket相關的知識,學習之餘,動手做了一個簡單的區域網聊天器。有萌生做這個的想法,主要是由於之前家裡兩臺電腦之間想要傳輸文件十分麻煩,需要藉助QQ,微信或者其他第三方應用,基本都要登錄,而且可能傳輸的文件還有大小限制,壓縮問題。所以本聊天器的首要目標就是解決這兩個問題,做到使用方... ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...