irpas技术客

java spring 降级_spring-cloud-gateway降级的实现_拉菲雪球兔

irpas 7548

前言

本文主要研究一下 spring cloud gateway 如何集成 hystrix。

当下游接口负载很大,或者接口不通等其他原因导致超时,如果接口不熔断的话将会影响到下游接口得不到喘息,网关也会因为超时连接一直挂起,很可能因为一个子系统的问题导致整个系统的雪崩。所以我们的网关需要设计熔断,当因为熔断器打开时,网关将返回一个降级的应答。

Maven 配置

添加 hystrix 依赖

pom.xml

org.springframework.cloud

spring-cloud-starter-netflix-hystrix

项目实战

在 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 defaultfallback(){

System.out.println("降级操作...");

Map 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。 感兴趣的小伙伴可以自行阅读相关源码。

到此这篇关于spring-cloud-gateway降级的实现的文章就介绍到这了,更多相关spring-cloud-gateway降级 内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!


1.本站遵循行业规范,任何转载的稿件都会明确标注作者和来源;2.本站的原创文章,会注明原创字样,如未注明都非原创,如有侵权请联系删除!;3.作者投稿可能会经我们编辑修改或补充;4.本站不提供任何储存功能只提供收集或者投稿人的网盘链接。

标签: #JAVA #Spring #前言本文主要研究一下 #Cloud #gateway #如何集成