SpringCloud学习（四）熔断器Hystrix的使用

妖狐艹你老母 2021-12-14 16:49 300阅读 0赞

hystrix 当某个服务单元发生故障（类似用电器发生短路）之后，通过熔断器的故障监控（类似熔断保险丝），直接切断原来的主逻辑调用，可实现服务降级（服务容错保护），线程隔离，熔断器等功能。

服务降级（服务容错保护）与线程隔离是绑在一起的，当调用服务超时时，会触发服务降级；而让熔断器发挥作用则需满足以下三个参数之一：是否强制开启熔断、请求总数下限、错误百分比下限。  
熔断器未打开之前，对于工程中示例的情况就是每个请求都会在当hystrix超时之后返回fallback，每个请求时间延迟就是近似hystrix的超时时间，如果设置为5秒，那么每个请求就都要延迟5秒才会返回。  
当熔断器在10秒内发现请求总数超过20，并且错误百分比超过50%，这个时候熔断器打开。打开之后，再有请求调用的时候，将不会调用主逻辑，而是直接调用降级逻辑，这个时候就不会等待5秒之后才返回fallback。  
通过熔断器，实现了自动地发现错误并将降级逻辑切换为主逻辑，减少响应延迟的效果。

在熔断器打开之后，处理逻辑并没有结束，我们的降级逻辑已经被成了主逻辑，那么原来的主逻辑要如何恢复呢？  
对于这一问题，hystrix也为我们实现了自动恢复功能。当熔断器打开，对主逻辑进行熔断之后，hystrix会启动一个休眠时间窗，在这个时间窗内，降级逻辑是临时的成为主逻辑，当休眠时间窗到期，熔断器将进入半开状态，释放一次请求到原来的主逻辑上，如果此次请求正常返回，那么断路器将继续闭合，主逻辑恢复，如果这次请求依然有问题，熔断器继续进入打开状态，休眠时间窗重新计时。

**注意点：hystrix函数必须为public，fallback函数可以为private。两者需要返回值类型和参数相同。**

由于Hystrix已经停止开发，官方推荐替代项目为Resilience4j，另外也可以用阿里巴巴的sentinel（这两个后面会研究）。

这里会在前面两篇ribbon-conusmer以及feign-consumer工程的基础上改造，对Ribbon+Hystrix与Feign+Hystrix的使用进行介绍使用。

**（一）对ribbon-conusmer工程引入Hystrix**  
使用Hystrix时，需要引入以下依赖，由于父pom.xml中已经依赖了，所以这里子pom.xml不需再引入。

<dependency>
               <groupId>org.springframework.cloud</groupId>
               <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
           </dependency>

1、在RibbonConsumerApplication启动类添加注解`@EnableCircuitBreaker`  
![在这里插入图片描述][2019070318315615.png]  
假如是使用Hystrix熔断器组件，用@EnableHystrix注解亦可，抑或使用@SpringCloudApplication可替代@EnableDiscoveryClient、@SpringBootApplication、@EnableCircuitBreaker以上三个注解

2.改造controller接口方法  
定义一个服务降级方法，即服务调用失败时执行的方法。  
![在这里插入图片描述][20190703184015242.png]  
然后在请求方法头添加注解@HystrixCommand，并设置熔断器触发时的服务降级方法，还可以自定义其他一些属性  
代码：

package com.ningmeng.consumer.controller;
    
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    @RestController
    public class RibbonConsumerController {
    
        @Autowired
        RestTemplate restTemplate;
    
        /**
         * 熔断降级服务ribbonConsumerHystrix方法与ribbonConsumer方法参数以及返回值类型要一致
         * 当熔断器打开即触发熔断后，每隔五秒会尝试连接，看一下是否能够正常执行，如果能够正常执行，那么熔断自动恢复，否则继续处于熔断状态。
         * @return
         */
        @HystrixCommand(fallbackMethod = "ribbonConsumerHystrix", //指定熔断服务降级方法
                commandProperties = {
                        @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds",value = "1000"),//指定多久超时，单位毫秒,超时进fallbackMethod，默认事件为1000毫秒
                        @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "10"),//判断熔断的最少请求数，默认是10；只有在一个统计窗口内处理的请求数量达到这个阈值，才会进行熔断与否的判断
                        @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage",value = "50") //判断熔断的阈值，表示在一个统计窗口内有50%的请求处理失败，会触发熔断，默认是50
                })
        @GetMapping("/ribbonConsumer")
        public String ribbonConsumer(@RequestParam String time) {
            // SERVICE-PROVIDER 对应服务的serviceId,即spring.application.name的属性值，大小写均可
            return restTemplate.getForObject("http://SERVICE-PROVIDER/getApplicationName?time=" + time, String.class);
        }
    
        /**
         * 熔断服务降级方法
         * @return
         */
        public String ribbonConsumerHystrix(@RequestParam String time) {
            return "hystrix熔断：调用接口失败，服务降级，time=" + time;
        }
    }

