spring-cloud-gateway降級的實現(xiàn)
前言
本文主要研究一下 spring cloud gateway 如何集成 hystrix。
當下游接口負載很大,或者接口不通等其他原因導致超時,如果接口不熔斷的話將會影響到下游接口得不到喘息,網(wǎng)關也會因為超時連接一直掛起,很可能因為一個子系統(tǒng)的問題導致整個系統(tǒng)的雪崩。所以我們的網(wǎng)關需要設計熔斷,當因為熔斷器打開時,網(wǎng)關將返回一個降級的應答。
Maven 配置
添加 hystrix 依賴
pom.xml
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
項目實戰(zhàn)
在 provider1 服務中添加一個方法,延時 2 秒返回響應。
@GetMapping("/timeout") public String timeout() { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("休眠了2秒"); return "timeout test"; }
修改網(wǎng)關配置文件
server: port: 2000 spring: application: name: idc-gateway2 redis: host: localhost port: 6379 timeout: 6000ms # 連接超時時長(毫秒) jedis: pool: max-active: 1000 # 連接池最大連接數(shù)(使用負值表示沒有限制) max-wait: -1ms # 連接池最大阻塞等待時間(使用負值表示沒有限制) max-idle: 10 # 連接池中的最大空閑連接 min-idle: 5 # 連接池中的最小空閑連接 cloud: consul: host: localhost port: 8500 gateway: discovery: locator: enabled: true # gateway可以通過開啟以下配置來打開根據(jù)服務的serviceId來匹配路由,默認是大寫 routes: - id: provider1 uri: lb://idc-provider1 predicates: - Path=/p1/** filters: - StripPrefix=1 - name: Hystrix args: name: default fallbackUri: forward:/defaultfallback # 只有該id下的服務會降級 - id: provider2 uri: lb://idc-provider2 predicates: - Path=/p2/** filters: - StripPrefix=1 # hystrix 信號量隔離,1.5秒后自動超時 hystrix: command: default: execution: isolation: strategy: SEMAPHORE thread: timeoutInMilliseconds: 1500
網(wǎng)關添加降級處理類
@RestController public class FallbackController { @RequestMapping("/defaultfallback") public Map<String,Object> defaultfallback(){ System.out.println("降級操作..."); Map<String,Object> map = new HashMap<>(); map.put("code",200); map.put("msg","服務超時降級"); map.put("data",null); return map; } }
降級測試
超時服務降級
curl http://localhost:2000/p1/timeout
返回
{"msg":"服務超時降級","code":200,"data":null}
其他異常
spring-cloud-gateway 調用下游服務返回的異常,網(wǎng)關不做任何處理,會直接返回。大家想一下為什么在網(wǎng)關不去處理下游異常呢? 因為很多時候下游的異常是包含有效信息的(異常信息千千萬),如果在網(wǎng)關處做了統(tǒng)一返回,就失去了返回異常的意義。
spring-cloud-starter-netflix-hystrix 內置的 Hystrix 過濾器是
HystrixGatewayFilterFactory。 感興趣的小伙伴可以自行閱讀相關源碼。
到此這篇關于spring-cloud-gateway降級的實現(xiàn)的文章就介紹到這了,更多相關spring-cloud-gateway降級 內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
- 詳解Spring Cloud Gateway 限流操作
- Spring Cloud Gateway全局異常處理的方法詳解
- Spring Cloud Gateway入門解讀
- 詳解SpringCloud Finchley Gateway 統(tǒng)一異常處理
- springcloud gateway聚合swagger2的方法示例
- 詳解SpringCloud Gateway之過濾器GatewayFilter
- Spring Cloud Gateway使用Token驗證詳解
- Spring Cloud GateWay 路由轉發(fā)規(guī)則介紹詳解
- spring cloud gateway 限流的實現(xiàn)與原理
- Spring Cloud Gateway重試機制的實現(xiàn)
相關文章
JDBC連接SQL?Server數(shù)據(jù)庫實現(xiàn)增刪改查的全過程
實際開發(fā)中手動的輸入SQL語句是少之又少,大多數(shù)情況下是通過編譯代碼進行來控制自動執(zhí)行,下面這篇文章主要給大家介紹了關于JDBC連接SQL?Server數(shù)據(jù)庫實現(xiàn)增刪改查的相關資料,需要的朋友可以參考下2023-04-04