微服务——Hystrix的使用

╰+哭是因爲堅強的太久メ 2023-09-24 22:06 59阅读 0赞

#### 目录 ####

*  一. Hystrix的简单介绍
 *  二. 使用Hystrix
 *   *  2.1 引入依赖
     *  2.2 开启熔断
     *  2.3 编写降级逻辑
     *  2.4 配置Hystix的超时时间
     *   *  2.4.1 用注解解决Hystix超时问题
         *  2.4.2 用配置文件解决Hystix超时问题
     *  2.5 统一降级方法
     *   *  2.5.1 写一个统一降级方法
         *  2.5.2 注解@HystrixCommand去掉指定的降级方法
         *  2.5.3 在类上添加注解
     *  2.6 Feign结合hystrix完成降级
     *   *  2.6.1 编写Feign客户端
         *  2.6.2 实现Feign客户端（降级方法）
         *  2.6.3 配置文件
         *  2.6.4 入口类添加注解
         *  2.6.5 测试
 *  三. Hystrix的监控平台
 *   *  3.1 搭建Hystrix DashBoard监控
 *  四. 熔断器

## 一. Hystrix的简单介绍 ##

Hystrix是由Netflix开源的一个延迟和容错库，用于隔离访问远程系统、服务或者第三方库，防止级联失  
败，从而提升系统的可用性与容错性。Hystrix主要通过以下几点实现延迟和容错。

>  *  包裹请求：使用HystrixCommand包裹对依赖的调用逻辑，每个命令在独立线程中执行。这使用 了设计模式中的“命令模式”。
>  *  跳闸机制：当某服务的错误率超过一定的阈值时，Hystrix可以自动或手动跳闸，停止请求该服务 一段时间。
>  *  资源隔离：Hystrix为每个依赖都维护了一个小型的线程池（或者信号量）。如果该线程池已满， 发往该依赖的请求就被立即拒绝，而不是排队等待，从而加速失败判定。
>  *  监控：Hystrix可以近乎实时地监控运行指标和配置的变化，例如成功、失败、超时、以及被拒绝 的请求等。
>  *  回退机制：当请求失败、超时、被拒绝，或当断路器打开时，执行回退逻辑。回退逻辑由开发人员 自行提供，例如返回一个缺省值。
>  *  自我修复：断路器打开一段时间后，会自动进入“半开”状态。

## 二. 使用Hystrix ##

### 2.1 引入依赖 ###

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

### 2.2 开启熔断 ###

在启动类 UserApplication 中添加 **@EnableCircuitBreaker** 注解开启对熔断器的支持。  
![在这里插入图片描述][3be2f8718cb04882bfccdbec26aca4f5.png]

### 2.3 编写降级逻辑 ###

1.  降级方法要求：参数列表和返回值都与被保护的方法一致。
2.  在被保护的方式上使用注解@HystrixCommand的fallbackMethod属性，指定熔断触发的降级方法。

@HystriCommand注解：

> fallbackMethod：指定服务降级后调用方法，降级方法参数一定要和controller方法参数一致  
> commandProperties：相关参数。

![在这里插入图片描述][6045c3bf28c94dd9b8af1f727f3d96f3.png]

### 2.4 配置Hystix的超时时间 ###

测试：  
![在这里插入图片描述][c7a6d420a0ef43ea8fa86d17de2110ef.png]  
休眠一秒居然降级了，原因是因为，**Hystix的默认超时时长为 1S** ，所以要修改超时时间，修改超时时间有两张方式：

1.  注解
2.  配置文件

#### 2.4.1 用注解解决Hystix超时问题 ####

![在这里插入图片描述][db3bbf5685df4d8a95de26da3065efac.png]

#### 2.4.2 用配置文件解决Hystix超时问题 ####

# Hystix的默认超时时长为 1S ，
    hystrix:
      command:
        default:
          execution:
            isolation:
              thread:
                timeoutInMilliseconds: 3000

### 2.5 统一降级方法 ###

#### 2.5.1 写一个统一降级方法 ####

> 统一降级方法只要求返回值一样

/*
         *   统一降级方法：
         *    和需要收到保护方法的返回值一致
         * */
        public User defaultBack() {
        
            log.info("------ defaultBack 服务降级 ------");
            User user = userService.queryById(1L);
            user.setAddress("服务降级");
    
            return user ;
        }

#### 2.5.2 注解@HystrixCommand去掉指定的降级方法 ####

![在这里插入图片描述][be7e654cde4241dc9c5eec2f831eb84b.png]

#### 2.5.3 在类上添加注解 ####

> @DefaultProperties(defaultFallback = “defaultBack”)  
> defaultFallback 指定统一的降级方法

### 2.6 Feign结合hystrix完成降级 ###

