首页 > 其他 > 详细

hystrix总结之命令执行

时间:2018-01-08 12:43:32      阅读:251      评论:0      收藏:0      [点我收藏+]

  HystrixCommand有四种执行方法:

  execute方法使用同步方式获取结果,本质是调用了queue方法获取了一个Future,然后通过该Future获取返回结果。

public R execute() {
        try {
            return queue().get();
        } catch (Exception e) {
            throw Exceptions.sneakyThrow(decomposeException(e));
        }
    }

  queue方法通过异步方式活动结果,本质是通过toObservable方法获取了一个Observable,然后通过该Observable获得一个Future

public Future<R> queue() {
      ...
        final Future<R> delegate = toObservable().toBlocking().toFuture();
     ...    
};

  observe方法通过Observable实现异步,并且该Observable无论在任何时候监听,都可以接收到所有消息。本质是使用了一个ReplaySubject监听toObservable返回的Observable,然后再返回该ReplaySubject。

public Observable<R> observe() {
       ...
        final Subscription sourceSubscription = toObservable().subscribe(subject);
       ...
        return subject.doOnUnsubscribe(new Action0() {
            @Override
            public void call() {
                sourceSubscription.unsubscribe();
            }
        });
    }

  toObservable方法Observable实现异步,在Observable被监听时执行。本质是创建一个Observable,当这个Observable被监听时,执行run命令,并返回消息。

public Observable<R> toObservable() {
       ...
        return Observable.defer(new Func0<Observable<R>>() {
            @Override
            public Observable<R> call() {
               ...
                Observable<R> hystrixObservable =
                        Observable.defer(applyHystrixSemantics)  //会调用run方法
                                .map(wrapWithAllOnNextHooks);
               ...
            }
        });
    }

 

hystrix总结之命令执行

原文:https://www.cnblogs.com/zhangwanhua/p/8242003.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!