正文
hystrix(6) 命令执行
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
上一节中讲到了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() {
ReplaySubject<R> subject = ReplaySubject.create();
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);
...
}
});
}
命令执行流程：
命令执行流程主要包含一下内容：
1.熔断器判断
2.各个阶段HystrixCommandExecutionHook调用。
3.各个阶段
4.发送metrics消息
执行流程：
1.执行HystrixCommandExecutionHook的onStart。
2.通过熔断器判断服务是否熔断
3.如果没有熔断
3.1如果是SEMAPHORE模式
3.1.1 判断是否到达指定并发量，如果不是进入
3.1.1.1 向metrics发送执行开始消息。
3.1.1.2执行HystrixCommandExecutionHook的onRunStart、onExecutionStart方法
3.1.1.3执行run方法，并把执行结果返回Observable。
3.1.1.4监听Observable执行结果消息，如果返回消息是success、error、emit执行HystrixCommandExecutionHook相应方法。
3.1.3 ［handleSemaphoreRejectionViaFallback］
3.2如果是THREAD模式
3.2.1 向metrics发送执行开始消息。
3.2.2 向metrics发送线程池执行开始消息。
3.2.3 执行HystrixCommandExecutionHook的onThreadStart、onRunStart、onExecutionStart方法
3.2.4 执行run方法，并把执行结果返回Observable。
3.2.5 监听Observable执行结果消息，如果返回消息是success、error、emit执行HystrixCommandExecutionHook相应方法。
3.2.6 如果线程执行过程中，发送TERMINAL，UNSUBSCRIBED，执行HystrixCommandExecutionHook的onThreadComplete方法，并向metrics发送线程池执行结束消息。
2.3如果timeout检测启动，则启动定时器判断timeout检测。
4.如果熔断［handleShortCircuitViaFallback］
命令执行状态
hystrix命令执行过程中有以下状态，hystrix命令的状态是不可逆的，每个hystrix命令只能使用一次：
1. 初始状态（NOT_STARTED）。
2.创建（OBSERVABLE_CHAIN_CREATED），toObservable开始执行后变为OBSERVABLE_CHAIN_CREATED状态
3.用户代码执行（ USER_CODE_EXECUTED），用户调用开始执行前变为USER_CODE_EXECUTED
4.UNSUBSCRIBED,
5.TERMINAL
hystrix命令执行过程中线程有一下状态：
1. 初始状态（NOT_USING_THREAD）。
2.开始（STARTED），通过线程池方式执行命令前变为STARTED。
3.UNSUBSCRIBED,
4.TERMINAL
