Akka和Ask模式。当演员突然停下来时，我能回到未来吗？

Question

我目前有使用询问模式分派请求的代码。发送的请求将生成Akka Actor，该Actor发送HTTP请求，然后返回响应。我使用Akka的断路器API来管理我调用的上游Web服务的问题。

如果断路器处于断开状态，则所有后续请求都会快速失败，这是理想的效果。但是，当actor快速失败时，它只会抛出一个CircuitBreakerOpenException，停止actor，但是在生成AskTimeoutException之前，控制不会返回发出初始请求的代码。

这是发送请求的代码

Timeout timeout = new Timeout(Duration.create(10, SECONDS));
Future<Object> future = Patterns.ask(myActor, argMessage, timeout);
Response res = (Response ) Await.result(future, timeout.duration());

这是断路器

getSender().tell(breaker.callWithSyncCircuitBreaker(new Callable<Obj>() 
                    {
                        @Override
                        public Obj call() throws Exception {
                            return fetch(message);
                        }
                    }), getSelf()
            );
getContext().stop(getSelf());

当执行这段代码时，如果电路断开，它会快速失败并引发异常，但是我想将控制权返回到处理未来的代码，而不必等待超时。

这可能吗？

Answer 1

当参与者失败并重新启动时，如果它正在处理消息，则不会自动向该发送者发送响应。如果您想向该发送者发送一条关于该特定故障的消息，那么显式捕获该异常，并用失败的结果回复该发送者，确保在以后进行任何回调之前先捕获发送者，以避免结束此可变状态。您也可以尝试在重新启动前这样做，但这不是很安全，因为如果您在actor内部使用futures，那么到那时发送方可能已经改变了。