spring cloud gateway集成hystrix全局?jǐn)嗦菲鞑僮?/h1>
更新時間:2021年07月17日 10:06:30 作者:草寶蟲
這篇文章主要介紹了spring cloud gateway集成hystrix全局?jǐn)嗦菲鞑僮鳎哂泻芎玫膮⒖純r值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
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 全局熔斷
熔斷主要保護的是調(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 的熔斷特性,在流量過大時進行服務(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
:指定哪些方法的請求需要進行重試邏輯,默認(rèn)值是 GET 方法,取值參考:org.springframework.http.HttpMethod
series
:一些列的狀態(tài)碼配置,取值參考:org.springframework.http.HttpStatus.Series。符合的某段狀態(tài)碼才會進行重試邏輯,默認(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è)置超時時間

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
-
spring boot jpa寫原生sql報Cannot resolve table錯誤解決方法
在本篇文章里小編給大家整理的是關(guān)于spring boot jpa寫原生sql報Cannot resolve table錯誤的解決方法,需要的朋友學(xué)習(xí)下。 2019-11-11
-
Java JDK動態(tài)代理實現(xiàn)原理實例解析
這篇文章主要介紹了Java JDK動態(tài)代理實現(xiàn)原理實例解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下 2020-06-06
-
Java在并發(fā)環(huán)境中SimpleDateFormat多種解決方案
這篇文章主要介紹了Java在并發(fā)環(huán)境中SimpleDateFormat多種解決方案,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下 2020-07-07
-
java冷知識:javac AbstractProcessor詳解
這篇文章主要介紹了java冷知識:javac AbstractProcessor詳解,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教 2021-11-11
最新評論
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 全局熔斷
熔斷主要保護的是調(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 的熔斷特性,在流量過大時進行服務(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
:指定哪些方法的請求需要進行重試邏輯,默認(rèn)值是 GET 方法,取值參考:org.springframework.http.HttpMethod
series
:一些列的狀態(tài)碼配置,取值參考:org.springframework.http.HttpStatus.Series。符合的某段狀態(tài)碼才會進行重試邏輯,默認(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è)置超時時間
以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持腳本之家。
相關(guān)文章
spring boot jpa寫原生sql報Cannot resolve table錯誤解決方法
在本篇文章里小編給大家整理的是關(guān)于spring boot jpa寫原生sql報Cannot resolve table錯誤的解決方法,需要的朋友學(xué)習(xí)下。2019-11-11Java JDK動態(tài)代理實現(xiàn)原理實例解析
這篇文章主要介紹了Java JDK動態(tài)代理實現(xiàn)原理實例解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-06-06Java在并發(fā)環(huán)境中SimpleDateFormat多種解決方案
這篇文章主要介紹了Java在并發(fā)環(huán)境中SimpleDateFormat多種解決方案,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下2020-07-07java冷知識:javac AbstractProcessor詳解
這篇文章主要介紹了java冷知識:javac AbstractProcessor詳解,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-11-11