快捷導(dǎo)航

Spring?Cloud?Hystrix的基本用法大全

更新時間：2022年07月14日 08:28:37 作者：、楽.

這篇文章主要介紹了Spring?Cloud?Hyxtrix的基本使用,它是Spring Cloud中集成的一個組件，在整個生態(tài)中主要為我們提供服務(wù)隔離，服務(wù)熔斷，服務(wù)降級功能，本文給大家介紹的非常詳細，需要的朋友可以參考下

1. Hystrix的簡單使用

1.1 服務(wù)降級

添加依賴

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

啟動類添加注解

@EnableCircuitBreaker //開啟熔斷

對應(yīng)接口加上注解

注解里面相關(guān)的參數(shù)可以至HystrixCommandProperties類中查找；注解里面也可以不寫相關(guān)內(nèi)容。

fallbackMethod = "fallback"里面是熔斷方法名。

//HystrixCommandProperties
    @HystrixCommand( commandProperties = {
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold",value = "10")
    },fallbackMethod = "fallback")
    @GetMapping
    public String order() {
        log.info("begin do order");
//        使用openfiegn
        String goods = goodsService.getGoodsById();
        String promotion = promotionService.getPromotionById();
        String result = orderService.createOrder(goods, promotion);
        return result;
    }

 	public String fallback(){
        return "觸發(fā)降級";
    }

修改商品服務(wù)的接口，加上超時時間，使接口調(diào)用錯誤。

@GetMapping("/goods")
public String getGoodsById() {

    try {
        Thread.sleep(3000);
    } catch (Exception e){
        e.printStackTrace();
    }
    log.info("收到請求，端口為：{}", port);
    return "返回商品信息";
}

啟動項目，調(diào)用接口，看是否可以進行服務(wù)降級。

1.2 服務(wù)熔斷

熔斷的觸發(fā)機制

在10S內(nèi)，超過20次請求，并且失敗率超過50%（默認情況）- > 觸發(fā)熔斷

熔斷后經(jīng)過一段時間等待后又可以繼續(xù)正常訪問。

我們稍微改造下代碼：

    @HystrixCommand(commandProperties = {
            @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"), //請求閾值
            @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "5000"),//熔斷窗口持續(xù)時間
            @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50")//錯誤比
    }, fallbackMethod = "fallback")
    @GetMapping("/{num}")
    public String order(@PathVariable("num") int num) {
        if (num % 2 == 0) {
            return "正常訪問。";
        }

        log.info("begin do order");
        String goods = goodsService.getGoodsById();
        String promotion = promotionService.getPromotionById();
        String result = orderService.createOrder(goods, promotion);
        return result;
    }
    public String fallback(int num) {
        return "觸發(fā)降級";
    }

我們來看下上述代碼，首先我們給接口添加了相關(guān)一個參數(shù)，在接口中根據(jù)傳參來執(zhí)行不同的操作，比如參數(shù)為2那就正常返回，如果參數(shù)為1 就執(zhí)行下面的代碼，由于我們加了超時時間，所以會調(diào)用失敗。

注意，我們給接口加了參數(shù)后，服務(wù)降級的方法也要加上相關(guān)參數(shù)，否則會錯誤。

觸發(fā)的相關(guān)機制都是可以根據(jù)參數(shù)自己修改的，大家測試的時候可以將請求閾值設(shè)置小一點，方便測試查看效果。

2. OpenFeign集成Hystrix

以上都是我們直接在客戶端調(diào)用的時候直接集成Hystrix來進行服務(wù)的保護，那在OpenFeign中我們該如何集成呢？

然后我們在service-api項目中引入相關(guān)依賴：

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

然后我們在暴露接口的地方創(chuàng)建相關(guān)回調(diào)實現(xiàn)：

我們首先實現(xiàn)暴露接口的FeignClient，然后在實現(xiàn)的方法中編寫對應(yīng)的降級操作即可，這樣當發(fā)生調(diào)用失敗的情況，則會返回降級的信息。

這里可以使用component注解將該類交給spring管理，或者通過configuration注解進行處理。

//@Component
public class IGoodsServiceFallback implements IGoodsServiceFeignClient {

    @Override
    public String getGoodsById() {
        return "查詢商品信息異常，觸發(fā)降級保護機制。";
    }
}

編寫完該類后，我們需要至FeignClient處進行相關(guān)配置。

@FeignClient(name = "goods-service",
        configuration = FeignClientLogConfiguration.class,
        fallback = IGoodsServiceFallback.class)
