前言 此文档是从学习 rocketmq 源码过程中的笔记中整理出来的，由于时间及能力原因，理 解有误之处还请谅解，希望对大家学习使用 rocketmq 有所帮助。 Rocketmq 是阿里基于开源思想做的一款产品，代码托管于 github 上，要想学好用好 rocketmq 请从 状态消息不被消费 发送消息 ok，执行本地事物分支， 本地事物方法需要实现 rocketmq 的回调接口 2）2） 2) LocalTransactionExecuter ， 处 理 本 地 事 物 逻 辑 返 回 处 理 的 事 物 状 态 LocalTransactionState 3) 二阶段，处理完本地事物中业务得到事物状态， 根据 offset 查找到 commitLog 中 的 prepared 三：Broker 落地消息 2.1 普通消息落地 Broker 根 据 producer 请 求 的 RequestCode.SEND_MESSAGE 选 择 对 应 的 处 理 器 SendMessageProcessor 根据请求消息内容构建消息内部结构 MessageExtBrokerInner 调 DefaultMessageStore 加消息写入 commitlog

RocketMQ的实现 • Cloud Native时代下消息系统的挑战 • Apache RocketMQ 简介 • Apache RocketMQ 存储设计 分布式事务⾯面临的挑战 分布式事务理理论 ACID 刚性事务(强⼀一致) BASE 柔性事务(最终⼀一致) CAP Atomicity Consistency Isolation Durability Consistency

权任何商业行为。 1.6 RocketMQ 一个新的消费组初次启动时从何处开始消费呢？ < 70 代码@3：CONSUME_FROM_FIRST_OFFSET(从队列最小偏移量开始消费)的处 理逻辑，下文会详细介绍。 代码@4：CONSUME_FROM_TIMESTAMP(从指定时间戳开始消费)的处理逻辑， 下文会详细介绍。 代码@5：返回最后计算的偏移量，从该偏移量出开始消费。 1 RocketMQ 消息轨迹主要包含两篇文章：设计篇与源码分析篇，本节将详细介绍 RocketMQ 消息轨迹-设计相关。 RocketMQ 消息轨迹，主要跟踪消息发送、消息消费的轨迹，即详细记录消息各个处 理环节的日志，从设计上至少需要解决如下三个核心问题：  消费轨迹数据格式  记录消息轨迹(消息日志)  消息轨迹数据存储在哪？ 一、消息轨迹数据格式 RocketMQ4.5 版本消息轨迹主要记录如下信息：