【问题标题】:Hystrix Execution PatternsHystrix 执行模式
【发布时间】:2015-01-19 20:56:53
【问题描述】:
我正试图围绕Hystrix 转转,在阅读了他们的文档后,仍然对其使用模式有疑问。
一方面,我不了解 何时 使用他们的 异步 执行与他们的 Reactive用例 /strong> 执行。我能看到的唯一区别是异步执行始终是非阻塞的,而 Reactive 既可以是阻塞的,也可以是非阻塞的。所以我想我真正的问题是:
- 同步执行和阻塞响应执行有什么区别?和
- 异步和非阻塞响应式执行有什么区别?
【问题讨论】:
标签:
java
asynchronous
reactive-programming
fault-tolerance
hystrix
【解决方案1】:
假设您已将两个服务调用 A 和 B 包装为 HystrixCommand。您现在有三个选择:
使用.execute():纯同步调用。一旦结果到达,您调用该方法并继续您的程序。您的程序的总执行时间是两个调用的总和。您的程序的主要流程是非常线性的。
使用.queue():立即为这两个命令接收Future。两个服务调用并行执行。然后使用.get() 检索结果。这些调用与阻塞,直到结果在那里。您的总执行时间比以前更快:您的执行时间将是最长服务调用的长度。当您想要合并两个服务的结果时使用它。尽管两个调用是并行执行的,但程序的主要流程仍然是线性的。
使用.subscribe():立即为这两个命令接收Observable。两个服务调用并行执行。然后使用.subscribe() 注册一个回调,以便在结果可用时对其进行操作。如果您不想合并结果并希望在服务 A 和 B 的结果到达后独立地做出反应,这将非常有用。
您的程序的主要流程不是线性的,而是反应式的:程序流程将在每个命令的回调内继续。
希望对你有帮助。