08.微服务防雪崩利器之Hystrix

谁借莪１个温暖的怀抱￠ 2022-10-06 01:53 96阅读 0赞

### 微服务防雪崩利器之Hystrix ###

*   *  前言
     *  Hystrix
     *   *  概念
         *  熔断条件
         *  断路器流程
         *  简单使用
         *   *  1. 启动consul
             *  2.新建Module
             *  3.pom.xml
             *  4.application.properties
             *  5.HystrixApplication.java
             *  6.HystrixController.java
             *  7.测试
         *  OpenFeign+Hystrix实现服务降级
         *   *  正常访问无降级
             *   *  1.新建Module
                 *  2.pom.xml
                 *  3.application.properties
                 *  4.HystrixOpenFeignApplication.java
                 *  5.HystrixClient.java
                 *  6.HystrixOpenFeignController.java
                 *  7.测试
             *  实现服务降级
             *   *  1.引入依赖
                 *  2.开启Hystrix支持
                 *  3.HystrixClient.java
                 *  4.HystrxiClientFallBack.java
                 *  5.测试
         *  补充说明

## 前言 ##

上一节中我们说Hystrix是微服务中防止服务雪崩的利器，但它是Netflix之前开源的一个组件，发展到今天也已经和Eureka与Ribbon一样进入到了维护模式，后面我们会用学习阿里的sentinel（基于Hystrix）。但是作为曾经最火爆的组件之一还是有必要学习一下的

## Hystrix ##

### 概念 ###

[Hystrix][]是一个库，它通过添加延迟容忍和容错逻辑来帮助您控制这些分布式服务之间的交互。Hystrix通过隔离服务之间的访问点、停止它们之间的级联故障以及提供后备选项来实现这一点，所有这些都可以提高系统的整体弹性

通俗定义: **Hystrix**是一个用于处理分布式系统的延迟和容错的开源库，在分布式系统中，许多依赖不可避免的会调用失败、超时、异常等；Hystrix能够保证在一个依赖出问题的情况下，不会导致整体服务失败，避免级联故障(服务雪崩现象)，提高分布式系统的弹性。

### 熔断条件 ###

*  当满足一定的阀值的时候（默认10秒内超过20个请求次数）
 *  当失败率达到一定的时候（默认10秒内超过50%的请求失败）

> 到达以上阀值，断路器将会开启。当开启的时候，所有请求都不会进行转发。 一段时间之后（默认是5秒），这个时候断路器是半开状态，会让其中一个请求进行转发。如果成功，断路器会关闭，若失败，继续开启，如此反复

### 断路器流程 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70]

### 简单使用 ###

#### 1. 启动consul ####

首先`win+R`启动命令行窗口，输入`consul agent -dev`启动我们的服务注册中心

#### 2.新建Module ####

我们新建一个Module - **05.springcloud\_hystrix**，点击`Finish`

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 1]

#### 3.pom.xml ####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>springcloud_parent</artifactId>
            <groupId>com.christy</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>05.springcloud_hystrix</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</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-netflix-hystrix</artifactId>
            </dependency>
        </dependencies>
    </project>

#### 4.application.properties ####

server.port=8900
    spring.application.name=HYSTRIX
    
    # 注册到consul server
    spring.cloud.consul.host=localhost
    spring.cloud.consul.port=8500

#### 5.HystrixApplication.java ####

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    
    /** * @Author Christy * @Date 2021/6/10 15:08 **/
    @SpringBootApplication
    // 代表服务注册中心客户端
    @EnableDiscoveryClient
    // 开启Hystrix服务熔断
    @EnableCircuitBreaker
    public class HystrixApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(HystrixApplication.class, args);
        }
    }

#### 6.HystrixController.java ####

