爱站程序员基地1. 概述
老话说的好：做人要正直，做事要正派，胸怀坦荡、光明磊落，才会赢得他人的信赖与尊敬。
言归正传，之前聊了服务间通信的组件 Feign，今天我们来聊聊服务降级。
服务降级简单的理解就是给一个备选方案，当服务调用报错或者超时时，能终止远程调用，并很快的返回备选的结果，避免引发服务雪崩。
今天我们用两个例子，模拟一下 接口报错 和 接口超时 的服务降级实现。
我们使用 hystrix 实现服务降级，虽然从Spring Cloud 2020.0 版本开始，移除了 hystrix 组件，但并不影响我们对他的使用。
闲话不多说，直接上代码。
2. 接口报错的服务降级
2.1 被调用服务
2.1.1 接口代码
@GetMapping(\"/exception\")String exception() throws Exception;
2.1.2 实现类代码
@Overridepublic String exception() throws Exception {if(1==1) {throw new Exception(\"模拟异常\");}return null;}
2.2 调用服务
2.2.1 主要依赖
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- 健康检查 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-openfeign</artifactId></dependency><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-hystrix</artifactId><version>2.2.9.RELEASE</version></dependency>
这里 hystrix 使用目前的最新版本2.2.9.RELEASE。
2.2.2 主要配置
feign:circuitbreaker:enabled: true # 开启 feign 的断路器hystrix:command:default:fallback:enabled: true # 开启服务降级
2.2.3 降级工厂类的开发
@Componentpublic class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {@Overridepublic EurekaClientService create(Throwable cause) {return new EurekaClientService() {@Overridepublic String exception() throws Exception {System.out.println(\"exception方法 降级\");return \"exception方法 降级\";}};}}
2.2.4 在 Feign 接口配置降级工厂类
@FeignClient(name = \"my-eureka-client\", fallbackFactory = MyEurekaClientServiceFactory.class) // name为 调用服务的名称@RequestMapping(\"/api\")public interface EurekaClientService {@GetMapping(\"/exception\")String exception() throws Exception;}
2.2.5 启动类增加@EnableHystrix 注解
@SpringBootApplication@EnableDiscoveryClient@EnableFeignClients@EnableHystrixpublic class MyFeignApplication {public static void main(String[] args) {SpringApplication.run(MyFeignApplication.class, args);}}
2.2.6 启动服务测试
可以正常进入降级方法。
3. 接口超时的服务降级
3.1被调用服务
3.1.1 接口代码
@GetMapping(\"/timeout\")String timeout(@RequestParam Integer timeoutSecond);
3.1.2 实现类代码
@Overridepublic String timeout(Integer timeoutSecond) {System.out.println(\"调用timeout方法\");try {Thread.sleep(timeoutSecond * 1000L);} catch (InterruptedException e) {e.printStackTrace();}return \"success：\" + port;}
3.2 调用服务
3.2.1 主要配置
feign:client:config:# 全局配置default:connectTimeout: 1000 # 连接超时时间，单位msreadTimeout: 3000 # 获取Response响应超时时间，单位ms# 针对 my-eureka-client 的 feign 配置，优先级高于全局配置my-eureka-client:connectTimeout: 300 # 连接超时时间，单位msreadTimeout: 5000 # 获取Response响应超时时间，单位mscircuitbreaker:enabled: true # 开启 feign 的断路器hystrix:command:default:fallback:enabled: true # 开启服务降级execution:timeout:enabled: true # 全局超时配置isolation:thread:timeoutInMilliseconds: 3000 # 超时时间配置interruptOnTimeout: true # 超时后是否终止线程interruptOnFutureCancel: true # 取消后是否终止线程
注意：feign 的 readTimeout 属性和 hystrix 的timeoutInMilliseconds 属性会同时生效，以超时时间最短的为准。
3.2.2降级工厂类的开发
@Componentpublic class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {@Overridepublic EurekaClientService create(Throwable cause) {return new EurekaClientService() {@Overridepublic String exception() throws Exception {System.out.println(\"exception方法 降级\");return \"exception方法 降级\";}@Overridepublic String timeout(Integer timeoutSecond) {return \"timeout方法 降级\";}};}}
3.2.3 启动服务测试
可以正常进入降级方法。
4. 综述
今天聊了一下 服务降级 的相关知识，希望可以对大家的工作有所帮助。
欢迎帮忙点赞、评论、转发、加关注 ：）
关注追风人聊Java，每天更新Java干货。
5. 个人公众号
追风人聊Java，欢迎大家关注
