Akka演员被阻止了

Question

ActorRef myActorPool = actorSystem.actorOf(new RoundRobinPool(200).props(Props.create(MyActor.class, args)), MyActor.class.getSimpleName());

java.util.concurrent.CompletionException：Akka.Pattern.AskTimeoutException：收件人[Actor[akka:/web_server/user/MyActor#-769383443]]已终止。发送者[null]发送了类型为“com.data.model.request”的消息。

所以我重写了poststop方法，在那里添加了一个log语句。

@Override
public void postStop() {
    log.warn("Actor is stopped");
}

现在，我可以在日志中看到演员们被阻止了。但我不确定它是为了哪个请求发生的。一旦池中的所有执行元终止（200是我设置的池大小），我将得到前面所说的AskTimeoutException。是否有调试为什么演员被终止？

CompletableFuture<Object> s = ask(myActorPool, request, 1000000000).toCompletableFuture();
return s.join();

执行元只处理一种消息。

@Override
public AbstractActor.Receive createReceive() {
    return receiveBuilder()
            .match(Request.class, this::process)
            .build();
}

private void process(Request request) {
    try {
        // code here
    } catch (Exception e) {
        log.error(e.getMessage(), e);
        getSender().tell(new akka.actor.Status.Failure(e), getSelf());
    }
}

Answer 1

就您所描述的probelm而言，您似乎是在ask调用中处理数据，并且花费了比askTimeout更多的时间，因此您会得到错误。

您可以做的是增加askTimeout或在ask调用内部进行更少的处理。

您不应该在ask调用中执行CPU绑定操作，这可能会导致您的系统变慢。建议您在ask调用中执行I/O绑定操作。这样你就可以利用演员了。

val x=x+1   // CPU bound operation should not do inside the ask call