本文主要研究一下春云网关如何集成hystrix。
当下游接口负载很大,或者接口不通等其他原因导致超时,如果接口不熔断的话将会影响到下游接口得不到喘息,网关也会因为超时连接一直挂起,很可能因为一个子系统的问题导致整个系统的雪崩,所以我们的网关需要设计熔断,当因为熔断器打开时,网关将返回一个降级的应答。
添加hystrix依赖
pom.xml
& lt; dependency>
& lt; groupId> org.springframework.cloud
& lt; artifactId> spring-cloud-starter-netflix-hystrix
& lt;/dependency>
之前
在provider1服务中添加一个方法,延时2秒返回响应。
@GetMapping("/超时”)
公共字符串超时(){
尝试{
thread . sleep (2000);
}捕捉(InterruptedException e) {
e.printStackTrace ();
}
System.out.println(“休眠了2秒”);
返回“超时测试”;
}
之前
修改网关配置文件
服务器:
端口:2000
春天:
应用程序:
名称:idc-gateway2
复述:
主持人:localhost
端口:6379
超时:6000 #女士连接超时时长(毫秒)
能:
池:
max-active: 1000 #连接池最大连接数(使用负值表示没有限制)
最大等待:1 #女士连接池最大阻塞等待时间(使用负值表示没有限制)
最大空闲:10 #连接池中的最大空闲连接
min-idle: 5 #连接池中的最小空闲连接
云:
领事:
主持人:localhost
端口:8500
网关:
发现:
定位器:
启用:真#网关可以通过开启以下配置来打开根据服务的serviceId来匹配路由,默认是大写
路线:
- id: provider1
uri:磅://idc-provider1
谓词:
-路径=/p1/* *
过滤器:
——StripPrefix=1
——名称:Hystrix
参数:
名称:默认
fallbackUri:转发:/defaultfallback #只有该id下的服务会降级
- id: provider2
uri:磅://idc-provider2
谓词:
-路径=/p2/* *
过滤器:
——StripPrefix=1
# hystrix信号量隔离,1.5秒后自动超时
hystrix:
命令:
默认值:
执行:
隔离:
策略:信号量
线程:
timeoutInMilliseconds: 1500
网关添加降级处理类
@RestController
公开课FallbackController {
@RequestMapping ("/defaultfallback”)
公共Map<字符串,Object>defaultfallback () {
System.out.println(“降级操作……”);
Object> Map<字符串;地图=new HashMap<在();
map.put(“代码”,200);
map.put(“味精”、“服务超时降级”);
map.put("数据",null);
返回地图;
}
}
超时服务降级
curl http://localhost: 2000/p1/超时
返回
{“味精”:“服务超时降级”、“代码”:200年,“数据”:零}
spring-cloud-gateway调用下游服务返回的异常,网关不做任何处理,会直接返回。大家想一下为什么在网关不去处理下游异常呢& # 63;因为很多时候下游的异常是包含有效信息的(异常信息千千万),如果在网关处做了统一返回,就失去了返回异常的意义。
spring-cloud-starter-netflix-hystrix内置的Hystrix过滤器是
HystrixGatewayFilterFactory。感兴趣的小伙伴可以自行阅读相关源码。
到此这篇关于spring-cloud-gateway降级的实现的文章就介绍到这了,更多相关spring-cloud-gateway降级内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
