SpringBoot如何整合Hystrix

Posted 2023-04-26

参考技术A

在application.properties配置文件中加入如下配置：

将全局的默认超时时间由1s修改为3s，但是配置未起作用。

Archaius 默认支持两种方式来加载本地的配置文件：

使用注解的方式，为方法添加hystrix断路器。

在resources\\config.properties中进行配置：

使用Hystrix后，配置均会在 com.netflix.hystrix.AbstractCommand#AbstractCommand 类中组装。

[图片上传失败...(image-a9070e-1612084543977)]

注：需要注意的是，虽然在3个地方设置了 超时时间。但是只有4000ms的超时时间生效。

1. hystrix配置的优先级是怎么样的呢？
2. 如何为某个方法配置不同的hystrix策略？

优先级从低到高的配置：

注：全局配置是default的配置，而实例配置为commandKey配置。

默认情况下，Hystrix会使用 类名作为CommandGroup ，会使用 方法名作为CommandKey。 可以使用commandKey进行个性化的配置。参考【1.3 如何使用】

[图片上传失败...(image-95f991-1612084543977)]

表示HystrixCommand.run()的执行时的策略，有以下两种策略：

以下属性控制 HystrixCommand.getFallback() 如何执行，这些属性对隔离策略 THREAD 和 SEMAPHORE 都起作用。

此属性设置从调用线程允许Hystrix.getFallback()方法允许的最大并发请求数，如果达到最大的并发量，则接下来的请求都会被拒绝并且抛出异常。

控制断路器的行为。

默认值20。若是在10s(窗口时间)内，只收到19个请求且都失败了，则断路器也不会开启。

断路器跳闸后，在此值的时间内，hystrix会拒绝新的请求，只有过了这个时间，断路器才会打开闸门。默认值5000ms

设置失败百分比的阈值，如果失败比率超过这个值，则断路器跳闸并且进入fallback状态。默认值：50

如果这个属性true强制断路器进入开路（跳闸）状态，它将拒绝所有请求。
此属性优先于circuitBreaker.forceClosed。默认值false

如果设置true，则强制使断路器进行关闭状态，此时会允许执行所有请求，无论是否失败的次数达到circuitBreaker.errorThresholdPercentage值。默认值：false。

捕获和HystrixCommand以及HystrixObservableCommand执行信息相关的配置属性。

Hystrix保留断路器使用和发布指标的时间。默认值：10000

metrics.rollingStats.timeInMilliseconds % metrics.rollingStats.numBuckets == 01
如：10000/10、10000/20是正确的配置,但是10000/7错误的。默认值：10
注：在高并发的环境里，每个桶的时间长度建议大于100ms。

该属性控制HystrixCommand使用到的Hystrix的上下文。

默认值：true

表示是否开启日志，打印执行HystrixCommand的情况和事件。默认值true

设置请求合并请求。

默认值：Integer.MAX_VALUE

默认值：10

是否对HystrixCollapser.execute() 和 HystrixCollapser.queue()开启请求缓存
默认值：true

默认值：10

在1.5.9中添加。此属性设置最大线程池大小。这是在不开始拒绝HystrixCommands的情况下可以支持的最大并发数量。请注意，此设置仅在您设置时生效allowMaximumSizeToDivergeFromCoreSize。在1.5.9之前，核心和最大尺寸始终相等。
默认值：10

设置最大的BlockingQueue队列的值。如果设置-1，则使用SynchronousQueue队列（无限队列）。如果设置正数，则使用LinkedBlockingQueue队列。默认值：-1

因为maxQueueSize值不能被动态修改，所有通过设置此值可以实现动态修改等待队列长度。即等待的队列的数量大于queueSizeRejectionThreshold时（但是没有达到maxQueueSize值），则开始拒绝后续的请求进入队列。
默认值：5
注：如果设置-1，则属性不启作用。

设置线程空闲多长时间后，释放（maximumSize-coreSize ）个线程。默认值1（分钟）

设置allowMaximumSizeToDivergeFromCoreSize值为true时，maximumSize才有作用
默认值：false

官网——Hystrix的参数配置
Hystrix常用功能介绍
Hystrix源码解析--从原生的lib开始使用hystrix(一)

15Feign整合断路器监控Hystrix Dashboard

Ribbon可以整合整合断路器监控Hystrix Dashboard，Feign也不能少, 本篇讲解一下Feign如何整合断路器监控Hystrix Dashboard。本篇主要整合sc-eureka-client-consumer-feign-hystrix项目和sc-hystrix-dashboard项目。

1、新建项目sc-feign-hystrix-dashboard，对应的pom.xml文件如下

<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">
    <modelVersion>4.0.0</modelVersion>

    <groupId>spring-cloud</groupId>
    <artifactId>sc-feign-hystrix-dashboard</artifactId>
    <version>0.0.1-SNAPSHOT</version>
    <packaging>jar</packaging>

    <name>sc-feign-hystrix-dashboard</name>
    <url>http://maven.apache.org</url>

    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.0.4.RELEASE</version>
    </parent>

    <dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Finchley.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

        </dependencies>
    </dependencyManagement>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <maven.compiler.source>1.8</maven.compiler.source>
        <maven.compiler.target>1.8</maven.compiler.target>
    </properties>

    <dependencies>

        <!-- 说明是一个 eureka client -->
        <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.cloud</groupId> 
                        <artifactId>spring-cloud-starter-feign</artifactId> 
                    <version>1.4.5.RELEASE</version> 
             </dependency> -->

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

        <!-- <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix-dashboard</artifactId>
                <version>1.4.5.RELEASE</version>
        </dependency> -->

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

        <!-- <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-hystrix</artifactId>
                <version>1.4.5.RELEASE</version>
        </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>

    </dependencies>
</project>

说明：可以看出这个pom.xml文件是sc-eureka-client-consumer-feign-hystrix项目和sc-hystrix-dashboard项目的并集。

2、新建spring root 启动类FeignDashboardApplication.java

package sc.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableEurekaClient
@EnableFeignClients
@EnableHystrixDashboard
public class FeignDashboardApplication {

    public static void main(String[] args) {
        SpringApplication.run(FeignDashboardApplication.class, args);
    }

}

这个启动类的注解是sc-eureka-client-consumer-feign-hystrix项目和sc-hystrix-dashboard项目的并集
3、其他项目文件说明如下，具体见源码

4、启动注册中心sc-eureka-server和服务提供者sc-eureka-client-provider，并确保启动成功

5、启动sc-feign-hystrix-dashboard项目，并验证是否启动成功
方式一：访问注册中心查看sc-feign-hystrix-dashboard项目配置的服务名是否注册成功

方式二：访问仪表盘Dashboard对的地址http://127.0.0.1:5800/hystrix

6、使用Hystrix Dashboard查看服务情况
在下图标注处输入http://127.0.0.1:5800/hystrix.stream

然后点击Monitor Stream按钮

7、使用postman访问任意服务接口，以访问获取用户信息接口为例
http://127.0.0.1:5800/feign/user/getUser/3

尽量多访问几次，然后查看仪表盘Bashboard监控后台，发现之前一直处于Loading的界面发生了变化，如下图，图中单元具体含义可以访问网站
https://github.com/Netflix-Skunkworks/hystrix-dashboard/wiki

访问http://127.0.0.1:5800/hystrix.stream也出现大量数据，这些数据就是对服务的监控数据。