Akka参与者，等待完成初始化问题

Question

我的应用程序使用一个主管akka actor，在内部初始化其他参与者（child）。然而，由于它是异步进行的，所以我在尝试使用Akka TestKit编写测试时遇到了问题。

例如，当试图测试一个系统是如何从另一个系统终止通过发送消息到一个子演员的主管，我创建一个新的演员系统，然后与actorOf一个主管，它接收一个配置（用于在里面创建子演员主管），像这样：

val anotherSystem: ActorSystem = ActorSystem("anotherSystem")

anotherSystem.actorOf(Props(classOf[Supervisor], new ConfigurationFromStatic(configsAnother), metrics), "AnotherSupervisor")

然后，如果我尝试使用actorSelection向另一个主管中的子参与者发送消息，则会失败，因为该子参与者尚未可选择：

anotherSystem.actorSelection("/user/AnotherSupervisor/AnotherManagementReceiver") ! message
expectMsg(Ack)

失败，因为还没有创建ANTHERManagementRecector。

使用Thread.sleep（5000）工作，但这太糟糕了。

在寻找可能的解决方案后，我测试了：

anotherSystem.actorSelection("/user/AnotherSupervisor/AnotherManagementReceiver").resolveOne() ! message

对现有参与者消息也失败。

还尝试了EventFilter以获得儿童演员在日志中的回声：

EventFilter.info("Management consumer started", occurrences = 1) intercept {
   anotherSystem.actorOf(Props(classOf[Supervisor], new ConfigurationFromStatic(configsAnother), metrics), "AnotherSupervisor")
}

这会一直等到超时（我甚至看到日志消息），但我猜EventFilter只从TestKit创建的“主”参与者系统中读取。

关于如何应对这种情况，有什么想法或建议吗？




Answer 1

一种更可靠、更一致的方法是让已知的参与者将您介绍给更多的参与者：在这种情况下，主管是开始沟通的入口点。您可以通过此参与者转发所有消息，也可以为子参与者添加查找协议，其他人可以在其中向主管询问他们的ActorRefs。

ActorSelection仅用于远程节点之间的初始通信，以获得第一个ActorRef。从那以后，只使用如上所述的消息要好得多。