java - Akka actor 不能给自己发送 PoisonPill

Question

这里是 Java/Akka。我有以下 Actor :

public class MyActor extends AbstractActor {
    private Logger log = LoggerFactory.getLogger(this.getClass());

    public MyActor() {
        super();
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
            .match(Init.class, init -> {
                log.info("Sending myself a Poison Pill...");
                self().tell(PoisonPill.getInstance(), self());
            }).match(PoisonPill.class, poisonPill -> {
                log.info("Got the Poison Pill...");
                context().system().terminate();
            }).build();
    }
}

当它收到 Init 消息时，我看到写了以下日志语句:

Sending myself a Poison Pill...

但我从未看到:

Got the Poison Pill...

此外，该应用程序只是坐在那里，并没有按预期关闭。在我使用 self().tell(PoisonPill.getInstance(), self()) 时是否有什么东西阻止它接收消息并关闭？

Answer 1

日志消息没有出现，因为 PoisonPill是一个 AutoReceivedMessage . AutoReceivedMessage 是 Akka 内部处理的一种特殊类型的消息，并不意味着在用户代码中进行模式匹配。

一旦 actor“中毒”/停止，关闭 actor 系统的一种方法是覆盖 actor 的 postStop() 方法:

@Override
public Receive createReceive() {
  return receiveBuilder()
    .match(Init.class, init -> {
      log.info("Sending myself a Poison Pill...");
      self().tell(PoisonPill.getInstance(), ActorRef.noSender());
    })
    .build();
}

@Override
public void postStop() {
  getContext().getSystem().terminate();
}