摘要：斷路器本身是一種開關裝置，用于在電路上保護線路過載，當線路中有電器發生短路時，斷路器能夠及時的切斷故障電路，防止發生過載發熱甚至起火等嚴重后果。具備擁有回退機制和斷路器功能的線程和信號隔離，請求緩存和請求打包，以及監控和配置等功能。

轉載請注明出處 http://www.paraller.com

概念:

在微服務架構中，我們將系統拆分成了一個個的服務單元，各單元間通過服務注冊與訂閱的方式互相依賴。由于每個單元都在不同的進程中運行，依賴通過遠程調用的方式執行，這樣就有可能因為網絡原因或是依賴服務自身問題出現調用故障或延遲，而這些問題會直接導致調用方的對外服務也出現延遲，若此時調用方的請求不斷增加，最后就會出現因等待出現故障的依賴方響應而形成任務積壓，最終導致自身服務的癱瘓。

舉個例子，在一個電商網站中，我們可能會將系統拆分成，用戶、訂單、庫存、積分、評論等一系列的服務單元。用戶創建一個訂單的時候，在調用訂單服務創建訂單的時候，會向庫存服務來請求出貨（判斷是否有足夠庫存來出貨）。此時若庫存服務因網絡原因無法被訪問到，導致創建訂單服務的線程進入等待庫存申請服務的響應，在漫長的等待之后用戶會因為請求庫存失敗而得到創建訂單失敗的結果。如果在高并發情況之下，因這些等待線程在等待庫存服務的響應而未能釋放，使得后續到來的創建訂單請求被阻塞，最終導致訂單服務也不可用。

在微服務架構中，存在著那么多的服務單元，若一個單元出現故障，就會因依賴關系形成故障蔓延，最終導致整個系統的癱瘓，這樣的架構相較傳統架構就更加的不穩定。為了解決這樣的問題，因此產生了斷路器模式。

斷路器模式源于Martin Fowler的Circuit Breaker一文。“斷路器”本身是一種開關裝置，用于在電路上保護線路過載，當線路中有電器發生短路時，“斷路器”能夠及時的切斷故障電路，防止發生過載、發熱、甚至起火等嚴重后果。

在分布式架構中，斷路器模式的作用也是類似的，當某個服務單元發生故障（類似用電器發生短路）之后，通過斷路器的故障監控（類似熔斷保險絲），向調用方返回一個錯誤響應，而不是長時間的等待。這樣就不會使得線程因調用故障服務被長時間占用不釋放，避免了故障在分布式系統中的蔓延。

Netflix Hystrix:

在Spring Cloud中使用了Hystrix 來實現斷路器的功能。Hystrix是Netflix開源的微服務框架套件之一，該框架目標在于通過控制那些訪問遠程系統、服務和第三方庫的節點，從而對延遲和故障提供更強大的容錯能力。Hystrix具備擁有回退機制和斷路器功能的線程和信號隔離，請求緩存和請求打包，以及監控和配置等功能。

Feign使用Hystrix:
我們不需要在Feigh工程中引入Hystix，Feign中已經依賴了Hystrix，但是不推薦這樣做，太隱秘了 ， 不好自定義，維護成本也高

application.yml:

hystrix:
  command:
    default:
      execution:
        timeout:
          enabled: false
      circuitBreaker:
        enabled: true
        requestVolumeThreshold: 3

相當于是降級操作. 對于查詢操作, 我們可以實現一個fallback方法, 當請求后端服務出現異常的時候, 可以使用fallback方法返回的值. fallback方法的返回值一般是設置的默認值或者來自緩存.

程序的入口添加注釋

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@EnableDiscoveryClient
@EnableCircuitBreaker
@EnableHystrixDashboard
@RibbonClient(name = "yea-ribbon", configuration = YeaRibbonConfiguration.class)
@ComponentScan(basePackages = { "cn.yeamoney.**" })
public class Application {

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

}

類調用樣例

@FeignClient(value = "ticket-service", configuration = YeaFeignConfiguration.class, fallback = TicketClientHystrix.class)
interface TicketClient {

    @RequestMapping(method = RequestMethod.POST, value = "/create")
    Message create(
            @RequestParam(value = "Type") Integer Type, 
            @RequestParam(value = "amount") String amount,
            @RequestParam(value = "userId") String userId, 
            @RequestParam(value = "mobile") String mobile,
            @RequestParam(value = "status") Integer status, 
            @RequestParam(value = "belong") Integer belong,
            @RequestParam(value = "useProfit")String useProfit,
            @RequestParam(value = "useCounter")String useCounter);

}