public interface IGoodsServiceFeignClient extends IGoodsService {
}

這里修改完成后，我們就可以至集成服務(wù)修改相關(guān)配置了。

首先在配置文件中開啟feign的熔斷保護機制。

#開啟feign的熔斷保護機制
feign.hystrix.enabled=true

然后需要將之前的IGoodsServiceFallback交給spring容器進行管理，我這里是使用的configuration注解進行處理的。

@Configuration
public class HystrixFallbackConfiguration {

    @Bean
    public IGoodsServiceFallback goodsServiceFallback() {
        return new IGoodsServiceFallback();
    }
}

以上便是我們的全部配置，這個時候我們只需要去goods-service中的調(diào)用接口人為的制造一些異常，這樣調(diào)用的時候就可以觸發(fā)異常了。

比如我直接加了超時時間：

@Slf4j
@RestController
public class GoodsService implements IGoodsService  {

    @Value("${server.port}")
    private String port;

    /**
     * 根據(jù)ID查詢商品信息
     *
     * @return
     */
    @GetMapping("/goods")
    public String getGoodsById() {

        try {
            Thread.sleep(5000);
        } catch (Exception e){
            e.printStackTrace();
        }
        log.info("收到請求，端口為：{}", port);
        return "返回商品信息";
    }
}

然后我們就可以直接開始測試了：

可以看到成功獲取了降級信息，代表我們集成成功。

實際上我們在調(diào)用OpenFeign接口的時候，他會判斷我們的Feign接口上是否有Hustrix的一些機制，如果有的話先進行相關(guān)判斷，然后在執(zhí)行請求。如下圖所示：

3. Hystrix熔斷原理

下圖為Hystrix的熔斷簡單工作原理，調(diào)用出現(xiàn)異常后，如果錯誤率達到一個閾值，則開始熔斷。相關(guān)的閾值，時間等都是可以進行配置的。

3.1 熔斷狀態(tài)

open

觸發(fā)熔斷，意味著請求不會發(fā)送到服務(wù)端，而是直接調(diào)用fallback。

closed

熔斷關(guān)閉，表示可以正常通信。

Half-Open

熔斷的自動恢復(fù)機制。通過嘗試的方式，判斷服務(wù)是否正常，然后恢復(fù)到closed 狀態(tài)；如果還是異常，則繼續(xù)保持熔斷。

3.2 熔斷的工作原理

使用滑動窗口來實現(xiàn)數(shù)據(jù)的統(tǒng)計。

可能有人不太了解什么是滑動窗口。

我們首先來看下計數(shù)器的一種實現(xiàn)方式，類似我們在60s內(nèi)只能發(fā)送一次短信。比如下圖，限制一分鐘之內(nèi)只能接受100個請求，但是位于臨界點的時候，我們可能突然收到200個請求，所以可能會導(dǎo)致一些問題。

滑動窗口和計算器是類似的，首先多了一個滑動的步驟，窗口會隨著時間往前滑動。然后我們的窗口大小是固定的（可以自己設(shè)置），比如下圖我們的窗口大小就是60S，隨著時間的推進，窗口向前滑動，但是會保證大小不變。

熔斷的閾值就是根據(jù)滑動窗口的請求數(shù)以及失敗次數(shù)來進行計算的，從而判斷出是否開啟熔斷。

RxJava 響應(yīng)式編程（類似webflux），實現(xiàn)事件流的分發(fā)。

既然了解了他的大致原理，我們再將這部分帶入之前的流程中來看：

我們一個請求進來后，如果該接口聲明了HystrixCommand注解，首先會調(diào)用allowRequest方法去校驗當前請求是否允許發(fā)生：判斷當前是否位于isOpen狀態(tài)，如果是則直接返回服務(wù)降級的邏輯；如果不是則判斷當前時間窗口的總健康請求數(shù)量是否大于20次（閾值可自行設(shè)置），小于則正常執(zhí)行，如果大于則判斷當前滑動窗口內(nèi)的錯誤請求率是否達到閾值，從而開啟熔斷狀態(tài)。

滑動窗口的數(shù)據(jù)統(tǒng)計都是通過事件流來實現(xiàn)的，任務(wù)執(zhí)行結(jié)束后，通過發(fā)布一個時間，然后將相關(guān)數(shù)據(jù)更新到當前時間窗口中，老的數(shù)據(jù)則直接丟棄。相關(guān)流程比較復(fù)雜，這里不過多闡述。