跟我學SpringCloud | 第四篇：熔斷器Hystrix

SpringCloud系列教程 | 第四篇：熔斷器Hystrix

Springboot: 2.1.6.RELEASE

SpringCloud: Greenwich.SR1

如無特殊說明，本系列教程全採用以上版本

1. 熔斷器

服務雪崩

在正常的微服務架構體系下，一個業務不多有隻須要調用一個服務就能夠返回數據的狀況，這種比較常見的是出如今demo中，通常都是存在調用鏈的，好比A->B->C->D，若是D在某一個瞬間出現問題，好比網絡波動，io偏高，致使卡頓，隨着時間的流逝，後續的流量繼續請求，會形成D的壓力上升，有可能引發宕機。

你覺得這就是結束麼，圖樣圖森破，這纔是噩夢的開始，在同一個調用鏈上的ABC三個服務都會隨着D的宕機而引起宕機，這還不是結束，一個服務不可能只有一個接口，當它開始卡頓宕機時，會影響到其餘調用鏈的正常調用，最終致使全部的服務癱瘓。

以下圖所示：

熔斷器

相信你們都知道家用電閘，原來老式的電閘是使用保險絲的（如今不少都是空氣開關了），當家裏用電量過大的時候，保險絲常常燒斷，這麼作是保護家裏的用電器，防止過載。

熔斷器的做用和這個很像，它能夠實現快速失敗，若是在一段時間內服務調用失敗或者異常，會強制要求當前調用失敗，不在走遠程調用，走服務降級操做（返回固定數據或者其餘一些降級操做）。從而防止應用程序不斷地嘗試執行可能會失敗的操做，使得應用程序繼續執行而不用等待修正錯誤，或者浪費CPU時間去等到長時間的超時產生。熔斷器也能夠自動診斷錯誤是否已經修正，若是已經修正，應用程序會再次嘗試調用操做。

熔斷器模式就像是那些容易致使錯誤的操做的一種代理。這種代理可以記錄最近調用發生錯誤的次數，而後決定使用容許操做繼續，或者當即返回錯誤。 Hystrix會有一個熔斷時間窗口，具體轉換邏輯以下：

熔斷器就是保護服務高可用的最後一道防線。

2. Hystrix

1. 斷路器機制

斷路器很好理解, 當Hystrix Command請求後端服務失敗數量超過必定比例(默認50%), 斷路器會切換到開路狀態(Open)。這時全部請求會直接失敗而不會發送到後端服務。斷路器保持在開路狀態一段時間後(默認5秒), 自動切換到半開路狀態(HALF-OPEN)。這時會判斷下一次請求的返回狀況, 若是請求成功, 斷路器切回閉路狀態(CLOSED), 不然從新切換到開路狀態(OPEN)。Hystrix的斷路器就像咱們家庭電路中的保險絲, 一旦後端服務不可用, 斷路器會直接切斷請求鏈, 避免發送大量無效請求影響系統吞吐量, 而且斷路器有自我檢測並恢復的能力。

2. Fallback

Fallback至關因而降級操做。對於查詢操做, 咱們能夠實現一個fallback方法, 當請求後端服務出現異常的時候, 可使用fallback方法返回的值。fallback方法的返回值通常是設置的默認值或者來自緩存。

3. 資源隔離

在Hystrix中, 主要經過線程池來實現資源隔離。一般在使用的時候咱們會根據調用的遠程服務劃分出多個線程池。例如調用產品服務的Command放入A線程池, 調用帳戶服務的Command放入B線程池。這樣作的主要優勢是運行環境被隔離開了。這樣就算調用服務的代碼存在bug或者因爲其餘緣由致使本身所在線程池被耗盡時, 不會對系統的其餘服務形成影響。可是帶來的代價就是維護多個線程池會對系統帶來額外的性能開銷。若是是對性能有嚴格要求並且確信本身調用服務的客戶端代碼不會出問題的話, 可使用Hystrix的信號模式(Semaphores)來隔離資源。

3. Feign Hystrix

上一篇咱們使用了producer和consumers，熔斷器是隻做用在服務調用端，所以上一篇使用到的consumers咱們能夠直接拿來使用。由於，Feign中已經依賴了Hystrix因此在maven配置上不用作任何改動。

1. 配置文件application.yml新增

server:
  port: 8081
spring:
  application:
    name: spring-cloud-consumers
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
feign:
  hystrix:
    enabled: true

其中新增了feign.hystrix.enabled = true

2. 建立fallback類，繼承與HelloRemote實現回調的方法

package com.springcloud.consumers.fallback;

import com.springcloud.consumers.remote.HelloRemote;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * Created with IntelliJ IDEA.
 *
 * @User: weishiyao
 * @Date: 2019/7/2
 * @Time: 23:14
 * @email: inwsy@hotmail.com
 * Description:
 */
@Component
public class HelloRemoteFallBack implements HelloRemote {
    @Override
    public String hello(@RequestParam(value = "name") String name) {
        return "hello " + name + ", i am fallback massage";
    }
}

3. 添加fallback屬性

在HelloRemote類添加指定fallback類，在服務熔斷的時候返回fallback類中的內容。

package com.springcloud.consumers.remote;

import com.springcloud.consumers.fallback.HelloRemoteFallBack;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;

/**
 * @Author: shiyao.wei
 * @Date: 2019/7/2 11:14
 * @Version: 1.0
 * @Desc:
 */
@FeignClient(name= "SPRING-CLOUD-PRODUCER", fallback = HelloRemoteFallBack.class)
public interface HelloRemote {
    @RequestMapping(value = "/hello")
    String hello(@RequestParam(value = "name") String name);
}

全部改動結束。

4. 測試

如今咱們測試看下結果，老規矩，順次啓動註冊中心Eureka、provider、consumer

訪問上一節咱們訪問過的連接：http://localhost:8081/hello/spring

如今能夠看到頁面正常顯示：hello spring，producer is ready

如今咱們手動把provider停掉，再訪問一下連接看一下：

如今頁面已經顯示咱們熔斷後的信息了：hello spring, i am fallback massage

如今說明咱們的測試已經成功了。

好了，如今能夠將代碼打包扔到Github上去了：）

示例代碼-Github

參考：

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