我有一个Akka2.0循环路由器。现在我需要广播一个消息给所有的路由,并等待他们所有的答案。我还没有找到这样做的方法。首先,我有一个传递给路由器的参与者列表,但现在我需要从application.conf加载它们。有办法等待广播的所有信息吗?如果我能从会议上得到路由的数目,也会很好。
如果您知道路由的数量,那么您通常只需要计算收到的答案的数量。但是,您可能需要考虑超时,特别是如果您的参与者是分布式运行的,因为无法保证消息确实得到传递。
我尝试了一个带有MongoDb支持的akka-persistence的“Hello-World”示例,使用这个开源https://github.com/scullxbones/akka-persistence-mongo/tree/master/rxmongo/src。下面是我的代码。但是,当我运行应用程序时,我得到了ask Timeout: Akka.Pattern.AskTimeoutExce
A处理请求的方式是使用嵌套映射 这是可行的(也就是说,只有当actor C完成处理时才会进行最终处理),但不用说,它看起来很可怕。我试过使用平面地图,但不能使它工作。有什么好点子吗?)谢谢
我正致力于将一个单节点akka actor系统应用程序改为akka集群。一个变化是将一种有状态的参与者(在运行时可以有很多)变成集群分片托管实体。现在它在多个节点上运行良好。 我面临的一个问题是如何查询(获取全部)在集群中划分区域所创建的实体。以前在单节点模式下,它使用actor system ActorSelection进行actor路径匹配以获得匹配的actor列表,这在集群分片中不再起作用。