Akka 主管 管理主管

Question

我认为这里可能隐藏着一个使用 Akka 进行应用程序设计的更广泛的问题，但我会问如何建立一棵监督树，其中“内核”或“顶级”监督者可能会监督其他监督者（监督工作人员）的子级？

Answer 1

您可以从顶层的声明性主管开始，

 val kernel = Supervisor(
     SupervisorConfig(
         OneForOneStrategy(List(classOf[Exception]), 3, 1000),
         Supervise(
             actorOf[Module1],
             Permanent) ::
         Supervise(
             actorOf[Module2],
             Permanent) ::
         Supervise(
             actorOf[Module3],
             Permanent) ::
         Nil
     )
 )

其中模块 1 到 3 代表应用程序架构的下一个级别。每个模块本身都是其所有子参与者的主管，并像示例一样实现

class Module1 extends Actor {
   self.faultHandler = OneForOneStrategy(List(classOf[Throwable]), 5, 5000)

   def receive = {
       case Register(actor) =>
       self.link(actor)
   }
}

您可以将“注册（参与者）”消息替换为更适合您的应用程序的内容，并且您可能希望跨越进一步以编程方式创建的主管层，但基本上这将是应遵循的方法。

您可以在 Scala 容错 或 容错使用 Java。