分布式事务涉及到两阶段提交问题，在数据存储方面的方面必然需要 KV 存储的支持，因为第二阶段的提交回 滚需要修改消息状态，一定涉及到根据 Key 去查找 Message 的劢作。RocketMQ 在第二阶段绕过了根据 Key 去查找 Message 的问题，采用第一阶段収送 Prepared 消息时，拿到了消息的 Offset，第二阶段通过 Offset 去访问消息， 幵修改状态，Offset 就是数据的地址。 因此返里存在两次冲突的情冴；第一种，key 的 hash 值丌同但模数相同，此时查询的时候会在比较一次 key 的 hash 值（每个索引项保存了 key 的 hash 值），过滤掉 hash 值丌相等的项。第二种，hash 值相等但 key 丌等， 出亍性能的考虑冲突的检测放到客户端处理（key 的原始值是存储在消息文件中的，避免对数据文件的解析）， 客户端比较一次消息体的 key 是否相同。 5 Consumer1 Consumer2 7-6 订阅消息 Rebalance 如图所示，如果有 5 个队列，2 个 consumer，那举第一个 Consumer 消费 3 个队列，第二 consumer 消费 2 个队列。 返样即可达到平均消费的目的，可以水平扩展 Consumer 来提高消费能力。但是 Consumer 数量要小亍等亍队列数 量，如果 Consumer 超过队列数量，那举多余的

温馨提示：本文不会详细跟踪整个整个源码创建过程，只会点出代码的关键入口点，如 想详细了解 NameServer 路由消息、消息发送高可用的实现原理，建议查阅笔者的书籍《 RocketMQ 技术内幕》第二、三章。 Step1：在 Broker 启动流程中，会构建 TopicConfigManager 对象，其构造方法中 首先会判断是否开启了允许自动创建主题，如果启用了自动创建主题，则向 topicConfigT 端还会有一个定时任务，定时将内存中的路由信息，持久化到 Broker 端的磁盘上。 3. 消息发送者会每隔 30s 向 NameServer 更新路由信息，如果消息发送端一段时间内 未发送消息，就不会有消息发送集群内的第二台 Broker，那么 NameServer 中新创 建的 Topic 的路由信息只会包含 Broker-a，然后消息发送者会向 NameServer 拉取 最新的路由信息，此时就会消息发送者原本缓存了 马更新了，从 服务器此时只需定时同步主服务器的消息消费进度即可。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 47 > 1.4 RocketMQ HA 核心工作机制 第二种是，消息消费者在向主服务器拉取消息时，如果是是主服务器，在处理消息拉取 时，也会更新消息消费进度。 主服务器消息拉取时更新消息消费进度 主服务器在处理消息拉取命令时，会触发消息消费进度的更新，其代码入口为：

............................................................................................. 12 第二章 consumer ........................................................................................ 分钟）将状态为 prepared 事物回查 producer 端 redolog 这个队列其实标记消费到哪了， 事物状态的恢复根本上是有 commitlog 来做的 第二章 consumer 有别于其他消息中间件由 broker 做负载均衡并主动向 consumer 投递消息，RocketMq 是基于 拉模式拉取消息，consumer 做负载均衡并通过长轮询向 broker