目录

一. 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 注解开启对熔断器的支持。
在这里插入图片描述

2.3 编写降级逻辑

  1. 降级方法要求：参数列表和返回值都与被保护的方法一致。

  2. 在被保护的方式上使用注解@HystrixCommand的fallbackMethod属性，指定熔断触发的降级方法。

@HystriCommand注解：

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

在这里插入图片描述

2.4 配置Hystix的超时时间

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

  1. 注解
  2. 配置文件

2.4.1 用注解解决Hystix超时问题

在这里插入图片描述

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去掉指定的降级方法

在这里插入图片描述

2.5.3 在类上添加注解

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

2.6 Feign结合hystrix完成降级

关于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 测试

关闭被调用的服务
在这里插入图片描述

三. Hystrix的监控平台

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

  • 引入依赖
   <!-- Hystrix的监控平台 -->
       <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 ,即可看到实时的监控数据。

在这里插入图片描述

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

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

在这里插入图片描述

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

在这里插入图片描述

hystrix控制台面板

在这里插入图片描述

四. 熔断器

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

  • 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 会导致服务降级

在这里插入图片描述

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

在这里插入图片描述

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

在这里插入图片描述

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

# 微服务 # hystrix # java
Logo
GitCode 开源社区

旨在为数千万中国开发者提供一个无缝且高效的云端环境，以支持学习、使用和贡献开源项目。

更多推荐

cover

GitTalk | 使用面向业务的狮偶编程语言提升开发效率

avatar GitCode 开源社区
cover

GitTalk | DevUI Suits 场景解决方案

avatar GitCode 开源社区
cover

GitTalk | DevUI Admin 前端项目构建

avatar GitCode 开源社区