java - 如何从 Akka 路由器中删除失效的 actor？

Question

在我的应用程序中，我有一个服务器节点和多个工作节点，每个节点有一个参与者。每个参与者将初始消息发送到服务器，服务器将其添加到路由器。但是当客户端死掉时(例如程序被杀死)，路由器中的routee数量保持不变。

如何清除路由器上死去的 Actor ？

Answer 1

Akka 有一些可以重写的生命周期方法。例如，在 preStart 方法中，您可以将 Actor 注册到路由器，在 postStop 方法中，您可以将其删除。

override def preStart() {
  router ! AddMe
}

override def postStop() {
  router ! RemoveMe
}

Akka 很好 documentation关于 Actor 的生命周期。