隨着微服務的流行，熔斷作為其中一項很重要的技術也廣為人知。當微服務的運行質量低於某個臨界值時，啟動熔斷機制，暫停微服務調用一段時間，以保障后端的微服務不會因為持續過負荷而宕機。本文介紹了新一代熔斷器Resilience4j如何使用。
譯者注：Hystrix官方已經停止開發了，Hystrix官方推薦使用新一代熔斷器作為Resilience4j。作為新一代的熔斷器，Resilience4j有很多優勢，比如依賴少，模塊化程度較好等優勢。本文是關於resilience4j的初學者指南。
resilience4j是受Hystrix啟發而做的熔斷器，通過管理遠程調用的容錯處理來幫助實現一個健壯的系統。resilience4j提供了更好用的API，並且提供了很多其他功能比如Rate Limiter（限流器）,Bulkhead（艙壁隔離）。
設置Maven
添加依賴如下：
這里僅僅添加了熔斷器模塊，其他模塊可以點擊這里[1]。
熔斷器
使用這部分功能，需要引入上文所述的依賴。熔斷器模式可以幫助我們在遠程服務出故障時防止故障級聯。
在多次請求失敗后，我們就認為服務不可用/超載，並且對之后的請求進行短路處理，這樣我們就能節約系統資源。
我們看看resilience4j如何做到這一點。
首先需要定義使用的設置，我們先使用默認設置：
當然你也可以自定義一些參數：
這里我們設置ratethreshold為20%，最小5次重試。
然后我們創建一個熔斷器對象，並調用遠程服務：
通過junit進行測試，我們會調用服務10次，可以驗證服務至少調用5次，如果有20%的失敗的情況下，會停止調用。
熔斷器狀態及設置
熔斷器有三種可能狀態：
-
關閉— 服務正常，不需要進行短路
-
打開— 遠程服務宕機，所有請求都短路
-
半開— 進入打開狀態一段時間后，熔斷器允許檢查遠程服務是否恢復
可以做以下設置：
-
熔斷器進入打開狀態的閾值
-
等待時間，即熔斷器進入打開狀態到半開狀態需要等待的時間
-
熔斷器半開或者閉合時，ring buffer的大小
-
處理自定義事件的監聽器
-
自定義謂詞，用於評估異常是否應算作故障，從而提高故障率
限流器
這里需要引入resilience4j-ratelimiter[2]依賴。可以允許限制對某些服務的訪問。
所有對decorateFunction的調用都符合rate limiter.
我們可以配置參數如下：
-
limit刷新周期
-
刷新周期的權限限制
-
默認等待權限持續時間
艙壁隔離
這里需要引入resilience4j-bulkhead[3]依賴。可以限制對特定服務的並發調用數。
讓我們看一個使用Bulkhead API配置並發調用的示例：
為了測試，我們可以調用一個mock服務的方法。這種情況下，我們就不允許其他調用：
我們可以做如下設置：
-
允許的最大並行數
-
線程等待的最大時間
重試
需要引入resilience4j-retry[4]庫。可以在調用失敗后自動重試：
現在我們模擬遠程調用失敗，並確認自動重試：
我們可以做如下設置：
-
最大嘗試數
-
重試前等待時間
-
自定義函數，用於修改故障后的等待間隔。
-
自定義謂詞，用於評估異常是否應重試
緩存
cache模塊需要引入resilience4j-cache[5]依賴。初始化代碼與眾不同：
這里的緩存是通過使用的JSR-107 Cache實現完成的，Resilience4j提供了使用緩存的方法。
請注意，沒有用於裝飾功能的API（如Cache.decorateFunction（Function）），API僅支持Supplier和Callable類型。
限時器
該模塊需要引入resilience4j-timelimiter[6]依賴。可以使用TimeLimiter限制調用遠程服務所花費的時間。
我們設置超時時間為1毫秒的TimeLimiter：
使用Future.get()驗證是否如預期超時：
可以和熔斷器組合使用：
附加模塊
Resilience4j還提供了許多附加模塊，可以簡化與流行框架和庫的集成。
一些比較知名的集成是：
-
Spring Boot - resilience4j-spring-boot模塊
-
Ratpack - resilience4j-ratpack模塊
-
Retrofit - resilience4j-Retrofit模塊
-
Vertx - resilience4j-vertx模塊
-
Dropwizard - resilience4j-metrics模塊
-
Prometheus - resilience4j-prometheus模塊
結論
在本文中，我們了解了Resilience4j庫的不同方面，並學習了如何使用它來解決服務器間通信中的各種容錯問題。源代碼和更多示例可以在這里[5]找到。
文中鏈接：
[1]https://search.maven.org/classic/#search%7Cga%7C1%7Cg%3A%22io.github.resilience4j%22
[2]https://search.maven.org/classic/#search%7Cga%7C1%7Ca%3A%22resilience4j-ratelimiter%22
[3]https://search.maven.org/classic/#search%7Cga%7C1%7Cresilience4j-bulkhead
[4]https://search.maven.org/classic/#search%7Cga%7C1%7Cresilience4j-retry
[5]https://search.maven.org/classic/#search%7Cga%7C1%7Cresilience4j-cache
[6]https://search.maven.org/classic/#search%7Cga%7C1%7Cresilience4j-timelimiter
[7]https://github.com/eugenp/tutorials/tree/master/libraries
原文地址：
https://www.baeldung.com/resilience4j
本文作者baeldung，由方圓翻譯。