RokectMQ

作者: SelbyYang | 来源:发表于2018-05-24 16:02 被阅读0次

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

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

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

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

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

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

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

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

    相关文章

      网友评论

          本文标题:RokectMQ

          本文链接:https://www.haomeiwen.com/subject/sadsjftx.html