没有使用过hystrix，需要了解hystrix原理：How-it-Works
整体流程
image.png
1.构造一个 HystrixCommand或者HystrixObservableCommand对象
2.执行命令
3.是否返回值已经缓存？
4.是否打开断路器？
5.是否线程池/队列/型号量已满？
6.执行HystrixObservableCommand.construct() 或者HystrixCommand.run()方法
7.计算线路健康值
8.获取fallback 基于本地缓存的 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()orconstruct()方法超出命令的超时值，则该线程将抛出TimeoutException（如果命令本身未在其自己的线程中运行，则该线程将抛出单独的计时器线程）。在那种情况下，Hystrix通过8路由响应。获取Fallback，如果该方法没有取消/中断，它将丢弃最终的返回值run()或construct()方法。
请注意，没有办法强制潜在线程停止工作-Hystrix在JVM上能做的最好的事情就是将其抛出InterruptedException。如果Hystrix封装的工作不遵守InterruptedExceptions，尽管客户端已经收到TimeoutException，Hystrix线程池中的线程仍将继续工作。尽管负载已“正确释放”，但此行为可能会使Hystrix线程池饱和。大多数Java HTTP客户端库不解释InterruptedExceptions。因此，请确保在HTTP客户端上正确配置连接和读取/写入超时。
如果命令没有引发任何异常并且返回了响应，则Hystrix在执行一些日志记录和度量标准报告后将返回此响应。在的情况下run()，Hystrix返回Observable发出单个响应并发出onCompleted通知的；在的情况下construct()猬返回相同Observable的返回construct()。
7.计算电路健康
Hystrix向断路器报告成功，失败，拒绝和超时，断路器保持滚动的一组计数器来计算统计信息。
它使用这些统计信息来确定电路何时应“跳闸”，在此点它会将随后的所有请求短路，直到经过恢复期为止，在此之后，在首先检查某些运行状况检查之后，它将再次闭合电路。
8.获取后备
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通知，将导致命令失败的异常发送回调用方。（实施回退实现可能会失败，这是一个糟糕的做法。您应该实施回退，以使其不执行任何可能失败的逻辑。）
后备失败或不存在的后备结果将因调用Hystrix命令的方式而异：
-
execute()-引发异常 -
queue()—成功返回Future，但是Future如果get()调用其方法，则会抛出异常 -
observe()—返回一个Observable，当您订阅它时，将通过调用订阅者的onError方法立即终止 -
toObservable()—返回一个Observable，当您订阅时，它将通过调用订阅者的onError方法终止
9.返回成功的回应
如果Hystrix命令成功执行，它将以的形式将一个或多个响应返回给调用方Observable。根据您在上面的步骤2中调用命令的方式，在Observable返回给您之前，可能会对其进行转换：
image.png
-
execute()-获得Future的相同方式一样.queue()，然后调用get()在此Future以获得由所发射的单个值Observable -
queue()—将转换Observable为，BlockingObservable以便可以将其转换为Future，然后返回Future -
observe()—Observable立即订阅并开始执行命令的流程；返回一个Observable，当您subscribe重播时，它会排放和通知 -
toObservable()—返回Observable不变；您必须先subscribe执行此命令才能真正开始导致执行命令的流程
网友评论