繼承HystrixCommand實現run方法的命令只能返回單一值，Hystrix也提供了方式可以讓我返回一個Observable結果，然后持續監聽運行結果。

繼承HystrixObservableCommand

public class HelloWorldHystrixObservableCommand extends HystrixObservableCommand{private String name;protected HelloWorldHystrixObservableCommand(String group) {super(HystrixCommandGroupKey.Factory.asKey(group));this.name = group;}@Overrideprotected Observable resumeWithFallback() {return Observable.create(new Observable.OnSubscribe<String>() {public void call(Subscriber<? super String> observer) {observer.onNext("fallback:"+name);}});}protected Observable construct() {return Observable.create(new Observable.OnSubscribe<String>() {public void call(Subscriber<? super String> observer) {observer.onNext("hello world:"+name);observer.onCompleted();}});} }

construct為需要執行的命令并返回一個Observable對象，如果執行過程中發生異常，則會觸發resumeWithFallback來降級。

有兩種方法執行命令：

Observable<String> s = new HelloWorldHystrixObservableCommand("Bob").observe(); Observable<String> s = new HelloWorldHystrixObservableCommand("Bob").toObserve();

　　執行原理與HystrixCommand相同，繼承了相同的虛擬類（AbstractCommand）只是最終調用的執行方法不同。

　　HystrixObservableCommand默認使用SEMAPHORE模式執行。

?

轉載于:https://www.cnblogs.com/zhangwanhua/p/8257468.html

總結

以上是生活随笔為你收集整理的hystrix总结之多返回值命令的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。