一、熔断原理

在服务熔断中，使用的熔断器，也叫断路器，其英文单词为：Circuit Breaker

熔断机制与家里使用的电路熔断原理类似；当如果电路发生短路的时候能立刻熔断电路，避免发生灾难。在分布式系统中应用服务熔断后；服务调用方可以自己进行判断哪些服务反应慢或存在大量超时，可以针对这些服务进行主动熔断，防止整个系统被拖垮。

Hystrix的服务熔断机制，可以实现弹性容错；当服务请求情况好转之后，可以自动重连。通过断路的方式，将后续请求直接拒绝，一段时间（默认5秒）之后允许部分请求通过，如果调用成功则回到断路器关闭状态，否则继续打开，拒绝请求的服务。

Hystrix的熔断状态机模型
image.png
状态机有3个状态：

  • Closed：关闭状态（断路器关闭），所有请求都正常访问。
  • Open：打开状态（断路器打开），所有请求都会被降级。Hystrix会对请求情况计数，当一定时间内失败请求百分比达到阈值，则触发熔断，断路器会完全打开。默认失败比例的阈值是50%，请求次数最少不低于20次。

  • HalfOpen：半开状态，不是永久的，断路器打开后会进入休眠时间（默认是5S）。随后断路器会自动进入半开状态。此时会释放部分请求通过，若这些请求都是健康的，则会关闭断路器，否则继续保持打开，再次进行休眠计时

    二、代码演示

    为了能够精确控制请求的成功或失败，在consumer-demo的处理器业务方法中加入一段逻辑；
    修改consumer-demo\src\main\java\com\itheima\consumer\controller\Consumercontroller.java

    1. @GetMapping("{id}")
    2. @HystrixCommand
    3. public String queryById(@Pathvariable("id") Long id) {
    4.   if(id == 1){
    5.       throw new RuntimeException("太忙了");
    6.   }
    7.   String url = "http://user-service/user/" + id;
    8.   String user = restTemplate.getForObject(url, String.class);
    9.   return user;
    10. }

    这样如果参数是id为1，一定失败，其它情况都成功。(不要忘了清空user-service中的休眠逻辑)
    我们准备两个请求窗口:

  • 一个请求: http://localhost:8080/consumer/1. 注定失败

  • 一个请求: http://localhost:8080/consumer/2, 肯定成功

当我们疯狂访问id为1的请求时(超过20次) ，就会触发熔断。断路器会打开，一切请求都会被降级处理。

此时你访问id为2的请求，会发现返回的也是失败，而且失败时间很短，只有20毫秒左右；因进入半开状态之后2是可以的。
image.png
不过，默认的熔断触发要求较高，休眠时间窗较短，为了测试方便，我们可以通过配置修改熔断策略：

  1. # 配置熔断策略:
  2. hystrix:
  3.     command:
  4.         default:
  5.             circuitBreaker:
  6.                 errorThresholdpercentage: 50 # 触发熔断错误比例阈值，默认值50%
  7.                 sleepwindowInMilliseconds: 10000 # 熔断后休眠时长，默认值5秒
  8.                 requestvolumeThreshold: 10 # 熔断触发最小请求次数，默认值是20
  9.             execution:
  10.                 isolation:
  11.                     thread:
  12.                         timeoutInMilliseconds: 2000 # 熔断超时设置，默认为1秒

为了方便复制上述配置，可以使用如下格式复制到yml文件中会自动格式化：

  1. hystrix.command.default.circuitBreaker.requestvolumeThreshold=10
  2. hystrix.command.default.circuitBreaker.sleepWindowInMilliseconds=10000
  3. hystrix.command.default.circuitBreaker.errorThresholdPercentage=50
  4. hystrix.command.default.execution.isolation.thread.timeoutInMilliseconds=2000

上述的配置项可以参考HystrixCommandproperties类中。