java - 当没有定义缓存时，HystrixCommand肯定执行 `run`还是 `fallback`

Question

我需要同步等待HystrixCommand的一些逻辑完成，所以我添加了一个CountDownLatch并在run和fallback中释放它。

public class AsyncHystrixCommand extends HystrixCommand implements SofaHystrixInvokable {

    @Override
    protected Object run() throws Exception {
        // part1 sync
        this.syncCall();
        lock.countDown();
        // part2 async
        return this.asyncCall();
    }

    @Override
    protected Object getFallback() {
        if (lock.getCount() > 0) {
            lock.countDown();
        }
    }
}

然后主线程将通过lock.wait阻塞，但是如果run或fallback没有执行，这将永远等待。

在 flowchart of Hystrix ，如果没有定义cache，Hystrix能否保证run或fallback会被执行？还有更好的办法吗？

Answer 1

HystrixCommand 使用 RxJava 1.x 异步工作，但支持同步执行。

您所需要做的只是使用如下命令调用 execute() 方法。

Object result = new YourHystrixCommand().execute()`

或者，如果使用 queue() 或 observe()，您可以自己使用 Future 或 Observable 等待。