RokectMQ很好的支持了事务消息发布,保证了事件发布与业务的一致性。
支持3种消息发布方式:同步、异步、单向(可靠性相对较低)
支持事务消息发布,通过实现TransactionCheckListener监听器实现未确认消息的回查(RokectMQ的消息发送分为两个阶段:Prepare和Commit)。
支持定时消息,但仅只支持几种时间间隔类型,不支持具体时间,通过在发送消息时设置Message的Delay Time Level实现。
支持批量消息发送,但有限制条件,必须是相同的Topic和相同的waitStoreMsgOK设置,不支持定时消息,同时批量发送的消息总大小需小于 1 MiB。适用于消息体小的消息。
支持2种消费方式:顺序消费、并发消费。分别通过MessageListenerOrderly和MessageListenerConcurrently监听器实现。
支持2种消费模式:Push推、Pull拉。
支持消费端的消息过滤,可通过Tag过滤,也可通过设置其他自定义Property(发送时设置,消费时通过MessageSelector过滤)来过滤。
网友评论