Hystrix基本用法

Hystrix

Hystrix 是 Netflix公司的一个开源项目，它提供了熔断功能，能够阻止分布式系统中出现联动故障。Hystrix 是通过隔离服务的访问点，阻止联动故障的，并提供了故障的解决方案，从而提高了整个分布式系统的弹性。

Hystrix 的设计原则

防止单个服务的故障耗尽整个服务的Servlet容器（例如 Tomcat）的线程资源。
快速失败机制，如果某个服务出现了故障，则调用该服务的请求快速失败，而不是线程等待。
提供回退（fallback）方案，在请求发生故障时，提供设定好的回退方案。
使用熔断机制，防止故障扩散到其他服务。
提供熔断器的监控组件 Hystrix Dashboard，可以实时监控熔断器的状态。

Hystrix 的工作机制

当服务的某个API接口失败次数在一定时间内小于设定的阀值时，熔断器处于关闭状态，该API接口正常提供服务。
当该API接口处理请求的失败次数大于设定的阀值时，Hystrix 判定该API接口出现了故障，打开熔断器，此时请求该API接口会执行快速失败的逻辑（即fallback回退的逻辑），不执行业务逻辑，请求的线程不会处于堵塞状态。
处于打开状态的熔断器，一段时间后会处于半打开状态，并将一定数量的请求执行正常逻辑。剩余的请求会执行快速失败，如果执行正常逻辑的请求失败了，则熔断器继续打开；如果成功了，则将熔断器关闭。这样熔断器就具有了自我修复能力。

熔断器:Circuit Breaker

熔断器是位于线程池之前的组件。用户请求某一服务之后，Hystrix会先经过熔断器，此时如果熔断器的状态是打开（跳起），则说明已经熔断，这时将直接进行降级处理，不会继续将请求发到线程池。熔断器相当于在线程池之前的一层屏障。每个熔断器默认维护10个bucket ，每秒创建一个bucket ，每个blucket记录成功,失败,超时,拒绝的次数。当有新的bucket被创建时，最旧的bucket会被抛弃。

熔断器的状态机

Closed：熔断器关闭状态，调用失败次数积累，到了阈值（或一定比例）则启动熔断机制；
Open：熔断器打开状态，此时对下游的调用都内部直接返回错误，不走网络，但设计了一个时钟选项，默认的时钟达到了一定时间（这个时间一般设置成平均故障处理时间，也就是MTTR），到了这个时间，进入半熔断状态；
Half-Open：半熔断状态，允许定量的服务请求，如果调用都成功（或一定比例）则认为恢复了，关闭熔断器，否则认为还没好，又回到熔断器打开状态；

流程说明

1:每次调用创建一个新的HystrixCommand，把依赖调用封装在run()方法中。
2:执行execute()/queue做同步或异步调用。
3:判断熔断器(circuit-breaker)是否打开，如果打开跳到步骤8，进行降级策略，如果关闭进入步骤。
4:判断线程池/队列/信号量是否跑满，如果跑满进入降级步骤8，否则继续后续步骤。
5:调用HystrixCommand的run方法。运行依赖逻辑
5a:依赖逻辑调用超时，进入步骤8。
6:判断逻辑是否调用成功
6a:返回成功调用结果
6b:调用出错，进入步骤8。
7:计算熔断器状态，所有的运行状态(成功, 失败, 拒绝,超时)上报给熔断器，用于统计从而判断熔断器状态。
8:getFallback()降级逻辑。
以下四种情况将触发getFallback调用：
(1)：run()方法抛出非HystrixBadRequestException异常
(2)：run()方法调用超时
(3)：熔断器开启拦截调用
(4)：线程池/队列/信号量跑满
8a:没有实现getFallback的Command将直接抛出异常
8b:fallback降级逻辑调用成功直接返回
8c:降级逻辑调用失败抛出异常
9:返回执行成功结果

使用步骤：

引入jar包依赖

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

启动类开启熔断@EnableCircuitBreaker

@SpringBootApplication
@EnableFeignClients
@EnableEurekaClient
@EnableCircuitBreaker
public class RoleServiceMain8004 {public static void main(String[] args) {SpringApplication.run(RoleServiceMain8004.class, args);}}

定义@HystrixCommand

@RestController
public class RemoteCallerController {@Autowiredprivate IUserService iUserService;@GetMapping("/user/sayHi/{name}")@HystrixCommand(fallbackMethod="sayHiFallback")public CommonRsp<String> sayHi(@PathVariable("name") String name) throws Exception {return iUserService.sayHi(name);}public CommonRsp<String> sayHiFallback(@PathVariable("name") String name) throws Exception {return CommonRspUtils.buildSuccessRsp("接口失败");}}

启动应用，测试