0

Java API 在这里。我试图了解 Akka 演员监督的真正运作方式，特别是监督策略。对我来说，该策略感觉就像（本质上）将异常映射到指令。

我刚刚阅读了官方的Akka Fault Tolerance 文档，但在该文档中实际上并没有明确说明何时/何地/如何触发监督策略。

所以我问：什么时候采用监督策略？当子actorThrowable从其onReceive方法中抛出一个？还是有什么不同？

4

1 回答 1

2

您是正确的，除了它在默认决策者规则中包含可抛出对象（即错误）和异常，并且它在 Actor 抛出可抛出对象时运行。根据http://doc.akka.io/docs/akka/2.0/java/fault-tolerance.html#default-supervisor-strategy，默认情况下，如果没有定义的主管策略或者它不涵盖由抛出的异常一个（用户创建的）Actor，依次执行以下规则，直到触发一个：

  1. ActorInitializationException 将停止失败的子actor
  2. ActorKilledException 将停止失败的子actor
  3. 其他异常将重新启动失败的子actor
  4. 其他类型的 Throwable 将升级为父actor

如果您还没有看过，请访问http://doc.akka.io/docs/akka/2.3.11/general/supervision.html对监督进行 ok 审查。

Derek Wyatt 在“Akka Concurrency”第 8 章中对代码级别进行了很好的讨论。它主要处理 Scala 版本，但我相信 Actor 故障处理是在 Scala 中实现的（依赖于 Java）。

查看 2.3.11 源代码，默认的 Actor 故障处理决策器位于 akka-actor_2.11-2.3.11-sources.jar\akka\actor.FaultHandling.scala 中，并且是：

/**
   * When supervisorStrategy is not specified for an actor this
 * [[Decider]] is used by default in the supervisor strategy.
 * The child will be stopped when [[akka.actor.ActorInitializationException]],
 * [[akka.actor.ActorKilledException]], or [[akka.actor.DeathPactException]] is
 * thrown. It will be restarted for other `Exception` types.
 * The error is escalated if it's a `Throwable`, i.e. `Error`.
 */
final val defaultDecider: Decider = {
  case _: ActorInitializationException ⇒ Stop
  case _: ActorKilledException         ⇒ Stop
  case _: DeathPactException           ⇒ Stop
  case _: Exception                    ⇒ Restart
}

/**
 * When supervisorStrategy is not specified for an actor this
 * is used by default. OneForOneStrategy with decider defined in
 * [[#defaultDecider]].
 */
final val defaultStrategy: SupervisorStrategy = {
  OneForOneStrategy()(defaultDecider)
}

这与文档一致 - 越来越少，因为 defaultDecider 不包含显式

case _ => Escalate // _ is the scala wildcard for anything

如果 Throwable 与 defaultDecider 不匹配，则在默认为 Escalate 的 makeDecider 函数中实现；并且文档没有提到包含 DeathPactException 的条款可能是为了减少与细节的混淆。

于 2015-06-21T11:23:37.040 回答