import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /** * @Author Christy * @Date 2021/6/10 15:11 **/
    @RestController
    @RequestMapping("hystrix")
    public class HystrixController { 
    
        @RequestMapping("test")
        /** * fallbackMethod：自定义快速响应失败方法 * defaultFallBack：如果没有特殊情况我们可以使用Hystrix提供的统一默认快速响应处理方法 * 这样可以避免Controller中的每个方法都自定义一个快速失败的响应 * 如果同时写上上面两个，则以前者为准 */
        @HystrixCommand(fallbackMethod = "testHystrixFallBack",defaultFallback = "defaultFallback")
        public String testHystrix(Integer id){ 
            System.out.println("Hystrix test OK!");
            if(id <= 0){ 
               throw new RuntimeException("id必须大于0！");
            }
    
            return "Hystrix test ok!";
        }
    
        /** * 默认速响应失败方法 * 默认的快速响应失败方法不需要跟原方法保持一致 */
        public String defaultFallback(){ 
            return "网络拥堵，请稍后再试……";
        }
    
        /** * 自定义快速响应失败方法 * 参数和返回值必须和testHystrix方法一致 */
        public String testHystrixFallBack(Integer id){ 
            return "网络故障，服务已经被熔断处理！";
        }
    }

#### 7.测试 ####

我们启动项目，在浏览器中输入`http://localhost:8900/hystrix/test?id=1`与`http://localhost:8900/hystrix/test?id=0`查看效果

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 2]

这个时候虽然`id=0`的时候返回的是**网路故障，服务已经被熔断处理**但是此时的服务并没有被熔断。如果服务熔断后正常的访问是访问不了的。

下面我们来模拟一下服务熔断的过程

![在这里插入图片描述][20210610172823228.gif]

当我们10秒内访问失败次数大于20的时候，这个时候开启了熔断；此时我们的正常访问也会进入到快速熔断。等过了5秒之后，我们再次正常访问就会返回正常的结果。

### OpenFeign+Hystrix实现服务降级 ###

#### 正常访问无降级 ####

##### 1.新建Module #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 3]

##### 2.pom.xml #####

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <parent>
            <artifactId>springcloud_parent</artifactId>
            <groupId>com.christy</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>05.springcloud_hystrix_openfeign</artifactId>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
    
        <dependencies>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-consul-discovery</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>
        </dependencies>
    </project>

##### 3.application.properties #####

server.port=8901
    spring.application.name=HYSTRIXOPENFEIGN
    
    #注册服务中心
    spring.cloud.consul.host=localhost
    spring.cloud.consul.port=8500

##### 4.HystrixOpenFeignApplication.java #####

import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.openfeign.EnableFeignClients;
    
    /** * @Author Christy * @Date 2021/6/10 16:05 **/
    @SpringBootApplication
    @EnableDiscoveryClient
    @EnableFeignClients
    public class HystrixOpenFeignApplication { 
        public static void main(String[] args) { 
            SpringApplication.run(HystrixOpenFeignApplication.class, args);
        }
    }

##### 5.HystrixClient.java #####

import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    
    /** * @Author Christy * @Date 2021/6/10 16:09 **/
    @FeignClient(value = "HYSTRIX")
    public interface HystrixClient { 
        @GetMapping("/hystrix/test")
        String testHystrix(@RequestParam("id") Integer id);
    }

##### 6.HystrixOpenFeignController.java #####

import com.christy.feignclients.HystrixClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    /** * @Author Christy * @Date 2021/6/10 16:11 **/
    @RestController
    @RequestMapping("/hystrix/openfeign/")
    public class HystrixOpenFeignController { 
    
        @Autowired
        private HystrixClient hystrixClient;
    
        @RequestMapping("/test")
        public String test(){ 
            System.out.println("hystrix openfeign test ok!");
            String hystrixResult = hystrixClient.testHystrix(1);
            System.out.println("hystrix result : "+hystrixResult);
            return "hystrix openfeign test ok ";
        }
    }

##### 7.测试 #####

