spring cloud gateway集成hystrix全局断路器操作
gateway集成hystrix全局断路器
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这个配置节。
如上的配置，将会使用hystrixcommand打包剩余的过滤器，并命名为fallbackcmd，我们还配置了可选的参数fallbackuri，降级逻辑被调用，请求将会被转发到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;
}
此时可以设置hystrix超时时间（毫秒） ，默认只有2秒
hystrix:
command:
default:
execution:
isolation:
thread:
timeoutinmilliseconds: 30000
示例代码：
https://github.com/wanghongqi/springcloudconsul_test/tree/master/springtest_gateway
spring cloud gateway 全局熔断
熔断主要保护的是调用方服务，如某a服务调用b服务的rpc接口，突然b服务接口不稳定，表现为接口延迟或者失败率变大。
这个时候如果对b服务调用不能快速失败，那么会导致a服务大量线程资源无法释放导致最终a服务不稳定，故障点由b服务传递到a服务，故障扩大。
熔断就是在b服务出现故障的情况下，断开对b的调用，通过快速失败来保证a服务的稳定。
一：gateway项目maven引入依赖包
spring cloud gateway 利用 hystrix 的熔断特性，在流量过大时进行服务降级，同样我们还是首先给项目添加上依赖
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-actuator</artifactid>
</dependency>
二：创建熔断后转发的请求
@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 时要会调的路径，当调用 hystrix 的 fallback 被调用时，请求将转发到/error/fallback 这个 uri
retry 通过这四个参数来控制重试机制： retries, statuses, methods, 和 series
retries：重试次数，默认值是 3 次
statuses：http 的状态返回码，取值请参考：org.springframework.http.httpstatus
methods：指定哪些方法的请求需要进行重试逻辑，默认值是 get 方法，取值参考：org.springframework.http.httpmethod
series：一些列的状态码配置，取值参考：org.springframework.http.httpstatus.series。符合的某段状态码才会进行重试逻辑，默认值是 server_error，值是 5，也就是 5xx(5 开头的状态码)，共有5 个值。
# hystrix 信号量隔离，3秒后自动超时
hystrix:
command:
fallbackcmd:
execution:
isolation:
strategy: semaphore
thread:
timeoutinmilliseconds: 3000
fallbackcmd 此处需要和上面设置的hystrixcommand一致
timeoutinmilliseconds 设置超时时间
以上为个人经验，希望能给大家一个参考，也希望大家多多支持。
上一篇： iOS15如何编辑照片的日期和时间
下一篇： JDBC常用接口总结