我有一个 ActorSystem，它的 eventStream 有几个订阅者。应用程序每秒可能产生数千条消息，其中一些消息比其他消息更重要。所以他们应该首先被处理。
我发现每个 ActorSystem 都附加了一个 eventStream，因此我似乎需要用两个（或更多）ActorSystems 注册同一个 Actor 类，以便在专用 eventStream 中接收重要消息。
这是首选方法，还是此任务有一些技巧？分类器是否也可以以某种方式调整消息优先级？
问问题
650 次
1 回答
2
EventStream 不是保存事件的数据结构，它只是将事件路由到订阅者，因此您应该使用 PriorityMailbox 作为侦听器参与者，有关如何使用优先级邮箱的文档，请参阅：http: //doc.akka.io/docs/akka/ 2.0.3/scala/dispatchers.html#Mailboxes
于 2012-08-29T22:01:27.397 回答