Spring Cloud熔斷機制之斷路器的示例分析

這篇文章主要介紹Spring Cloud熔斷機制之斷路器的示例分析，文中介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們一定要看完！

斷路器（Curcuit Breaker）模式

在分布式環境下，特別是微服務結構的分布式系統中， 一個軟件系統調用另外一個遠程系統是非常普遍的。這種遠程調用的被調用方可能是另外一個進程，或者是跨網路的另外一臺主機, 這種遠程的調用和進程的內部調用最大的區別是，遠程調用可能會失敗，或者掛起而沒有任何回應，直到超時。更壞的情況是， 如果有多個調用者對同一個掛起的服務進行調用，那么就很有可能的是一個服務的超時等待迅速蔓延到整個分布式系統，引起連鎖反應， 從而消耗掉整個分布式系統大量資源。最終可能導致系統癱瘓。

斷路器（Circuit Breaker）模式就是為了防止在分布式系統中出現這種瀑布似的連鎖反應導致的災難。

一旦某個電器出問題，為了防止災難，電路的保險絲就會熔斷。斷路器類似于電路的保險絲， 實現思路非常簡單，可以將需要保護的遠程服務嗲用封裝起來，在內部監聽失敗次數， 一旦失敗次數達到某閥值后，所有后續對該服務的調用，斷路器截獲后都直接返回錯誤到調用方，而不會繼續調用已經出問題的服務， 從而達到保護調用方的目的, 整個系統也就不會出現因為超時而產生的瀑布式連鎖反應。

1. 基本模式

上圖是斷路器（Curcuit Breaker）的結構，它有兩個基本狀態（close和open）和一個基本trip動作：

close狀態下， client向supplier發起的服務請求， 直接無阻礙通過斷路器， supplier的返回值接直接由斷路器交回給client.

open狀態下，client向supplier發起的服務請求后，斷路器不會將請求轉到supplier, 而是直接返回client, client和supplier之間的通路是斷的

trip: 在close狀態下，如果supplier持續超時報錯， 達到規定的閥值后，斷路器就發生trip, 之后斷路器狀態就會從close進入open.

 2. 擴展模式

基本的斷路器模式下，保證了斷路器在open狀態時，保護supplier不會被調用， 但我們還需要額外的措施可以在supplier恢復服務后，可以重置斷路器。一種可行的辦法是斷路器定期探測supplier的服務是否恢復， 一但恢復， 就將狀態設置成close。斷路器進行重試時的狀態為半開（half-open）狀態。

3. 斷路器的使用場合：

一個supplier一般很穩定，如果一旦故障發生后， 檢查和恢復需要的時間比較長，通常無法短時間內快速修復的，那么這種服務比較適合采用斷路器模式。否則很可能導致ping-pong效應。

3. 斷路器不適合的場合：

 為了防止一個應用程序試圖調用一個遠程服務或訪問共享資源，如果該操作是極有可能失敗， 這種模式可能不適合。

對于處理中的應用程序訪問本地專用資源，例如在存儲器內數據結構。在這種環境下通常也不適合，使用斷路器只會增加系統開銷。

下面直接介紹Spring Cloud的斷路器如何使用。

SpringCloud Netflix實現了斷路器庫的名字叫Hystrix. 在微服務架構下，通常會有多個層次的服務調用.下面是微服架構下, 瀏覽器端通過API訪問后臺微服務的一個示意圖：

一個微服務的超時失敗可能導致瀑布式連鎖反映，下圖中，Hystrix通過自主反饋實現的斷路器，防止了這種情況發生。

圖中的服務B因為某些原因失敗，變得不可用，所有對服務B的調用都會超時。當對B的調用失敗達到一個特定的閥值(5秒之內發生20次失敗是Hystrix定義的缺省值), 鏈路就會被處于open狀態， 之后所有所有對服務B的調用都不會被執行， 取而代之的是由斷路器提供的一個表示鏈路open的Fallback消息. Hystrix提供了相應機制，可以讓開發者定義這個Fallbak消息.

open的鏈路阻斷了瀑布式錯誤， 可以讓被淹沒或者錯誤的服務有時間進行修復。這個fallback可以是另外一個Hystrix保護的調用, 靜態數據，或者合法的空值. Fallbacks可以組成鏈式結構，所以，最底層調用其它業務服務的第一個Fallback返回靜態數據.

