SpringCloud 2020.0.4 系列之服务降级

本文主要是介绍SpringCloud 2020.0.4 系列之服务降级，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1. 概述

2. 接口报错的服务降级

3. 接口超时的服务降级

4. 综述

5. 个人公众号

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 降级工厂类的开发

@Component
public 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
@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 实现类代码

    @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 降级工厂类的开发

@Component
public 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 启动服务测试

可以正常进入降级方法。