阿卡问广播

tgr*_*tgr 5 routing scala akka

我有一个akka 2.0循环路由器.现在我需要向所有路由广播一条消息并等待所有路由的答案.我还没有找到办法.首先我有一个我传递给路由器的演员列表,但现在我需要从我的application.conf中加载它们.有没有办法等待广播的所有消息?如果我可以从conf flie获得路由数量,那也没关系.

Chr*_*rle 2

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