Akka 的事件总线是否保证消息顺序？

Question

我想保持事件进入总线的顺序。 例如，如果 event1 然后 event2 进入总线，那么订阅的 Actor 将按该顺序获取它们。

问题是这样的顺序是否可以保证，无论是在集群还是在单节点参与者系统上。

Answer 1

如果您在 Actor 系统 (system.eventStream) 上使用事件流，并且如果您可以保证单个线程正在发布，那么可以，将保留顺序。事件总线的子通道分类风格（与system.eventStream 绑定的那种）非常简单。订阅演员列表中有一个基本上是类类型的Map。当一个事件发布时，它会从Map（如果有的话）获取匹配的订阅者列表，然后将消息发送给每个订阅者。因此，如果只有一个线程在调用publish，那么它需要完成 event1 的发布（并因此将其发送到所有订阅者的邮箱），然后才能继续进行 event2。 Actor 按照收到消息的顺序处理他们的邮箱（除非您使用自定义的PriorityMailbox impl），所以先进先出。

当然，如果您有多个线程，我不能保证按顺序处理，因为线程 1 可能首先开始发布，但线程 2 可能首先完成它，导致您认为出现乱序。