java – Akka的事件总线是否保证消息顺序?

我想保留事件进入公交车的顺序.
例如,如果event1然后event2输入到总线,那么订阅的actor将按顺序获取它们.

问题是,如果这种顺序是保证的,那么无论是在集群节点还是在单节点actor系统上.

解决方法

如果您在actor系统(system.eventStream)上使用事件流,并且如果您可以保证单个线程正在发布,那么是,将保留该顺序.事件总线的子通道分类风格(与system.eventStream绑定的类型)非常简单.有一个基本类类型的Map到订阅者的列表.发布事件时,它会从Map(如果有)获取匹配的订户列表,然后将消息发送给每个订阅者.因此,如果只有一个线程正在调用publish,那么它需要完成发布event1(从而将其传递给所有订阅者的邮箱),然后再转到event2. Actors按照收到邮件的顺序处理邮箱(除非您使用自定义的PriorityMailbox impl),所以先进先出.

当然,如果你有多个线程,我不能保证这个顺序处理,因为thread1可能首先启动发布,但是线程2可能首先完成它,导致你不按顺序考虑.

相关文章

本文从从Bitcask存储模型讲起,谈轻量级KV系统设计与实现。从...
内部的放到gitlab pages的博客,需要统计PV,不蒜子不能准确...
PCM 自然界中的声音非常复杂,波形极其复杂,通常我们采用的...
本文介绍如何离线生成sst并在线加载,提供一种用rocksdb建立...
验证用户输入是否正确是我们应用程序中的常见功能。Spring提...
引入pdf2dom <dependency> <groupId&a...