5%E5%BF%97%EF%BC %88jbd2%EF%BC%89bug/ 6.3 数据存储结构 Producer Consumer topic、queueId、message Commit Log 消费队列服务 （存储消息在CommitLog中的Offset 信息） Offset、Size、TagsCode 消息索引服务 （存储消息Key与消息在CommitLog 中的Offset对应关系） topic、queueId、message Commit Log Consume Queue存储消息在Commit Log中的位置信息 CommitLog Offset Size 8 Byte 4 Byte Message Tag Hashcode 8 Byte 图表 7-1RocketMQ 队列 (1). 所有数据单独存储到一个 Commit Log，完全顺序写，随机读。 (2) (2). 对最终用户展现的队列实际只存储消息在 Commit Log 的位置信息，幵丏串行方式刷盘。 项目开源主页：https://github.com/alibaba/RocketMQ 17 返样做的好处如下： (1). 队列轻量化，单个队列数据量非常少。 (2). 对磁盘的访问串行化，避免磁盘竟争，丌会因为队列增加导致 IOWAIT 增高。 每个方案都有缺点，它的缺点如下：

Half Topic: prepare message TransactionMessageCheckService Check Operation Topic: commit/rollback message Broker Producer with PID Broker到Producer的回查通信 Netty Remoting Server Netty Remoting TxAgent 1 2 machine/JVM 1 machine/JVM 2 Commit Service Rollback Service Timeout Service TxCoordinator 3 store TxQue Master Broker TxEvent Commit/Rollback Global Transaction ID Branch Transaction 3 TxMessageProcessor begin begin begin begin TxBranch1 commit/rollback commit/rollback TxBranch1 commit/rollback TxBranch1 commit/rollback ⼀一站式，轻量量级 • 事务消息的演进与Apache RocketMQ的实现 • Cloud Native时代下消息系统的挑战

Log 删除事物状态表 tranStateTable 通过 RedoLog 全量恢复 StateTable 重头扫描 RedoLog， 过滤出所有 prepared 状态的消息， 将 commit 或者 rollback 的消息对应的 prepared 消息删除 重建 StateTable, 将上面过滤出的 prepared 消息，添加到事物状态表文件中 这个事物状态表 申请锁队列成功后设置 true， 只有被锁定 的 processqueue 才能被执行消费 rollback: 将消费在 msgTreeMapTemp 中的消息，放回 msgTreeMap 重新消费 commit: 将临时表 msgTreeMapTemp 数据清空，代表消费完成，放回最大偏移 值 (3) 这里是个 TreeMap，对 key 即消息的 offset 进行排序，这个样可以使得消息进 行顺序消费 中 msgTreeMapTemp， 这个临时 map 用来回滚消息和 commit 消 息来实现事物消费 调回调接口消费消息，返回状态对象 ConsumeOrderlyStatus 根据消费状态，处理结果 1） 非事物方式，自动提交 消息消息状态为 success： 调用 processQueue.commit 方法 获取 msgTreeMapTemp 的最后一个 key，表示提交的

actions. Merit does not buy you authority (community must still agree). Merit gets you privileges: commit access, voting on committers. Open Development - For Everything Asynchronous communication is

ocketmq4.5_simple/store storePathCommitLog=E:/SH2019/tmp/rocketmq_home/rocketmq4.5_simple/store/commit log namesrvAddr=127.0.0.1:9876 autoCreateTopicEnable=false 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 消息体的长度。  costTime 耗时。  msgType 消息的类型，可选值：Normal_Msg(普通消息),Trans_Msg_Half(预提交消息), Trans_msg_Commit(提交消息),Delay_Msg(延迟消息)。  offsetMsgId 消息偏移量 ID,该 ID 中包含了 broker 的 ip 以及偏移量。  success 是发送成功。