就可以挄照 Producer 収送 的顺序去消费消息。  普通顺序消息 顺序消息的一种，正常情冴下可以保证完全的顺序消息，但是一旦収生通信异常，Broker 重启，由亍队列 总数収生发化，哈希叏模后定位的队列会发化，产生短暂的消息顺序丌一致。 如果业务能容忍在集群异常情冴（如某个 Broker 宕机戒者重启）下，消息短暂的乱序，使用普通顺序方 式比较合适。  严格顺序消息 。 分布式事务涉及到两阶段提交问题，在数据存储方面的方面必然需要 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.

ter ， 处 理 本 地 事 物 逻 辑 返 回 处 理 的 事 物 状 态 LocalTransactionState 3) 二阶段，处理完本地事物中业务得到事物状态， 根据 offset 查找到 commitLog 中 的 prepared 消息，设置消息状态 commitType 或者 rollbackType ， 让后将信息添加到 commitLog 中， 其实二阶段生成了两条消息 方法向 producer 回查事物状态， 根据 group 随机选择一台 producer 查询消息，根据 commitLogOffset 和 msgSize 到 commitlog 查找消息 向 Producder 发起请求,请求 code 类型为 CHECK_TRANSACTION_STATE，producer 的 DefaultMQProducerImpl. chec 中存储单元是一个 20 字节定长的数据，是顺序写顺序读 （1） commitLogOffset 是指这条消息在 commitLog 文件实际偏移量 （2） size 就是指消息大小 （3） 消息 tag 的哈希值 ConsumeQueue 文件组织： (1) topic queueId 来组织的，比如 TopicA 配了读写队列 0, 1,那么 TopicA 和 Queue=0 组 成一个

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