【SpringCloud】Hystrix工作原理（十三）

Hystrix工作原理

　　流程图：

　　

　　各节将更详细地说明此流程　HystrixCommand.run

1. 构造一个HystrixCommand或HystrixObservableCommand对象
2. 执行命令
3. 响应是否已缓存？
4. 断路器是否打开吗？
5. 线程池/队列/信号量是否已满？
6. HystrixObservableCommand.construct() 要么 HystrixCommand.run()
7. 计算电路健康
8. 获取Fallback
9. 返回成功的回应

1、构造一个HystrixCommand或HystrixObservableCommand对象

　　第一步是构造一个HystrixCommand或HystrixObservableCommand对象，以表示您对依赖项提出的请求。向构造函数传递发出请求时所需的任何参数。

　　HystrixCommand如果期望依赖项返回单个响应，则构造一个对象。例如：

HystrixCommand command = new HystrixCommand(arg1, arg2);

 

　　HystrixObservableCommand如果期望依赖项返回一个发出响应的Observable，则构造一个对象。例如：

HystrixObservableCommand command = new HystrixObservableCommand(arg1, arg2);

2、执行命令

　　通过使用Hystrix命令对象的以下四种方法之一，可以执行命令的四种方法（前两种仅适用于简单HystrixCommand对象，不适用于HystrixObservableCommand）：

　　execute() —阻止，然后返回从依赖项接收到的单个响应（或在发生错误的情况下引发异常）
　　queue()—返回一个Future，您可以从中获得依赖项的单个响应
　　observe()—订阅，该Observable代表表示从依赖项返回的响应，并返回Observable复制该源的。Observable
　　toObservable()—返回一个Observable，当您订阅它时，将执行Hystrix命令并发出其响应

K             value   = command.execute();
Future<K>     fValue  = command.queue();
Observable<K> ohValue = command.observe();         //hot observable
Observable<K> ocValue = command.toObservable();    //cold observable

　　同步调用execute()调用queue().get()。queue()依次调用toObservable().toBlocking().toFuture()。这就是说，最终每个实现HystrixCommand都由Observable实现支持，即使是那些旨在返回单个简单值的命令也是如此。

3、响应是否已缓存？

　　如果为此命令启用了请求缓存，并且如果对请求的响应在缓存中可用，则该缓存的响应将立即以的形式返回Observable。

4、断路器是否打开？

　　当您执行该命令时，Hystrix会检查断路器，以查看电路是否断开。

　　如果电路开路（或“跳闸”），则Hystrix将不执行命令，而是将流路由到（8）获取回退。

　　如果电路是闭合的，则流程进行到（5），以检查是否有可用于运行命令的容量。

5、线程池/队列/信号量是否已满？

　　如果与该命令关联的线程池和队列（或信号量，如果未在线程中运行）已满，则Hystrix将不会执行该命令，但会立即将流路由到（8）获取回退。

6、HystrixObservableCommand.construct()或HystrixCommand.run()


　　在这里，Hystrix通过为此目的编写的方法（以下之一）调用对依赖项的请求：

　　HystrixCommand.run() —返回单个响应或引发异常
　　HystrixObservableCommand.construct()—返回一个Observable，它发出响应或发送onError通知
　　如果run()or construct()方法超出命令的超时值，则该线程将抛出TimeoutException（如果命令本身未在其自己的线程中运行，则该线程将抛出单独的计时器线程）。在那种情况下，Hystrix通过8路由响应。获取Fallback，如果该方法没有取消/中断，它将丢弃最终的返回值run()或construct()方法。

7、计算电路健康

　　Hystrix向断路器报告成功，失败，拒绝和超时，断路器保持滚动的一组计数器来计算统计信息。

　　它使用这些统计信息来确定电路何时应“跳闸”，在此点它会将随后的所有请求短路，直到经过恢复期为止，在此之后，在首先检查某些运行状况检查之后，它将再次闭合电路。

8、获取Fallback

　　Hystrix尝试在命令执行失败时恢复到您的后备状态：当construct()或引发异常run()（6.），由于电路断开而使命令短路（4.），命令的线程池和队列或信号量为最大容量（5.），或者命令已超过其超时长度。

　　编写后备，以从内存中缓存或通过其他静态逻辑提供通用响应，而无需任何网络依赖性。如果必须在回退中使用网络呼叫，则应通过另一个HystrixCommand或进行HystrixObservableCommand。

　　对于HystrixCommand，要提供回退逻辑，您可以实现HystrixCommand.getFallback()，该逻辑返回单个回退值。

　　对于HystrixObservableCommand，要提供后备逻辑，您可以实现HystrixObservableCommand.resumeWithFallback()该逻辑，该逻辑返回一个Observable，它可能会发出一个或多个后备值。

　　如果fallback方法返回响应，则Hystrix将将此响应返回给调用方。对于a HystrixCommand.getFallback()，它将返回一个Observable，它发出从方法返回的值。在这种情况下，HystrixObservableCommand.resumeWithFallback()它将返回从方法返回的相同Observable。

　　如果尚未为Hystrix命令实现后备方法，或者后备本身引发异常，则Hystrix仍会返回一个Observable，但它不发出任何内容并立即以onError通知终止。通过该onError通知，将导致命令失败的异常发送回调用方。（实施回退实现可能会失败，这是一个糟糕的做法。您应该实施回退，以使其不执行任何可能失败的逻辑。）

9、返回成功的回应

　　如果Hystrix命令成功执行，它将以的形式将一个或多个响应返回给调用方Observable