hystrixCommand底层对结果的获取都使用了RxJava中的Observe，这样实现有什么优势呢？

Question

问题描述

问题出现的环境背景及自己尝试过哪些方法

使用常规的异步调用阻塞获取结果也能达到一样的效果，那observe是使得这个实现过程变得更加简约了？还是说另有其独特之处？

相关代码

我对于rxjava的了解比较少，在我看来，他在处理大量消息的时候功能多，性能好，但是http调用过程，应该是一次丢进去一个请求（消息），这样如何能体现他的优势呢？

Answer 1

Hystrix通过滑动窗口的数据结构来统计调用的指标数据，并且大量使用了RxJava响应式编程操作符。滑动窗口的本质就是不断变换的数据流，因此滑动窗口的实现非常适合使用观察者模式以及响应式编程模式去完成。最终，RxJava便成了Hystrix滑动窗口实现的框架选择。Hystrix滑动窗口的核心实现是使用RxJava的window操作符（算子）来完成的。使用RxJava实现滑动窗口还有一大好处就是可以依赖RxJava的线程模型来保证数据写入和聚合的线程安全。