spring cloud中使用hystrix实现回退

悠悠 2024-02-19 18:43 42阅读 0赞

在微服务架构中，我们的服务被拆分成多个微服务，每个微服务完成自己的职责，微服务之间通过rpc或http进行调用。这个时候我们就要确保我们的服务高可用，但谁也说不准我们的服务能永远快速的提供服务。**假如现在发生了这个一种情况** A->B->C->D->E 即A服务调用B服务，B调用C服务，C调用D服务，D调用E服务，这个时候我们的E服务过载，响应速度特别慢，当并发高时，我们的请求就会堆积在E服务，E服务无法返回，导致请求堆积在D服务，以此类推，就会导致请求依次堆积在我们的这个调用链上，最终导致所有的服务都不可用，形成服务的雪崩。**下面以一个简单的图来表示服务的雪崩。**  
![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTAxL2NiOWNjODI5LWU3ZDQtMzk1Mi1hNjljLTdmYjI5NzAxYjI2Ny5wbmc][]

**为了解决以上问题**,spring cloud中为我们提供了 **hystrix** 断路器来保护我们的应用程序。  
**断路器机制：**hystrix存在三种状态：CLOSED、OPEN和HALF\_OPEN。默认情况下为CLOSED,当一个服务在一定的时间内(**metrics.rollingStats.timeInMilliseconds**默认10s)，请求次数达到了某个阀值(**circuitBreaker.requestVolumeThreshold**默认20次)，并且错误率也达到了某个阀值(**`circuitBreaker.errorThresholdPercentage`**默认>50%)，此时断路器变成了OPEN的状态，当断路器打开，过了一定的时间(**circuitBreaker.sleepWindowInMilliseconds**默认为5s)将会放行一个请求，此时变成HALF\_OPEN状态，如果可以访问就变成CLOSED否则变成OPEN状态  
**资源隔离：**hystrix为每个依赖都提供了一个线程池或信号量。当线程池满了之后，发往该依赖的请求会被直接拒绝，从而加速失败。

**注意：** 进入fallback方法并不意味者断路器一定是打开的，请求失败、超时、被拒绝以及断路器打开时都会执行回退逻辑。

## 需求： ##

1、在feign中使用hystrix  
2、在降级方法中获取到为什么进入了降级方法

## 代码结构： ##

eureka-server  
|- 服务注册中心  
hystrix  
product-provider-8091  
|- 服务提供者  
 **product-consumer-feign-hystrix-8093**  
|- feign 和 hystrix的整合  
feign  
 **fallback**  
 **ProductServiceFeignFallback(回退实现)**  
 **ProductServiceFeignFallbackFactory(可以获知为何进入回退)**

## 代码实现 ##

### 一、注册中心和服务提供者的实现（见下方的代码） ###

### 二、服务消费者（需要引入hystrix） ###

#### 1、feign和hystrix引入 ####

<dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</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>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>

#### 2、启动方法上增加@EnableCircuitBreaker 注解 ####

@SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    @EnableCircuitBreaker
    public class ApplicationProductConsumer8093 {
    
    	public static void main(String[] args) {
    		SpringApplication.run(ApplicationProductConsumer8093.class, args);
    	}
    }

####  **3、配置文件中在feign中启动hystrix** ####

feign:
      hystrix:
        enabled: true

#### 4、回退的实现，fallback的实现 ####

![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTExLzZkM2ZlMzdhLTFjYzUtMzBiZi1iNjJiLTFmYzgyY2EzZTc0Yi5wbmc][]

####  注意： fallbackFatory 需要注意的事项 ####

![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTEzL2U3NWYxNTk3LWY0YTAtM2ZkZC05MjVjLWI1YjA0MjQ0MGUzOC5wbmc][]

#### 5、控制层的写法 ####

/**
     * 商品控制器
     *
     * @author huan.fu
     * @date 2018/5/30 - 16:52
     */
    @RestController
    @RequestMapping("product")
    public class ProductController {
    
    	@Autowired
    	private ProductService01Feign productService01Feign;
    
    	@Autowired
    	private ProductService02Feign productService02Feign;
    
    	/**
    	 * 获取商品信息
    	 *
    	 * @param productId
    	 * @return
    	 */
    	@GetMapping("/01/selectOne/{productId}")
    	public Map<String, Object> select01ByProductId(@PathVariable String productId) {
    		return productService01Feign.selectByProductId(productId);
    	}
    
    	/**
    	 * 获取商品信息
    	 *
    	 * @param productId
    	 * @return
    	 */
    	@GetMapping("/02/selectOne/{productId}")
    	public Map<String, Object> select02ByProductId(@PathVariable String productId) {
    		return productService02Feign.selectByProductId(productId);
    	}
    }

/product/**01**/selectOne/\{productId\} ===>  **fallback 回退**

/product/**02**/selectOne/\{productId\} ===> **fallbackFactory 回退，可以知道回退的原因**

#### 6、测试 ####

**测试的服务启动者先启动，然后停止看效果。  
![aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTE1L2QzZDI0MWZjLTQ2NjQtMzhlOS1iMTJlLTFjNTg4OWMxNjY5MC5naWY][]**

## 完整代码 ##

[ https://gitee.com/huan1993/spring-cloud-parent/tree/master/hystrix][https_gitee.com_huan1993_spring-cloud-parent_tree_master_hystrix]

[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTAxL2NiOWNjODI5LWU3ZDQtMzk1Mi1hNjljLTdmYjI5NzAxYjI2Ny5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/dc6aaf2cba144e73b95b75648a57a670.png
[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTExLzZkM2ZlMzdhLTFjYzUtMzBiZi1iNjJiLTFmYzgyY2EzZTc0Yi5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/4384a4f70b454ded8cb9261c0a9eeb07.png
[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTEzL2U3NWYxNTk3LWY0YTAtM2ZkZC05MjVjLWI1YjA0MjQ0MGUzOC5wbmc]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/7f167a0053054f5cabb41f178497b253.png
[aHR0cDovL2RsMi5pdGV5ZS5jb20vdXBsb2FkL2F0dGFjaG1lbnQvMDEyOS85OTE1L2QzZDI0MWZjLTQ2NjQtMzhlOS1iMTJlLTFjNTg4OWMxNjY5MC5naWY]: https://image.dandelioncloud.cn/pgy_files/images/2024/01/29/99aab56a24bd47cdacc0abd0016c2957.png
[https_gitee.com_huan1993_spring-cloud-parent_tree_master_hystrix]: https://gitee.com/huan1993/spring-cloud-parent/tree/master/hystrix