处理完成后Akka停止/杀死演员

Question

我想知道如何有效地清理在飞行中创建的akka演员。

要提供一点背景信息：

每个事件创建的演员层次结构。

主管-

在我的应用程序中，主管参与者动态创建其他参与者（在定期事件上）。我想在该事件的处理步骤完成后清理参与者。

所以，一旦处理完成，我想杀死所有的儿童演员。

1. 我在成功完成后以与创建相反的方式传播消息（successfulProcessing）。（1）-

这是主管演员的代码。

class Supervisor extends Actor {
    def receive={
        case onEvent: OnEvent =>
            //Create child actor and send message         
        case successfulProcessing =>
            sender() ! PoisonPill
    }
    override val supervisorStrategy = AllForOneStrategy() {
        case e: Exception =>
            Stop   
    }
}

这是清理动态创建的参与者的正确方法吗。这种方法是否有任何缺点，或者是否有一种模式可以遵循？

Answer 1

我看到的模式是有一个演员管理其他演员。在本教程的以下示例中，actor1管理actor2，其中actor2完成所有工作。

case class StartCounting(n: Int, actor: ActorRef)
case class CountDown(n: Int)

class CountDownActor extends Actor {
  def receive = {
    case StartCounting(n, actor) =>
      println(n)
      actor ! CountDown(n-1)
    case CountDown(n) =>
      if(n > 0) {
        println(n)
        sender ! CountDown(n-1)
      } else {
        context.system.shutdown()
      }
  }
}

object Main extends App {
  val system = ActorSystem("HelloSystem")
  // default Actor constructor
  val actor1 = system.actorOf(Props[CountDownActor], name = "manager")
  val actor2 = system.actorOf(Props[CountDownActor], name = "worker")
  actor1 ! StartCounting(10, actor2)
}

你可以把它想象成递归：基本情况和归纳情况。您可以将此应用于正在管理其父级的所有兄弟角色。

Answer 2

根据Akka文件2.4.14，处理毒药/杀戮信息的更好方法是广播它们。

    ActorRef ! Broadcast(PoisonPill)

注意：使用Balancingpool时不要广播消息