我正在使用 AKKA 2.1 和 Scala 2.10。
我需要多台机器来启动参与者系统并实例化一定数量的参与者。此后,每个系统都需要访问所有其他系统并使用“actorFor(...)”收集对其参与者的引用。
但是,我需要一种方法让参与者系统在连接之前等待其他系统启动,否则我会收到错误。
如果参与者系统 A 在 B 离线时连接到 B,我的程序就会失败。然而,如果 A 连接到 B 并在 B 上存在之前获取远程 Actor 引用,则一旦 B 实际实例化该 Actor,程序就会继续正常运行。
简而言之,在尝试连接到 B 之前,我需要以某种方式等待 B 的创建事件。在Scala+AKKA中有没有好的方法可以做到这一点?
最佳答案
您可能想研究 Akka 的集群支持。当其他机器加入集群并可用于通信时,它允许您监听事件。
关于events - 等待akka actor系统可用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/14999855/