scala - 阿卡问广播

Question

我有一个 akka 2.0 循环路由器。现在我需要向所有路由广播消息并等待所有人的答案。我还没有找到这样做的方法。首先，我有一个传递给路由器的演员列表，但现在我需要从我的 application.conf 加载它们。有没有办法等待广播的所有消息？如果我能从 conf 文件中获得路由的数量，那也很好。

Answer 1

如果您知道路由的数量，那么您通常只会计算收到的答案数量。但是，您可能需要考虑超时，特别是如果您的演员正在分布式运行，因为无法保证消息真的被传递。