被老师持续中出,亚洲加勒比AV在线

快捷導(dǎo)航

spring cloud gateway集成hystrix全局?jǐn)嗦菲鞑僮?/h1>

更新時間：2021年07月17日 10:06:30 作者：草寶蟲

這篇文章主要介紹了spring cloud gateway集成hystrix全局?jǐn)嗦菲鞑僮?，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教

gateway集成hystrix全局?jǐn)嗦菲?/h2>

pom.xml添加依賴

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

在配置文件中，增加spring.cloud.gateway.default-filters：

default-filters:
- name: Hystrix
  args:
    name: fallbackcmd
    fallbackUri: forward:/fallbackcontroller

一定要注意是spring.cloud.gateway.default-filters這個配置節(jié)。

如上的配置，將會使用HystrixCommand打包剩余的過濾器，并命名為fallbackcmd，我們還配置了可選的參數(shù)fallbackUri，降級邏輯被調(diào)用，請求將會被轉(zhuǎn)發(fā)到URI為/fallbackcontroller的控制器處理。

定義降級處理如下：

@RequestMapping(value = "/fallbackcontroller")
public Map<String, String> fallBackController() {
    Map<String, String> res = new HashMap();
    res.put("code", "-100");
    res.put("data", "service not available");
    return res;
}

此時可以設(shè)置hystrix超時時間（毫秒），默認(rèn)只有2秒

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            timeoutInMilliseconds: 30000

示例代碼：

https://github.com/wanghongqi/springcloudconsul_test/tree/master/springtest_gateway

spring cloud gateway 全局熔斷

熔斷主要保護(hù)的是調(diào)用方服務(wù)，如某A服務(wù)調(diào)用B服務(wù)的rpc接口，突然B服務(wù)接口不穩(wěn)定，表現(xiàn)為接口延遲或者失敗率變大。

這個時候如果對B服務(wù)調(diào)用不能快速失敗，那么會導(dǎo)致A服務(wù)大量線程資源無法釋放導(dǎo)致最終A服務(wù)不穩(wěn)定，故障點由B服務(wù)傳遞到A服務(wù)，故障擴大。

熔斷就是在B服務(wù)出現(xiàn)故障的情況下，斷開對B的調(diào)用，通過快速失敗來保證A服務(wù)的穩(wěn)定。

一：Gateway項目maven引入依賴包

Spring Cloud Gateway 利用 Hystrix 的熔斷特性，在流量過大時進(jìn)行服務(wù)降級，同樣我們還是首先給項目添加上依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>

二：創(chuàng)建熔斷后轉(zhuǎn)發(fā)的請求

@RestController
public class FallbackController {
    private Logger log= LoggerFactory.getLogger(getClass());
    @RequestMapping("/error/fallback")
    public Object fallacak(){
        log.info("熔斷處理?。?！");
        return "Service Error！?。?;
    }
}

三：yml配置

#全局熔斷攔截器
default-filters:
    - name: Hystrix
      args:
        name: fallbackcmd
        fallbackUri: forward:/error/fallback
    - name: Retry
      args:
        retries: 3
        statuses: BAD_GATEWAY,BAD_REQUEST
        methods: GET,POST

Hystrix是Gateway以封裝好的過濾器。如果不了解請查看：GatwayFilter工廠

name：即HystrixCommand的名字

fallbackUri：forward:/error/fallback 配置了 fallback 時要會調(diào)的路徑，當(dāng)調(diào)用 Hystrix 的 fallback 被調(diào)用時，請求將轉(zhuǎn)發(fā)到/error/fallback 這個 URI

Retry 通過這四個參數(shù)來控制重試機制： retries, statuses, methods, 和 series

retries：重試次數(shù)，默認(rèn)值是 3 次

statuses：HTTP 的狀態(tài)返回碼，取值請參考：org.springframework.http.HttpStatus

methods：指定哪些方法的請求需要進(jìn)行重試邏輯，默認(rèn)值是 GET 方法，取值參考：org.springframework.http.HttpMethod

series：一些列的狀態(tài)碼配置，取值參考：org.springframework.http.HttpStatus.Series。符合的某段狀態(tài)碼才會進(jìn)行重試邏輯，默認(rèn)值是 SERVER_ERROR，值是 5，也就是 5XX(5 開頭的狀態(tài)碼)，共有5 個值。

# hystrix 信號量隔離，3秒后自動超時
hystrix:
    command:
        fallbackcmd:
            execution:
                isolation:
                    strategy: SEMAPHORE
                    thread:
                        timeoutInMilliseconds: 3000

fallbackcmd 此處需要和上面設(shè)置的HystrixCommand一致

timeoutInMilliseconds 設(shè)置超時時間