下面，進入正題，在之前的兩HELLO WORLD服務集群中加入斷路器， 防止其中一個Hello world掛掉后， 導致系統發生連鎖超時失敗。

1. 在maven工程（前面章節中介紹的Ribbon或者Feign工程）的pom.xml中添加hystrix庫支持斷路器

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-hystrix</artifactId>
</dependency>

2.在Ribbon應用中使用斷路器

1). 在Spring Boot啟動類上添加@EnableCircuitBreaker注解

@SpringBootApplication
@EnableDiscoveryClient
@EnableCircuitBreaker
public class ServiceRibbonApplication {

  public static void main(String[] args) {
    SpringApplication.run(ServiceRibbonApplication.class, args);
  }

2). 用@HystrixCommand注解標注訪問服務的方法

@Service
public class HelloService {
  @Autowired RestTemplate restTemplate;

  @HystrixCommand(fallbackMethod = "serviceFailure")
  public String getHelloContent() {
    return restTemplate.getForObject("http://SERVICE-HELLOWORLD/",String.class);
  }

  public String serviceFailure() {
    return "hello world service is not available !";
  }
}

@HystrixCommand注解定義了一個斷路器，它封裝了getHelloContant()方法， 當它訪問的SERVICE-HELLOWORLD失敗達到閥值后，將不會再調用SERVICE-HELLOWORLD， 取而代之的是返回由fallbackMethod定義的方法serviceFailure（）。@HystrixCommand注解定義的fallbackMethod方法，需要特別注意的有兩點：

第一， fallbackMethod的返回值和參數類型需要和被@HystrixCommand注解的方法完全一致。否則會在運行時拋出異常。比如本例中，serviceFailure（）的返回值和getHelloContant()方法的返回值都是String。

第二， 當底層服務失敗后，fallbackMethod替換的不是整個被@HystrixCommand注解的方法（本例中的getHelloContant), 替換的只是通過restTemplate去訪問的具體服務。可以從中的system輸出看到， 即使失敗，控制臺輸出里面依然會有“call SERVICE-HELLOWORLD”。

啟動eureka服務，只啟動兩個Helloworld服務，然后中斷其中一個（模擬其中一個微服務掛起），訪問http://localhost:8901/然后刷新, 由于有負載均衡可以看到以下兩個頁面交替出現。可以看到第二個被掛起的服務，被定義在Ribbon應該里面的錯誤處理方法替換了。

4. 在Feign應用中使用斷路器

1）. Feign內部已經支持了斷路器，所以不需要想Ribbon方式一樣，在Spring Boot啟動類上加額外注解

2）. 用@FeignClient注解添加fallback類， 該類必須實現@FeignClient修飾的接口。

@FeignClient(name = "SERVICE-HELLOWORLD", fallback = HelloWorldServiceFailure.class)
 public interface HelloWorldService {
   @RequestMapping(value = "/", method = RequestMethod.GET)
   public String sayHello();
 }

3). 創建HelloWorldServiceFailure類， 必須實現被@FeignClient修飾的HelloWorldService接口。注意添加@Component或者@Service注解，在Spring容器中生成一個Bean

@Component
public class HelloWorldServiceFailure implements HelloWorldService {
  @Override
  public String sayHello() {
    System.out.println("hello world service is not available !");
    return "hello world service is not available !";
  }
}

4）. Spring Cloud之前的Brixton版本中，Feign是缺省是自動激活了斷路器的，但最近的Dalston版本已經將缺省配置修改為禁止。

原因參見： https://github.com/spring-cloud/spring-cloud-netflix/issues/1277， 這一點要注意。所以要在Feign中使用斷路器， 必須在application.yml中添加如下配置：

feign:
  hystrix:
   enabled: true

5）. 啟動Feign應用， 訪問http://localhost：8902/hello， 可以一看到和Ribbon一樣的效果。

以上是“Spring Cloud熔斷機制之斷路器的示例分析”這篇文章的所有內容，感謝各位的閱讀！希望分享的內容對大家有幫助，更多相關知識，歡迎關注億速云行業資訊頻道！