依次启动eureka-server、service-provider(两个实例)、ribbon-consumer工程，然后把其中一个service-provider实例停掉，访问测试地址[http://localhost:3001/ribbonConsumer?time=2018][http_localhost_3001_ribbonConsumer_time_2018]，可看到当负载均衡访问到停掉的那个实例时，返回熔断服务降级方法中的数据。  
![在这里插入图片描述][20190705005223907.png]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNjgxODQ_size_16_color_FFFFFF_t_70]  
**（二）对feign-conusmer工程引入Hystrix**  
改造过程与ribbon-consumer工程相似，Feign自带对Hystrix支持以及支持ribbon 的负载均衡 ，也可以在application.yml文件设置feign.hystrix.enabled=true，表示开启hystrix熔断器（默认就是true，所以可以省略）。

1、Feign已经支持hytrix熔断，所以不需要再像Ribbon那样添加`@EnableCircuitBreaker`注解

2.改造controller以及service层接口方法  
编写熔断器时执行的服务降级方法，即实现FeignConsumerService接口，然后在@FeignClient注解配置fallback属性指定的方法，controller层不变。  
代码：  
实现service接口：

package com.ningmeng.consumer.service.fallback;
    
    import com.ningmeng.consumer.service.FeignConsumerService;
    import org.springframework.stereotype.Component;
    
    @Component
    public class FeignConsumerHystrix implements FeignConsumerService {
    
        /**
         * 熔断降级服务ribbonConsumerHystrix方法与ribbonConsumer方法参数以及返回值类型要一致
         * @param time
         * @return
         */
        @Override
        public String feignConsumer(String time) {
            return "hystrix熔断：调用接口失败，服务降级，time=" + time;
        }
    }

在service层接口@FeignClient注解添加fallback属性：

package com.ningmeng.consumer.service;
    
    import com.ningmeng.consumer.service.fallback.FeignConsumerHystrix;
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    
    @FeignClient(value = "service-provider", fallback = FeignConsumerHystrix.class)//绑定该接口对应service-provider服务 fallback指定的类必须实现@FeignClient标记的接口
    public interface FeignConsumerService {
    
        /**
         * @RequestMapping属性要跟service-provider服务暴露初开的接口的属性一样  比如post请求方法要对应post请求方法,请求路径名要相同等等
         * 方法中的参数也要与暴露的接口的参数一致(参数数量一致，名称一致（若名称不一致，要通过设置value同名）)
         * @return
         */
        @GetMapping("/getApplicationName")
        String feignConsumer(@RequestParam(value = "time") String time);
    
    }

测试方式跟ribbon-consumer一致，依次启动eureka-server、service-provider(两个实例)、feign-consumer工程，然后把其中一个service-provider实例停掉，访问测试地址[http://localhost:4001/feignConsumer?time=2017][http_localhost_4001_feignConsumer_time_2017]，可看到当负载均衡访问到停掉的那个实例时，返回熔断服务降级方法中的数据。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNjgxODQ_size_16_color_FFFFFF_t_70 1]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNjgxODQ_size_16_color_FFFFFF_t_70 2]

本篇完结！

github代码地址：[https://github.com/huijunzeng/springCloudDemo.git][https_github.com_huijunzeng_springCloudDemo.git]

[2019070318315615.png]: /images/20211214/3e0fce3c923242a79794f2133b838e10.png
[20190703184015242.png]: /images/20211214/0f34c49be01e4a44ab1387df0bb75233.png
[http_localhost_3001_ribbonConsumer_time_2018]: http://localhost:3001/ribbonConsumer?time=2018
[20190705005223907.png]: /images/20211214/244e86f5439d4db698aaa762b75c117f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNjgxODQ_size_16_color_FFFFFF_t_70]: /images/20211214/34020180dde74c1e91c25d90ca1df6b8.png
[http_localhost_4001_feignConsumer_time_2017]: http://localhost:3001/feignConsumer?time=2017
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNjgxODQ_size_16_color_FFFFFF_t_70 1]: /images/20211214/f8e2db33ce9544ebb3c33e335c2e2c4d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3UwMTMwNjgxODQ_size_16_color_FFFFFF_t_70 2]: /images/20211214/b1cde3c066ae407eb9e9cfd3b332e991.png
[https_github.com_huijunzeng_springCloudDemo.git]: https://github.com/huijunzeng/springCloudDemo.git