SpringCloud- 第七篇 Hystrix工作流程(四)

1：工作流程图解

image.png

2：流程说明

• 创建一个 HystrixCommand 或 HystrixObservableCommand 实例来向其它组件发出操作请求，通过构造方法来创建实例。
• 缓存判断
  检查缓存内是否有对应指令的结果，如果有的话，将缓存的结果直接以 Observable 对象的形式返回
• 断路器判断
  检查Circuit Breaker的状态。如果Circuit Breaker的状态为开启状态，Hystrix将不会执行对应指令，而是直接进入失败处理状态（图中8）。如果Circuit Breaker的状态为关闭状态，Hystrix会继续执行
• 线程池、任务队列、信号量的检查
  确认是否有足够的资源执行操作指令。当线程池和队列（或者是信号量，当不使用线程池隔离模式的时候）资源满的时候，Hystrix将不会执行对应指令并且会直接进入失败处理状态
• HystrixObservableCommand.construct()和 HystrixCommand.run()
  如果资源充足，Hystrix将会执行操作指令，调用最终都会到这两个方法：
  HystrixCommand.run()或HystrixObservableCommand.construct()。如果执行指令的时间超时，执行线程会抛出 TimeoutException 异常。Hystrix会抛弃结果并直接进入失败处理状态。如果执行指令成功，Hystrix会进行一系列的数据记录，然后返回执行的结果。
• 统计断路器的健康情况
  Hystrix会根据记录的数据来计算失败比率，一旦失败比率达到某一阈值将自动开启Circuit Breaker
• 降级
  如果在Command中实现了HystrixCommand.getFallback()方法（或HystrixObservableCommand. resumeWithFallback() 方法，Hystrix会返回对应方法的结果。如果没有实现这些方法的话，仍然 Hystrix会返回一个空的 Observable 对象，并且可以通过 onError 来终止并处理错误。
  调用不同的方法返回不同的结果：
  execute()： 将会抛出异常
  queue()： 将会返回一个Future 对象，如果调用它的get()方法将会抛出异常
  observe()和 toObservable()：都会返回上述的 Observable 对象
• 返回成功
  如果Hystrix执行成功，返回的响应取决于在步骤2中调用命令。
  execute()：阻塞型方法，返回单个结果（或者抛出异常）
  queue()：异步方法，返回一个 Future 对象，可以从中取出单个结果（或者抛出异常）
  observe()：返回Observable 对象
  toObservable()：返回Observable 对象