本文主要研究一下 spring cloud gateway 如何集成 hystrix。
当下游接口负载很大,或者接口不通等其他原因导致超时,如果接口不熔断的话将会影响到下游接口得不到喘息,网关也会因为超时连接一直挂起,很可能因为一个子系统的问题导致整个系统的雪崩。所以我们的网关需要设计熔断,当因为熔断器打开时,网关将返回一个降级的应答。
添加 hystrix 依赖
pom.xml
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
provider1
服务中添加一个方法,延时 2 秒返回响应。 @GetMapping("/timeout") public String timeout() { try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("休眠了2秒"); return "timeout test"; }
server: port: 2000 spring: application: name: idc-gateway2 redis: host: localhost port: 6379 timeout: 6000ms # 连接超时时长(毫秒) jedis: pool: max-active: 1000 # 连接池最大连接数(使用负值表示没有限制) max-wait: -1ms # 连接池最大阻塞等待时间(使用负值表示没有限制) max-idle: 10 # 连接池中的最大空闲连接 min-idle: 5 # 连接池中的最小空闲连接 cloud: consul: host: localhost port: 8500 gateway: discovery: locator: enabled: true # gateway可以通过开启以下配置来打开根据服务的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
@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
调用下游服务返回的异常,网关不做任何处理,会直接返回。大家想一下为什么在网关不去处理下游异常呢? 因为很多时候下游的异常是包含有效信息的(异常信息千千万),如果在网关处做了统一返回,就失去了返回异常的意义。
spring-cloud-starter-netflix-hystrix
内置的 Hystrix 过滤器是
HystrixGatewayFilterFactory
。 感兴趣的小伙伴可以自行阅读相关源码。
本文到此结束,感谢大家的阅读。欢迎大家关注公众号【当我遇上你】。