当失败时，谁的责任是创造Akka演员的孩子？

Question

重新启动期间的精确事件顺序如下：挂起actor（这意味着它在恢复之前不会处理正常消息），并递归挂起所有子节点。

一个误导性的引用说：

恢复一个行动者将恢复它的所有从属，重新启动一个行动者意味着重新启动它的所有从属，同样地，终止一个行动者也将终止它的所有从属

  test("restart test") {
    val system = ActorSystem("test")
    val supervisor = system.actorOf(Props(new Supervisor), "supervisor")
    supervisor ! CREATE(Props(new First), "first")
    Thread.sleep(500)

    val first = system.actorFor("akka://test/user/supervisor/first")
    first ! CREATE(Props(new Second), "second")
    Thread.sleep(500)
    supervisor ! WTF

    Thread.sleep(20000)
  }

  case object WTF
  case class CREATE(p: Props, name: String)

  class Supervisor extends Actor {
    override val supervisorStrategy =
      OneForOneStrategy(maxNrOfRetries = 10) {
        case _: IllegalStateException       => Restart
        case _: IllegalArgumentException    => Stop
        case _: Exception                   => Restart
    }
    override def preStart() {
      println(s"$self starts")
    }
    override def postStop() {
      println(s"$self stopped")
    }
    override def receive = {
      case WTF => println("throwing exception"); throw new IllegalStateException()
      case CREATE(p, name) => context.actorOf(p, name)
    }
  }
  class First extends Actor {
    override def preStart() {
      println(s"$self starts")
    }
    override def postStop() {
      println(s"$self stopped")
    }
    override def receive = {
      case WTF => println("throwing exception"); throw new IllegalStateException()
      case CREATE(p, name) => context.actorOf(p, name)
    }
  }
  class Second extends Actor {
    override def preStart() {
      println(s"$self starts")
    }
    override def postStop() {
      println(s"$self stopped")
    }
    override def receive = {
      case WTF => println("throwing exception"); throw new IllegalStateException()
      case CREATE => sender ! "ok"
    }
  }

参与者[Akka://test/user/supervisor#1599926629]启动参与者[Akka://test/user/supervisor/first#2012011668]启动参与者[Akka://test/user/supervisor/first/second#1750038710]启动

抛出异常参与者[Akka://test/user/supervisor#1599926629]停止[ERROR][06/26/2013 11:11:16.899][test-akka.actor.default-dispatcher-4][Akka://test/user/supervisor]null java.lang.IllegalStateException at com.fg.mail.smtp.integrationSuite$supervisor$$anonfun$Receive$1.ApplyRelse（integrationsuite.scala:40)at box.scala:237)在akka.dispatch.mailbox.run（mailbox.scala:219)在akka.dispatch.forkJoinExecutorConfigurator$AkkaForkJoinAsk.exec（AbstractDispatcher.scala:386)在scala.concurrent.forkJoinAsk.doexec（forkJoinAsk.java:262)在scala.concurrent.forkJoinAsk.forkJoinAsk.doexec（forkJoinAsk.java:262)在运行(ForkJoinWorkerThread.java:104)

参与者[Akka://test/user/supervisor/first/second#1750038710]停止参与者[Akka://test/user/supervisor/first#2012011668]停止参与者[Akka://test/user/supervisor#1599926629]开始

Answer 1

你的怀疑是正确的。如果仔细查看http://doc.akka.io/docs/akka/snapshot/general/supervision.html上关于重新启动过程的7个步骤描述，您将看到：

2...默认将终止请求发送给所有孩子...

和