hystrix运行流程

素颜马尾好姑娘i 2023-06-15 15:25 81阅读 0赞

![hystrix运行流程][hystrix]  
**（1）构建一个HystrixCommand或HystrixObservableCommand**  
一个HystrixCommand或一个HystrixObservableCommand对象，代表了对某个依赖服务发起的一次请求。

HystrixCommand主要用于仅仅会返回一个结果的调用。  
HystrixObservableCommand主要用于可能会返回多条结果的调用。

**（2）调用command的执行方法**  
执行Command就可以发起一次对依赖服务的调用  
要执行Command，需要在4个方法中选择其中的一个：execute()，queue()，observe()，toObservable()  
其中execute()和queue()仅仅对HystrixCommand适用

execute()：阻塞，然后返回从依赖项接收到的单个响应(或在出现错误时抛出异常)，属于同步调用  
queue()：返回一个Future对象，可以通过Future对象获取单个响应，属于异步调用  
observe()：订阅一个Observable对象，Observable代表的是依赖服务返回的结果，获取到一个那个代表结果的Observable对象的拷贝对象  
toObservable()：返回一个Observable对象，如果我们订阅这个对象，就会执行command并且获取返回结果

**（3）检查是否开启缓存**  
如果这个command开启了请求缓存（Request Caching），并且这个调用的结果在缓存中存在，那么直接从缓存中返回结果  
HystrixCommand和HystrixObservableCommand实现可以定义一个缓存key，然后hystrix会自动进行缓存，接着在同一个request context内，再次访问的时候，就会直接取用缓存。

请求缓存的好处：  
1、不同的调用方式只会执行一次command操作。  
2、数据检索在整个请求中是一致的。  
3、线程不需要重复执行。

**（4）检查是否开启了熔断器（circuit-breaker）**  
当执行command的时候，Hystrix会去检查熔断器是否打开，如果打开了，则不会去执行command，而是直接跳到第（8）步执行fallback降级，如果是关闭的则继续往下执行第（5）步

**（5）检查线程池/队列/semaphore是否已经满了**  
如果command对应的线程池/队列/semaphore已经满了，那么也不会执行command，而是直接去第（8）步调用fallback降级机制

**（6）调用HystrixObservableCommand.construct()或HystrixCommand.run()**  
调用HystrixObservableCommand.construct()或HystrixCommand.run()来实际执行这个command

HystrixCommand.run()是返回一个单条结果，或者抛出一个异常  
HystrixObservableCommand.construct()是返回一个Observable对象，可以获取多条结果或发送一个onError通知

如果run()或construct()方法超时了，线程将抛出一个TimeoutException(如果命令本身不在自己的线程中运行，则单独的计时器线程将抛出一个TimeoutException)。此时执行步骤（8）调用fallback降级机制。run()或construct()方法的返回值也会被丢弃。

**（7）短路健康检查**  
Hystrix会将每一个依赖服务的调用成功，失败，拒绝，超时，等事件，都会发送给circuit breaker熔断器，熔断器就会对调用成功/失败/拒绝/超时等事件的次数进行统计  
熔断器会根据这些统计次数来决定，是否要打开熔断器，打开后后续请求会被直接熔断，当恢复期过去，熔断器会尝试请求，如果请求成功则关闭熔断器。

**（8）调用fallback降级机制**  
1、当construct()或run()方法抛出一个异常  
2、熔断器打开  
3、线程池/队列/semaphore容量满了  
4、command执行超时  
满足以上几种情况，hystrix就会调用fallback降级机制。  
一般在降级机制中，都建议给出一些默认的返回值，比如静态的一些代码逻辑，或者从内存中的缓存中提取一些数据，尽量在这里不要再进行网络请求了  
即使在降级中，一定要进行网络调用，也应该将那个调用放在一个HystrixCommand中，进行隔离。

**（9）返回成功的响应**  
如果command成功调用，将会返回一个Observable对象，并根据第（2）步中执行的方法，转换需要的对象出来。

参考：https://github.com/Netflix/Hystrix/wiki/How-it-Works\#flow7

[hystrix]: https://img-blog.csdnimg.cn/20191123093906899.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xPX1lVTg==,size_16,color_FFFFFF,t_70