SpringCloudAlibaba-Hystrix（六）

怼烎@ 2023-10-14 09:28 3阅读 0赞

**目录**

前言

hystrix注解解释

Hystrix使用Demo

不使用全局配置

父pom文件

pom文件

配置文件

DemoController

启动类

全局配置（使用配置文件）

配置文件

DemoController

OpenFeign结合Hystix使用

pom文件

配置文件

AClient

AClientFallBack

CController

启动类

--------------------

## 前言 ##

为什么要有熔断？在微服务中，服务均是拆分出来的，各个服务之间通过调用来完成整个系统的运转。但是也难免不会出现多个服务调用同一个服务,如图所示；最终都去调用y服务！

![f5857f9e3d2041f98f396e7b1b2d70d4.png][]

若是大批请求过来时，明知道走到某个服务时接口调不通还不立即停止，最终y服务会因压力过大而挂掉。而y服务一挂掉整个系统就gg了！所以熔断机制非常重要。

下面两篇博客很详细的介绍了Hystrix；

[SpringCloud--Hystrix--断路器--01\_springcloud断路器\_boss朴的博客-CSDN博客][SpringCloud--Hystrix--_--01_springcloud_boss_-CSDN]

[SpringCloud--Hystrix--断路器--02\_boss朴的博客-CSDN博客][SpringCloud--Hystrix--_--02_boss_-CSDN]

## hystrix注解解释 ##

1、@EnableHystrix启动类加此注解

2、 @HystrixCommand

@HystrixCommand(fallbackMethod = "testFallback", commandProperties = {
                //设置超时时间 调用此接口超过3秒就认为是失败的
                @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000"),
                //是否开启断路器(熔断)
                @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),
                //统计的时间窗口，默认为10s，一般不需要更改
                @HystrixProperty(name = "metrics.rollingStats.timeInMilliseconds", value = "10000"),
                //请求最小触发次数(在指定的时间窗口里,至少要收到5个请求才会触发机制。如果只收到4个请求，其中2个错误了，虽然到达了触发熔断的阈值50%，但是并不会熔断，因为请求数不够)
                @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "5"),
                //失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到50，则触发断路，断路器开启，链路中断
                @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50"),
                //断路后休眠状态的时长，10s，默认为5s，断路10s后断路器进入半开状态
                @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),
        })

## Hystrix使用Demo ##

### 不使用全局配置 ###

![b8fb4acd1b574e2580f4e7e218b01f53.png][]