/**
 * @author zhidaliao
 * 
 *         錯誤處理
 */
@Component
class TicketClientHystrix implements TicketClient {

    @Override
    public Message create(Integer Type, String amount, String userId, String mobile, Integer status,
            Integer belong, String useProfit, String useCounter) {
        // TODO 自動生成的方法存根
        return null;
    }

    
}

介紹
在Hystrix中, 主要通過線程池來實現資源隔離. 通常在使用的時候我們會根據調用的遠程服務劃分出多個線程池.
例如調用產品服務的Command放入A線程池, 調用賬戶服務的Command放入B線程池. 這樣做的主要優點是運行環境被隔離開了. 這樣就算調用服務的代碼存在bug或者由于其他原因導致自己所在線程池被耗盡時, 不會對系統的其他服務造成影響.
但是帶來的代價就是維護多個線程池會對系統帶來額外的性能開銷. 如果是對性能有嚴格要求而且確信自己調用服務的客戶端代碼不會出問題的話, 可以使用Hystrix的信號模式(Semaphores)來隔離資源.

自定義 hystrix command -- 待完善。。。

關鍵字：@HystrixCommand(ignoreExceptions = .class) 、 javanica 、 HystrixCommand 、Feign中自定義 Hystrix的groupKey commandKey threadPoolKey

想要程序自帶監控的功能，可以在Springboot中加上

@EnableHystrixDashboard

程序正常啟動之后
訪問http://localhost:8081/hystrix.stream 即可查看數據流
訪問 http://localhost:8081/hystrix 可以查看UI界面

1、功能比較全面的鏡像，支持turbine , 分布式監控。 kennedyoliveira/hystrix-dashboard:kennedyoliveira/standalone-hystrix-dashboard , 可以在輸入框中輸入 Eureka的地址 http://localhost:9761/eureka/apps

2、瀏覽器地址： http://localhost:7979/hystrix-dashboard/

3、在輸入框中輸入要監控的網址，例如： http://localhost:8081/hystrix.stream，即可查看情況

image

image

Turbine

在復雜的分布式系統中，相同服務的節點經常需要部署上百甚至上千個，很多時候，運維人員希望能夠把相同服務的節點狀態以一個整體集群的形式展現出來，這樣可以更好的把握整個系統的狀態。 為此，Netflix提供了一個開源項目（Turbine）來提供把多個hystrix.stream的內容聚合為一個數據源供Dashboard展示。

pom.xml

    org.springframework.cloud
    spring-cloud-netflix-turbine

application.yml

turbine: 
  appConfig: yea-service
  aggregator: 
    clusterConfig: default
    clusterNameExpression: new String("default")

turbine.appConfig ：配置Eureka中的serviceId列表，表明監控哪些服務

turbine.aggregator.clusterConfig ：指定聚合哪些集群，多個使用”,”分割，默認為default。可使用http://.../turbine.stream?clu...{clusterConfig之一}訪問

turbine.clusterNameExpression ：

clusterNameExpression指定集群名稱，默認表達式appName；此時：turbine.aggregator.clusterConfig需要配置想要監控的應用名稱；

當clusterNameExpression: default時，turbine.aggregator.clusterConfig可以不寫，因為默認就是default；

當clusterNameExpression: metadata[‘cluster’]時，假設想要監控的應用配置了eureka.instance.metadata-map.cluster: ABC，則需要配置，同時turbine.aggregator.clusterConfig: ABC

在入口程序中添加注釋

@EnableTurbine

測試

http://localhost:8001/turbine.stream

PS:在添加了 hystrix的程序里面添加turbine ,會導致 /hystrix.stream 鏈接無效。
建議新建一個項目，然后添加 turbine的功能，不要在微服務中添加。

當Hystrix和ribbon配合使用的時候，如果希望 Hystrix的超時時間大于ribbon配置的超時時間，你要考慮到重試次數，例如 Ribbon的超時時間是一秒，重試三次，那你的 Hystrix超時時間必須大于三秒。

    org.springframework.cloud
    spring-cloud-starter-hystrix-dashboard


    org.springframework.cloud
    spring-cloud-starter-hystrix


    org.springframework.boot
    spring-boot-starter-actuator

微服務框架Spring Cloud介紹 Part5: 在微服務系統中使用Hystrix, Hystrix Dashboard與Turbine

Hystrix Home - github

kennedyoliveira/standalone-hystrix-dashboard

SpringCloud使用Hystrix實現斷路器

How to Include Hystrix Dashboar

Configuration