上面的代码所实现的功能即服务**HYSTRIXOPENFEIGN**中调用**HYSTRIX**里面的方法，现在我们分别启动这两个服务然后浏览器输入`http://localhost:8901/hystrix/openfeign/test`来看下调用结果

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 4]

上面的结果显示我们的调用成功了。现在我们把**HYSTRIX**服务停掉，再次访问发现无法找到映射

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 5]

通过以上的结果我们想一下能够在OpenFeign这段也加上Hystrix，当服务不可用时进行熔断，执行快速失败响应结果呢？这个是可以的，下只不过这个时候不能叫熔断了，应该叫**服务降级**

#### 实现服务降级 ####

##### 1.引入依赖 #####

如果想要在OpenFeign端实现服务降级就需要引入Hystrix的依赖，所幸的是consul和OpenFeign中都已经依赖了Hystrix，所以我们这里就不需要单独引入Hystrix了

##### 2.开启Hystrix支持 #####

在**HYSTRIXOPENFEIGN**服务的配置文件中添加Hystrix的支持

# 开启openfeign在调用服务过程中 开启hystrix支持 默认:就是没有开启
    feign.hystrix.enabled=true

##### 3.HystrixClient.java #####

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 6]

在注解@FeignClient中有个属性`fallback`，不过他的值是一个class（这里指的是当前注解标注的接口的实现类），我们新建一个实现类就叫做**HystrxiClientFallBack.java**

package com.christy.feignclients;
    
    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    
    /** * @Author Christy * @Date 2021/6/10 16:09 **/
    @FeignClient(value = "HYSTRIX",fallback = HystrixClientFallBack.class)
    public interface HystrixClient { 
        @GetMapping("/hystrix/test")
        String testHystrix(@RequestParam("id") Integer id);
    }

##### 4.HystrxiClientFallBack.java #####

import org.springframework.stereotype.Component;
    
    /** * @Author Christy * @Date 2021/6/10 16:32 **/
    @Component
    public class HystrixClientFallBack implements HystrixClient{ 
        @Override
        public String testHystrix(Integer id) { 
            return "当前服务不可用！";
        }
    }

##### 5.测试 #####

以上工作完毕后我们只启动服务**HYSTRIXOPENFEIGN**，然后浏览器输入`http://localhost:8901/hystrix/openfeign/test`，可以看到当前服务并没有报错，但是控制台输出了**当前服务不可用**

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 7]

当我们再次把服务**HYSTRIX**启动，发现控制台可以正常输出结果

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 8]

至此呢在服务调用端的服务降级功能我们就实现了

### 补充说明 ###

Hystrix其实还有一个知识点就是Hystrix DashBoard，不过这个DashBoard已经被废弃了，后面我们会使用Sentinel DashBoard来替代它，所以这里暂时没有计划对Hystrix DashBoard进行详细说明，如果有必要后期再写吧ヾ(◍°∇°◍)ﾉﾞ

[Hystrix]: https://github.com/Netflix/Hystrix
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70]: /images/20221005/09c4627d0b304e3088faab5375c93bca.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 1]: /images/20221005/4255f9ea4c604a4c96bea63c7113e079.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 2]: /images/20221005/9b8bc8f71556407e8f831f4c8b8d9400.png
[20210610172823228.gif]: /images/20221005/53bd71a21679463aa45b9dfb3d86609c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 3]: /images/20221005/9815a97482ca4fe69eebd70c0024922f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 4]: /images/20221005/b51a83550aca43a29b1c61af23d27dc8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 5]: /images/20221005/a6b95d28c474414c801359bfe85e961d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 6]: /images/20221005/2d54462aff554ab4b6eccbd1c4025adc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 7]: /images/20221005/634319ca56e647ccad317d902f7aa289.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2JieHlscWYxMjZjb20_size_16_color_FFFFFF_t_70 8]: /images/20221005/548a770f4f334814bf0e0b8d6e8cafe7.png