ter ， 处 理 本 地 事 物 逻 辑 返 回 处 理 的 事 物 状 态 LocalTransactionState 3) 二阶段，处理完本地事物中业务得到事物状态， 根据 offset 查找到 commitLog 中 的 prepared 消息，设置消息状态 commitType 或者 rollbackType ， 让后将信息添加到 commitLog 中， 其实二阶段生成了两条消息 方法向 producer 回查事物状态， 根据 group 随机选择一台 producer 查询消息，根据 commitLogOffset 和 msgSize 到 commitlog 查找消息 向 Producder 发起请求,请求 code 类型为 CHECK_TRANSACTION_STATE，producer 的 DefaultMQProducerImpl. chec rocketmq 不做处理，只存储后透传 + 8 //QUEUEOFFSET 这个值是个自增值不是真正的 consume queue 的偏移量， 可以代表这个队列中消息的个数 ，要通过这个值查找到 consume queue 中数据， QUEUEOFFSET * 20 才是偏移地址 + 8 // PHYSICALOFFSET 代表消息在 commitLog 中的物理起始地址偏移量

tBrokerId()); } } else { responseHeader.setSuggestWhichBrokerId(MixAll.MASTER_ID); } 代码@1：如果从 commitlog 文件查找消息时，发现消息堆积太多，默认超过物理内 存的 40%后，会建议从从服务器读取。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 43 > 1.4 RocketMQ HA 核心工作机制 查看历史命令，都未在指定时 间执行过该命令，并且切换到 root 命令后，同样使用 history 命令，并未发现端倪。 但我始终相信，肯定是执行了手动执行了 kill 命令导致进程退出的，经过网上查找查， 得知可以通过查阅系统日志/var/log/messages 来查看系统命令的调用，于是乎把日志文 件下载到本地，开始搜索 kill 关键字，发现如下日志： 发现最近一次 kill 命令是在 DLedger 多副本即主从切换实战 < 128 如果启动成功，则在 rocketmq-console 中看到的集群信息如下： 3. 验证消息发送与消息查找 首先我们先验证升级之前的消息是否能查询到，那我们还是查找 key 为 m600000 的消息，查找结果如图所示： 然后我们来测试一下消息发送。测试代码如下： public class Producer { public static void

。 分布式事务涉及到两阶段提交问题，在数据存储方面的方面必然需要 KV 存储的支持，因为第二阶段的提交回 滚需要修改消息状态，一定涉及到根据 Key 去查找 Message 的劢作。RocketMQ 在第二阶段绕过了根据 Key 去查找 Message 的问题，采用第一阶段収送 Prepared 消息时，拿到了消息的 Offset，第二阶段通过 Offset 去访问消息， 幵修改状态，Offset hashcode%slotNum 得到具体的槽的位置（slotNum 是一个索引文件里面包含的最大槽的数目， 例如图中所示 slotNum=5000000）。 2. 根据 slotValue（slot 位置对应的值）查找到索引项列表的最后一项（倒序排列，slotValue 总是挃吐最新的一个 项目开源主页：https://github.com/alibaba/RocketMQ 21 索引项）。 3.