[关于Feign的使用，点这里][Feign]

#### 2.6.1 编写Feign客户端 ####

注解 @FeignClient 的 fallback 属性指明降级方法

@FeignClient(name="userservice",fallback =
            UserClientImpl.class)
    public interface UserClient {
        
    
        @GetMapping("/user/{id}")
        User findById(@PathVariable("id") Long id);
    }

#### 2.6.2 实现Feign客户端（降级方法） ####

@Slf4j
    @Component
    public class UserClientImpl implements UserClient {
        
    
        @Override
        public User findById(Long id) {
        
            log.info("feign---降级了---");
            return null;
        }
    }

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

*  feign.hystrix.enabled开启feign支持hystrix，在Spring Cloud的E版本之后，默认是关闭的。
 *

feign:
      hystrix:
        enabled: true # feign 开启熔断
      client:
        config:
          default:
            connectTimeout: 5000  #feign 实际的默认超时时间是1s，所以要配置超时时间
            readTimeout: 5000

hystrix默认超时时间是1秒，超过1秒未收到服务的响应就降级

feign:
      hystrix:
        command:
          default:
            execution:
              isolation:
                thread:
                  timeoutInMilliseconds: 2000   #默认是1秒，1秒没有收到其他服务的响应就降级

#### 2.6.4 入口类添加注解 ####

@EnableFeignClients 开启Feign远程调用

#### 2.6.5 测试 ####

关闭被调用的服务  
![在这里插入图片描述][a33d3b67039b43b0a69f7ec8ecc32bc4.png]

## 三. Hystrix的监控平台 ##

除了实现容错功能，Hystrix还提供了近乎实时的监控，HystrixCommand和HystrixObservableCommand在执行时，会生成执行结果和运行指标。比如每秒的请求数量，成功数量等。这些状态会暴露在Actuator提供的/health端点中。

*  引入依赖

<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>

*  暴露所有端点

management:
      endpoints:
        web:
          exposure:
            include: '*'

*  入口类加注解

> @EnableCircuitBreaker // 开启熔断器 开启hystrix

重启，访问，访问http://localhost:8088/actuator/hystrix.stream ,即可看到实时的监控数据。

![在这里插入图片描述][5d3e489e9dc14905ba14f2aadda5c049.png]

### 3.1 搭建Hystrix DashBoard监控 ###

刚刚讨论了Hystrix的监控，但访问/hystrix.stream接口获取的都是已文字形式展示的信息。很难通过文  
字直观的展示系统的运行状态，所以Hystrix官方还提供了基于图形化的DashBoard（仪表盘）监控平  
台。Hystrix仪表盘可以显示每个断路器（被@HystrixCommand注解的方法）的状态。

*  引入依赖

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

*  入口类添加注解
    
        @EnableHystrixDashboard  激活仪表盘项目
 *  重启访问 http://localhost:8088/hystrix

![在这里插入图片描述][b227e984f70148c5b553b12135c1cfd8.png]  
输入监控断点展示监控的详细数据: http://localhost:8088/actuator/hystrix.stream

![在这里插入图片描述][b7c11c7bc74845e589f642bd3ee092d7.png]

显示Loading···，重新发送一次请求就好了。

![在这里插入图片描述][583c77e6a66b45768edc2ea6de3db66c.png]

hystrix控制台面板

![在这里插入图片描述][5eb6b45730674c4cbe4cbc40da716eba.png]

## 四. 熔断器 ##

熔断器有三个状态 CLOSED 、 OPEN 、 HALF\_OPEN 熔断器默认关闭状态，当触发熔断后状态变更为  
OPEN ,在等待到指定的时间，Hystrix会放请求检测服务是否开启，这期间熔断器会变为 HALF\_OPEN 半开启状态，熔断探测服务可用则继续变更为 CLOSED 关闭熔断器。  
![在这里插入图片描述][fdb74bc2541d4f4bb7ba1a684a05ed96.png]

>  *  Closed：关闭状态（断路器关闭），所有请求都正常访问。代理类维护了最近调用失败的次数， 如果某次调用失败，则使失败次数加1。如果最近失败次数超过了在给定时间内允许失败的阈值，  
>     则代理类切换到断开(Open)状态。此时代理开启了一个超时时钟，当该时钟超过了该时间，则切  
>     换到半断开（Half-Open）状态。该超时时间的设定是给了系统一次机会来修正导致调用失败的错 误。
>  *  Open：打开状态（断路器打开），所有请求都会被降级。Hystix会对请求情况计数，当一定时间 内失败请求百分比达到阈值，则触发熔断，断路器会完全关闭。默认失败比例的阈值是50%，请求 次数最少不低于20次。
>  *  Half Open：半开状态，open状态不是永久的，打开后会进入休眠时间（默认是5S）。随后断路 器会自动进入半开状态。此时会释放1次请求通过，若这个请求是健康的，则会关闭断路器，否则 继续保持打开，再次进行5秒休眠计时。

