1. 概述
老话说的好：做人要正直，做事要正派，胸怀坦荡、光明磊落，才会赢得他人的信赖与尊敬。
言归正传，之前聊了服务间通信的组件 Feign，今天我们来聊聊服务降级。
服务降级简单的理解就是给一个备选方案，当服务调用报错或者超时时，能终止远程调用，并很快的返回备选的结果，避免引发服务雪崩。
今天我们用两个例子，模拟一下 接口报错 和 接口超时 的服务降级实现。
我们使用 hystrix 实现服务降级，虽然从 Spring Cloud 2020.0 版本开始，移除了 hystrix 组件，但并不影响我们对他的使用。
闲话不多说，直接上代码。
2. 接口报错的服务降级
2.1 被调用服务
2.1.1 接口代码
@GetMapping("/exception")
String exception() throws Exception;
2.1.2 实现类代码
@Override
public 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 降级工厂类的开发
@Component
public class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {
@Override
public EurekaClientService create(Throwable cause) { return new EurekaClientService() { @Override
public 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
@EnableHystrix
public 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 实现类代码
@Override
public 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 # 连接超时时间，单位ms
readTimeout: 3000 # 获取Response响应超时时间，单位ms # 针对 my-eureka-client 的 feign 配置，优先级高于全局配置
my-eureka-client:
connectTimeout: 300 # 连接超时时间，单位ms
readTimeout: 5000 # 获取Response响应超时时间，单位ms
circuitbreaker:
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 降级工厂类的开发
@Component
public class MyEurekaClientServiceFactory implements FallbackFactory<EurekaClientService> {
@Override
public EurekaClientService create(Throwable cause) { return new EurekaClientService() { @Override
public String exception() throws Exception {
System.out.println("exception方法 降级");
return "exception方法 降级";
} @Override
public String timeout(Integer timeoutSecond) {
return "timeout方法 降级";
}
};
}
}
3.2.3 启动服务测试
可以正常进入降级方法。
4. 综述
今天聊了一下 服务降级 的相关知识，希望可以对大家的工作有所帮助。
欢迎帮忙点赞、评论、转发、加关注 ：）
关注追风人聊Java，每天更新Java干货。
5. 个人公众号
追风人聊Java，欢迎大家关注
