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

    RokectMQ很好的支持了事务消息发布,保证了事件发布与业务的一致性。 支持3种消息发布方式:同步、异步、单向(...

  • linux 下搭建rokectMQ集群

    官网地址:https://github.com/alibaba/RocketMQ/releases/tag/v3....

  • rokectMq 消息发送超长的问题

    最近公司项目使用了 Apache rokectMq 进行消息发送,本人也是第一次接触mq。 领导说要处理下mq消息...

网友评论

      本文标题:RokectMQ

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