RokectMQ

RokectMQ很好的支持了事务消息发布,保证了事件发布与业务的一致性。

支持3种消息发布方式:同步、异步、单向(可靠性相对较低)

支持事务消息发布,通过实现TransactionCheckListener监听器实现未确认消息的回查(RokectMQ的消息发送分为两个阶段:Prepare和Commit)。

支持定时消息,但仅只支持几种时间间隔类型,不支持具体时间,通过在发送消息时设置Message的Delay Time Level实现。

支持批量消息发送,但有限制条件,必须是相同的Topic和相同的waitStoreMsgOK设置,不支持定时消息,同时批量发送的消息总大小需小于 1 MiB。适用于消息体小的消息。

支持2种消费方式:顺序消费、并发消费。分别通过MessageListenerOrderly和MessageListenerConcurrently监听器实现。

支持2种消费模式:Push推、Pull拉。

支持消费端的消息过滤,可通过Tag过滤,也可通过设置其他自定义Property(发送时设置,消费时通过MessageSelector过滤)来过滤。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

友情链接更多精彩内容