#### 父pom文件 ####

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.2.5.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.chensir</groupId>
        <artifactId>nacos-root</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>nacos-root</name>
        <description>nacos-root</description>
        <properties>
            <java.version>1.8</java.version>
            <spring.cloud.version>Hoxton.SR3</spring.cloud.version>
        </properties>
        <packaging>pom</packaging>
        <dependencyManagement>
            <dependencies>
    
    
                <dependency>
                    <groupId>org.projectlombok</groupId>
                    <artifactId>lombok</artifactId>
                    <version>1.18.24</version>
                    <optional>true</optional>
                </dependency>
    
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>${spring.cloud.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
                    <version>2.2.1.RELEASE</version>
                </dependency>
                <dependency>
                    <groupId>com.alibaba.cloud</groupId>
                    <artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId>
                    <version>2.2.1.RELEASE</version>
                </dependency>
                <dependency>
                    <groupId>cn.hutool</groupId>
                    <artifactId>hutool-all</artifactId>
                    <version>5.8.3</version>
                </dependency>
            </dependencies>
    
        </dependencyManagement>
    
        <modules>
            <module>nacos-spring-boot-config</module>
            <module>nacos-spring-cloud-config</module>
            <module>nacos-spring-cloud-discover-a</module>
            <module>nacos-spring-cloud-discover-b</module>
            <module>nacos-spring-cloud-openfeign-c</module>
            <module>nacos-spring-cloud-ribbon</module>
            <module>nacos-spring-cloud-gateway</module>
            <module>spring-cloud-hystrix</module>
    
        </modules>
    </project>

#### pom文件 ####

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.chensir</groupId>
            <artifactId>nacos-root</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <relativePath>../pom.xml</relativePath>
        </parent>
    
        <artifactId>spring-cloud-hystrix</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
            <dependency>
                <groupId>cn.hutool</groupId>
                <artifactId>hutool-all</artifactId>
    
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <configuration>
                        <excludes>
                            <exclude>
                                <groupId>org.projectlombok</groupId>
                                <artifactId>lombok</artifactId>
                            </exclude>
                        </excludes>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    
    </project>

#### 配置文件 ####

server:
      port: 8041

#### DemoController ####

@RestController
    public class DemoController {
    
        //@HystrixCommand 为服务降级;fallbackMethod = "testFallback" 当调用test方法失败或超时时 就调用testFallback这个方法。特有的可以在此使用注解配置,还可以在配置文件中配置公用的！
        @HystrixCommand(fallbackMethod = "testFallback", commandProperties = {
                //设置超时时间 调用此接口超过3秒就认为是失败的
                @HystrixProperty(name = "execution.isolation.thread.timeoutInMilliseconds", value = "3000"),
                //是否开启断路器(熔断)
                @HystrixProperty(name = "circuitBreaker.enabled", value = "true"),
                //统计的时间窗口，默认为10s，一般不需要更改
                @HystrixProperty(name = "metrics.rollingStats.timeInMilliseconds", value = "10000"),
                //请求最小触发次数(在指定的时间窗口里,至少要收到5个请求才会触发机制。如果只收到4个请求，其中2个错误了，虽然到达了触发熔断的阈值50%，但是并不会熔断，因为请求数不够)
                @HystrixProperty(name = "circuitBreaker.requestVolumeThreshold", value = "5"),
                //失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到50，则触发断路，断路器开启，链路中断
                @HystrixProperty(name = "circuitBreaker.errorThresholdPercentage", value = "50"),
                //断路后休眠状态的时长，10s，默认为5s，断路10s后断路器进入半开状态
                @HystrixProperty(name = "circuitBreaker.sleepWindowInMilliseconds", value = "10000"),
        })
        @GetMapping("/test")
        public String test(@RequestParam Integer sleepTime) {
            System.out.println("进入正常方法1");
            ThreadUtil.safeSleep(sleepTime);
            System.out.println("进入正常方法2");
            int a=4/0;
            return "这是正常结果";
        }
    
        //特别注意：特殊定制的兜底方法，形参列表返回类型必须和原方法一致
        //使用了commandKey = "commandKeyTest"  在配置文件中可对它制定华配置
        @HystrixCommand(fallbackMethod = "testFallback2",commandKey = "commandKeyTest")
        public String testFallback(@RequestParam Integer sleepTime) {
            System.out.println("进入兜底方法");
            int a = 4/0;
            return "这是兜底";
    
        }
    
        public String testFallback2(@RequestParam Integer sleepTime) {
            System.out.println("进入兜底方法2");
            return "这是兜底2";
    
        }
    }

#### 启动类 ####

@SpringBootApplication
    @EnableHystrix
    public class SpringCloudHystrixApplication {
    
        public static void main(String[] args) {
            SpringApplication.run(SpringCloudHystrixApplication.class, args);
        }
    
    }

### 全局配置（使用配置文件） ###

父pom、pom、启动类与上方相同

#### 配置文件 ####

server:
      port: 8041
    
    hystrix:
      command:
        default:
          metrics:
            rollingStats:
              timeInMilliseconds: 30000 #统计的时间窗口，默认为10s，一般不需要更改
          fallback:
            enabled: true
          circuitBreaker:
            enabled: true #是否开启断路器
            errorThresholdPercentage: 50 #失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到60，则触发断路，断路器开启，链路中断
            requestVolumeThreshold: 3 #请求最小触发次数
            sleepWindowInMilliseconds: 80000 #断路后休眠状态的时长，10s，默认为5s，断路10s后断路器进入半开状态
          execution:
            isolation:
              thread:
                interruptOnFutureCancel: true #取消是否中断
                interruptOnTimeout: true #超时是否中断
                timeoutInMilliseconds: 3000 #超时阈值，单位是毫秒
            timeout:
              enabled: true
        commandKeyTest: # 对commandKeyTest方法指定化配置
          metrics:
            rollingStats:
              timeInMilliseconds: 30000 #统计的时间窗口，默认为10s，一般不需要更改
          fallback:
            enabled: true
          circuitBreaker:
            enabled: true #是否开启断路器
            errorThresholdPercentage: 50 #失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到60，则触发断路，断路器开启，链路中断
            requestVolumeThreshold: 3 #请求最小触发次数
            sleepWindowInMilliseconds: 80000 #断路后休眠状态的时长，10s，默认为5s，断路10s后断路器进入半开状态
          execution:
            isolation:
              thread:
                interruptOnFutureCancel: true #取消是否中断
                interruptOnTimeout: true #超时是否中断
                timeoutInMilliseconds: 3000 #超时阈值，单位是毫秒
            timeout:
              enabled: true

#### DemoController ####

package com.chensir.controller;
    
    import cn.hutool.core.thread.ThreadUtil;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
    import com.netflix.hystrix.contrib.javanica.annotation.HystrixProperty;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class DemoController {
    
        @GetMapping("/test")
        //@HystrixCommand 为服务降级;fallbackMethod = "testFallback" 当调用test方法失败或超时时 就调用testFallback这个方法。
        @HystrixCommand(fallbackMethod = "testFallback")
        public String test(@RequestParam Integer sleepTime) {
            System.out.println("进入正常方法1");
            ThreadUtil.safeSleep(sleepTime);
            System.out.println("进入正常方法2");
            int a=4/0;
            return "这是正常结果";
        }
    
        //特别注意：特殊定制的兜底方法，形参列表返回类型必须和原方法一致
        //使用了commandKey = "commandKeyTest"  在配置文件中可对它制定华配置
        @HystrixCommand(fallbackMethod = "testFallback2",commandKey = "commandKeyTest")
        public String testFallback(@RequestParam Integer sleepTime) {
            System.out.println("进入兜底方法");
            int a = 4/0;
            return "这是兜底";
    
        }
    
        public String testFallback2(@RequestParam Integer sleepTime) {
            System.out.println("进入兜底方法2");
            return "这是兜底2";
    
        }
    }

## OpenFeign结合Hystix使用 ##

![96fff52c37134f378f0038f122ef3cfa.png][]

### pom文件 ###

<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>com.chensir</groupId>
            <artifactId>nacos-root</artifactId>
            <version>0.0.1-SNAPSHOT</version>
            <relativePath>../pom.xml</relativePath>
        </parent>
    
        <artifactId>nacos-spring-cloud-openfeign-c</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>cn.hutool</groupId>
                <artifactId>hutool-all</artifactId>
            </dependency>
    
          <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
    
         </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-openfeign</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-loadbalancer</artifactId>
            </dependency>
    
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            </dependency>
    
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                    <configuration>
                        <excludes>
                            <exclude>
                                <groupId>org.projectlombok</groupId>
                                <artifactId>lombok</artifactId>
                            </exclude>
                        </excludes>
                    </configuration>
                </plugin>
            </plugins>
        </build>
    
    </project>

### 配置文件 ###

logging:
      level:
        com:
          chensir: debug
    server:
      port: 8073
    spring:
      application:
        name: nacos-app-c
      cloud:
        nacos:
          discovery:
            server-addr: localhost:8848
        loadbalancer:
          ribbon:
            enable: false
    
    feign:
      hystrix:
        enabled: true
    #设置feign客户端超时时间(OpenFeign默认支持ribbon)
    ribbon:
      #指的是建立连接所用的时间，适用于网络状况正常的情况下,两端连接所用的时间
      ReadTimeout: 10000
      #指的是建立连接后从服务器读取到可用资源所用的时间
      ConnectTimeout: 10000
    
    hystrix:
      command:
        default:
          metrics:
            rollingStats:
              timeInMilliseconds: 30000 #统计的时间窗口，默认为10s，一般不需要更改
          fallback:
            enabled: true
          circuitBreaker:
            enabled: true #是否开启断路器
            errorThresholdPercentage: 50 #失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到60，则触发断路，断路器开启，链路中断
            requestVolumeThreshold: 3 #请求最小触发次数
            sleepWindowInMilliseconds: 80000 #断路后休眠状态的时长，10s，默认为5s，断路10s后断路器进入半开状态
          execution:
            isolation:
              thread:
                interruptOnFutureCancel: true #取消是否中断
                interruptOnTimeout: true #超时是否中断
                timeoutInMilliseconds: 3000 #超时阈值，单位是毫秒
            timeout:
              enabled: true
        commandKeyTest:
          metrics:
            rollingStats:
              timeInMilliseconds: 30000 #统计的时间窗口，默认为10s，一般不需要更改
          fallback:
            enabled: true
          circuitBreaker:
            enabled: true #是否开启断路器
            errorThresholdPercentage: 50 #失败率达到多少后跳闸，在统计窗口期中，请求数大于阈值并且失败率达到60，则触发断路，断路器开启，链路中断
            requestVolumeThreshold: 3 #请求最小触发次数
            sleepWindowInMilliseconds: 80000 #断路后休眠状态的时长，10s，默认为5s，断路10s后断路器进入半开状态
          execution:
            isolation:
              thread:
                interruptOnFutureCancel: true #取消是否中断
                interruptOnTimeout: true #超时是否中断
                timeoutInMilliseconds: 3000 #超时阈值，单位是毫秒
            timeout:
              enabled: true

### AClient ###

@FeignClient(value = "nacos-app-a",fallback = AClientFallBack.class)
    //@FeignClient(value = "nacos-app-a")
    public interface AClient {
    
        @GetMapping("/echo")
        String test(@RequestParam("name") String name) ;
    
    
    }

### AClientFallBack ###

@Service
    public class AClientFallBack implements  AClient {
        @Override
        public String test(@RequestParam("name") String name) {
            return "兜底";
        }
    }

### CController ###

@RestController
    public class CController {
    
        @Autowired
        private RestTemplate restTemplate;
    
    
        @Autowired
        private AClient aClient;
    
        @GetMapping("/test")
        public String test(@RequestParam(value = "name", defaultValue = "这是默认值") String name) {
    
            System.out.println("进来了");
            String ret = aClient.test(name);
            return  ret;
        }
    
        @GetMapping("/test2")
        public String test2(@RequestParam(value = "name", defaultValue = "这是默认值") String name) {
    
    
            String ret = restTemplate.getForObject("http://nacos-app-a/echo?name="+name,String.class);
            return  ret;
        }
    }

### 启动类 ###

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

[f5857f9e3d2041f98f396e7b1b2d70d4.png]: https://img-blog.csdnimg.cn/f5857f9e3d2041f98f396e7b1b2d70d4.png
[SpringCloud--Hystrix--_--01_springcloud_boss_-CSDN]: https://blog.csdn.net/m0_46159545/article/details/107801501
[SpringCloud--Hystrix--_--02_boss_-CSDN]: https://blog.csdn.net/m0_46159545/article/details/107801587
[b8fb4acd1b574e2580f4e7e218b01f53.png]: https://img-blog.csdnimg.cn/b8fb4acd1b574e2580f4e7e218b01f53.png
[96fff52c37134f378f0038f122ef3cfa.png]: https://img-blog.csdnimg.cn/96fff52c37134f378f0038f122ef3cfa.png