SpringCloud-Hystrix原理 (6)

当Hystrix命令执行成功之后,它会将处理结果直接返回或是以Observable的形式返回,具体取决于第2步中命令的执行方式,下图是官网中对于这四种调用方式之间的依赖关系。

f9599774946eb12eea83f5b6440edd4cca186ba6

toObservable():返回最原始的Observable, 必须通过订阅它才会真正触发命令的执行流程。

observe():在toObservable()产生原始Observable 之后立即订阅它,让命令能够马上开始异步执行,并返回一个Observable对象,当调用它的subscribe时,将重新产生结果和通知给订阅者。

queue():将toObservable()产生的原始Observable通过toBlocking() 方法转换成BlockingObservable对象,并调用它的toFuture()方法 返回异步的Future对象。

execute():在queue()产生异步结果Future对象之后,通过调用get()方法 阻塞并等待结果的返回。

 

三 配置信息

请参考Configuration,有详细的介绍。

四 参考文档

1 书籍

《Spring Cloud微服务实战》

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpdywy.html