为了能够精确控制请求的成功或失败，我们在 **被调用的服务** 中加入一段逻辑：

@GetMapping("/{id}")
        @HystrixCommand
        public User queryById(@PathVariable("id") Long id,
                              @RequestHeader(value = "Truth", required = false) String truth) throws InterruptedException {
        
            System.out.println("truth: " + truth);
            if (id== 1){
        
                throw new RuntimeException("用户信息异常");
            }
          //  Thread.sleep(1000); //休眠一秒，模拟业务堵塞
            return userService.queryById(id);
        }

熔断器的默认触发阈值是20次请求，不好触发。休眠时间时5秒，时间太短，不易观察，为了测试方  
便，我们可以通过配置修改熔断策略：

hystrix:
      command:
        default:
          circuitBreaker:
            requestVolumeThreshold: 10 #触发熔断的最小请求次数，默认20
            sleepWindowInMilliseconds: 10000 #熔断多少秒后去尝试请求
            errorThresholdPercentage: 50 #触发熔断的失败请求最小占比，默认50%

测试：

> http://localhost:8088/order/101 会导致服务降级

![在这里插入图片描述][748611c0c51e4c989467cc02301518d5.png]

> 连续请求10次以上，熔断器会开启

![在这里插入图片描述][42c9072728c94657a9542e9b9f61a205.png]

> 这时访问 正常的 http://localhost:8088/order/102，也会降级

![在这里插入图片描述][e68fe357957a4e45a09b8cf983db49d6.png]

过一会 http://localhost:8088/order/102 就又能正常访问了。  
![在这里插入图片描述][9f33026384b54e059a42450315fd8f4d.png]

[3be2f8718cb04882bfccdbec26aca4f5.png]: https://img-blog.csdnimg.cn/3be2f8718cb04882bfccdbec26aca4f5.png
[6045c3bf28c94dd9b8af1f727f3d96f3.png]: https://img-blog.csdnimg.cn/6045c3bf28c94dd9b8af1f727f3d96f3.png
[c7a6d420a0ef43ea8fa86d17de2110ef.png]: https://img-blog.csdnimg.cn/c7a6d420a0ef43ea8fa86d17de2110ef.png
[db3bbf5685df4d8a95de26da3065efac.png]: https://img-blog.csdnimg.cn/db3bbf5685df4d8a95de26da3065efac.png
[be7e654cde4241dc9c5eec2f831eb84b.png]: https://img-blog.csdnimg.cn/be7e654cde4241dc9c5eec2f831eb84b.png
[Feign]: https://blog.csdn.net/weixin_53604412/article/details/129302536
[a33d3b67039b43b0a69f7ec8ecc32bc4.png]: https://img-blog.csdnimg.cn/a33d3b67039b43b0a69f7ec8ecc32bc4.png
[5d3e489e9dc14905ba14f2aadda5c049.png]: https://img-blog.csdnimg.cn/5d3e489e9dc14905ba14f2aadda5c049.png
[b227e984f70148c5b553b12135c1cfd8.png]: https://img-blog.csdnimg.cn/b227e984f70148c5b553b12135c1cfd8.png
[b7c11c7bc74845e589f642bd3ee092d7.png]: https://img-blog.csdnimg.cn/b7c11c7bc74845e589f642bd3ee092d7.png
[583c77e6a66b45768edc2ea6de3db66c.png]: https://img-blog.csdnimg.cn/583c77e6a66b45768edc2ea6de3db66c.png
[5eb6b45730674c4cbe4cbc40da716eba.png]: https://img-blog.csdnimg.cn/5eb6b45730674c4cbe4cbc40da716eba.png
[fdb74bc2541d4f4bb7ba1a684a05ed96.png]: https://img-blog.csdnimg.cn/fdb74bc2541d4f4bb7ba1a684a05ed96.png
[748611c0c51e4c989467cc02301518d5.png]: https://img-blog.csdnimg.cn/748611c0c51e4c989467cc02301518d5.png
[42c9072728c94657a9542e9b9f61a205.png]: https://img-blog.csdnimg.cn/42c9072728c94657a9542e9b9f61a205.png
[e68fe357957a4e45a09b8cf983db49d6.png]: https://img-blog.csdnimg.cn/e68fe357957a4e45a09b8cf983db49d6.png
[9f33026384b54e059a42450315fd8f4d.png]: https://img-blog.csdnimg.cn/9f33026384b54e059a42450315fd8f4d.png