RocketMQ中顺序消息、重复消息、事务消息和消息存储的示例分析

这篇文章主要介绍RocketMQ中顺序消息、重复消息、事务消息和消息存储的示例分析，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！

成都创新互联网站建设公司一直秉承“诚信做人，踏实做事”的原则，不欺瞒客户，是我们最起码的底线！以服务为基础，以质量求生存，以技术求发展，成交一个客户多一个朋友！专注中小微企业官网定制，网站设计制作、网站制作，塑造企业网络形象打造互联网企业效应。

顺序消息

顾名思义，就是要保证需要按顺序消费的消息集发送到同一消息队列，同时消费消息成功后给予回执。

消息生产端发送消息的时候实现指定消息队列方法[把订单号取了做了一个取模运算再丢到 selector 中，selector 保证同一个模的都会投递到同一条 queue。

RocketMQ中顺序消息、重复消息、事务消息和消息存储的示例分析

即：相同订单号的 --> 有相同的模 --> 有相同的 queue。

重复消息

重复消息主要靠业务端实现。消费端处理消息的业务逻辑保持幂等性，保证每条消息都有唯一编号且保证消息处理成功与去重表的日志同时出现。

事务消息

事务消息，要分别在发送端和订阅端配合处理。发送端：

订阅端：业务在事务里实现消息处理，通过重试解决处理失败的消息问题，一直失败人工解决。

消息存储

RocketMQ 的消息存储是由 consume queue 和 commit log 配合完成的。

consume queue 是消息的逻辑队列，相当于字典的目录，用来指定消息在物理文件 commit log 上的位置。

根据 topic 和 queueId 来组织文件，图中TopicA有两个队列0,1，那么TopicA和QueueId=0组成一个ConsumeQueue，TopicA和QueueId=1组成另一个ConsumeQueue。

ConsumeQueue 存储：CommitLog Offset是指这条消息在 Commit Log 文件中的实际偏移量，Size 存储中消息的大小。

Message Tag HashCode 存储消息的 Tag 的哈希值：主要用于订阅时消息过滤（订阅时如果指定了 Tag，会根据 HashCode 来快速查找到订阅的消息）。

按照消费端的 GroupName 来分组重试队列，如果消费端消费失败，消息将被发往重试队列中。

按照消费端的 GroupName 来分组死信队列，如果消费端消费失败，并重试指定次数后，仍然失败，则发往死信队列。

Commit Log：消息存放的物理文件，每台 broker 上的 commit log 被本机所有的 queue 共享，不做任何区分。

以上是“RocketMQ中顺序消息、重复消息、事务消息和消息存储的示例分析”这篇文章的所有内容，感谢各位的阅读！希望分享的内容对大家有帮助，更多相关知识，欢迎关注创新互联行业资讯频道！

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容