Akka死亡观察-观察终止和重启

Question

我有两个演员，父母和孩子。家长使用内容监视孩子。看（孩子）。如果孩子调用上下文。停止（自我）父级收到终止消息。但是，如果子级抛出异常，akka将重新启动该异常，但不会向父级发送终止消息。

class Parent ... {
  def receive = {
    case "start" =>
      val child = ...
      context.watch(child)
      child ! "throw"
    case Terminated(actor) => logger.error(s"$actor died"")
  }
}

class Child ... {
  def receive = {
    case "stop" => context.stop(self) // parent is notified
    case "throw" => throw new Exception("oops") // parent is not notified
  }
}

家长参与者如何监视孩子并监视任何终止/重新启动？

我提出的一个选项是覆盖父级中的主管策略，以便在出现任何异常时停止：

class Parent ... {
  override val supervisorStrategy = OneForOneStrategy() {
    case _: Exception => Stop
  }
}

据我所知，这将适用于这位演员的所有孩子。理想情况下，我希望对个别孩子（演员类型）有一个不同的监督策略，所以我想使用

class Child ... {
  override def postRestart(reason: Throwable): Unit = context.stop(self) 
}

我工作，但这似乎有点像黑客。还有其他我不知道的选择吗？

非常感谢！

Answer 1

Akka演员监督策略更侧重于处理异常，并基于异常您可以决定要遵循的操作。

在您的情况下，您希望使它基于actor，如果是这种情况，不同类型的actor必须返回不同的异常。

因此，最好是根据异常类型执行操作。如果情况并非如此，并且抛出了类似的异常，那么最好将它们包装到参与者级别，然后返回到更高级别的参与者。

Answer 2

我不知道有哪种每参与者类型的监督模型，但我想到的是，您可以捕获子参与者中的异常并将其封装到信封中：

try {
  ...
} catch {
  case e: Throwable => throw new DontRestartMeException(e)
}

如果您手动抛出异常，甚至更容易，只需直接抛出包装好的异常。

然后在父级中，决定每种异常类型：

override val supervisorStrategy = OneForOneStrategy() {
    case e: DontRestartMeException => Stop
    case _: Exception => Restart
}