中消息偏移量。Prepared 状态消息不被消费 发送消息 ok，执行本地事物分支， 本地事物方法需要实现 rocketmq 的回调接口 2）2） 2) LocalTransactionExecuter ， 处 理 本 地 事 物 逻 辑 返 回 处 理 的 事 物 状 态 LocalTransactionState 3) 二阶段，处理完本地事物中业务得到事物状态， 根据 offset 查找到 查找到 commitLog 中 的 prepared 消息，设置消息状态 commitType 或者 rollbackType ， 让后将信息添加到 commitLog 中， 其实二阶段生成了两条消息 事物消息发送 三：Broker 落地消息 2.1 普通消息落地 Broker 位开始的八位记录是的消息在逻辑队列 中的 queueoffset， 但是针对事物消息为 preparedType 和 rollbackType 的存储的是事物状态 表的索引偏移量 2.2.2 分发事物消息： 分发消息位置信息到 ConsumeQueue : 事物状态为 preparedType 和 rollbackType 的消息 不会将请求分发到 ConsumeQueue 中去，即不处理， 所以不会被消息

虽然丌能严格保证丌重复，但是正常情冴下很少会出现重复収送、消 费情冴，只有网络异常，Consumer 启停等异常情冴下会出现消息重复。 此问题的本质原因是网络调用存在丌确定性，即既丌成功也丌失败的第三种状态，所以才产生了消息重复性问 题。 4.10 Broker 的 Buffer 满了怎么办？ Broker 的 Buffer 通常挃的是 Broker 中一个队列的内存 Buffer 大小，返类 然需要 KV 存储的支持，因为第二阶段的提交回 滚需要修改消息状态，一定涉及到根据 Key 去查找 Message 的劢作。RocketMQ 在第二阶段绕过了根据 Key 去查找 Message 的问题，采用第一阶段収送 Prepared 消息时，拿到了消息的 Offset，第二阶段通过 Offset 去访问消息， 幵修改状态，Offset 就是数据的地址。 RocketMQ 返种实现事务方式，没有通过 Broker Slave2 Producer集群 Consumer集群 图表 5-2RocketMQ 网络部署图 RocketMQ 网络部署特点  Name Server 是一个几乎无状态节点，可集群部署，节点乀间无任何信息同步。  Broker 部署相对复杂，Broker 分为 Master 不 Slave，一个 Master 可以对应多个 Slave，但是一个 Slave

IaaS 基础设施支持，降低成本 轻量级SDK： • 全面支持云原生通信标准 gRPC 协议 • 无状态 Pop 消费模式，多语言友好，易集成 从业务走向数据： • 事件流场景支撑 • 面向 SQL 的轻量级实时计算引擎 可分可合的存储计算分离： • Broker 升级为真正的无状态服务节点，无 binding • Broker和Store节点分离部署、独立扩缩 • 可分可合，适应多种业务场景，降低运维负担 消息体小且存储结构面向单 条消息，导致提升吞吐困难 • 在进行状态存储时，无 KV 语义支撑 挑战 • Commitlog 格式存储， 统一复制算法 • 不借助外部依赖，提供 状态存储能力 • 单一数据文件，支持面向流的索引及面向 批的索引 • 批量发，批量存，批量读，吞吐提升十倍 • 统一消息，KV 语义，统一 API，提供 状态存储能力 • 流表二象性支持 W r i t e

等待约 15 分钟，堆栈创建完成后您可以看到父堆栈和嵌套堆栈的创建状态，点击【输 出】标签栏您将看到创建的资源细节。 步骤四：查看堆栈 您可以在 AMAZON CloudFormation 控制台的【状态】列中查看堆栈 的状态，并点击右上 方的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈状态变 为 CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ

分钟，堆栈创建完成后您可以看到父堆栈和嵌套堆栈的创建状态，点击【输 出】标签栏您将看到创建的资源细节。 Page 15 of 21 步骤四：查看堆栈 您可以在 Amazon CloudFormation 控制台的【状态】列中查看 堆栈的状态，并点击右上 ⽅的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈 状态变为 CREATE_COMPLETE，此时堆栈创建成功。Apache

命令，逐一查看文件大小不为０的文件，从而寻找错误日志，便于快速解决 问题。 RocketMQ 提供了众多的运维命令来查看 RocketMQ 集群的运行状态，在这里我先 简单使用 clusterList 命令来查看集群的状态，用于验证一下集群的状态。 sh ./mqadmin clusterList -n 127.0.0.1:9876 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 的切换代码，其代码片段如下图所示： 上图中的几个关键分析如下：  客户端能通过缓存中的连接发送 RPC 请求的前提条件是 channel 的 isActive 方法返 回 true，即底层 TCP 连接处于激活状态。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 113 > 1.11 从年末生产故障解锁 RocketMQ 集群部署的最佳实践  在客户端向服务端发起 RPC 请求时，如出现非超时类异常，会执行 请求时，如出现非超时类异常，会执行 closeChannel 方法，该方法会关闭连接并从连接缓存表中移除，这个非常关键，因为在切换 Name Server 时如果缓存中存在连接并连接处于激活状态，就不会切换 nameserver。  如果发送 RPC 超时，rocketmq 会根据 clientCloseSocketIfTimeout 参数来决定是 否关闭连接，但遗憾的是该参数默认为 false，并且并未提供修改的入口。

Apache RocketMQ 简介 • Apache RocketMQ 存储设计 存储⽂文件 - - - - - 1G - - - - - 6M - - - - - 400M 配置和状态相关 消息存储和检索相关 存储设计 producer message(topic, queueId, tags, keys, msgBody) commitlog 8 bytes | SAGA 特点： 1. 提交+补偿 2. 并发隔离性很难保证 分布式事务解决⽅方案 TCC 特点： 1. 特殊的两阶段提交 2. Try阶段检查/锁定资源 没有真正提交 3. 增加了了⼀一个状态处理理，开发变复杂 4. CC需要幂等，能够⽀支持重试 5. 如果CC重试不不成功/超时，需要⼿手⼯工⼲干预 Apache RocketMQ 消息事务 Send a message first

properties >> /Users/gitsilence/JavaTools/rocketmq/logs/broker/slave-broker-b.log & 启动完成后可以使用mqadmin检查 集群状态 /Users/gitsilence/JavaTools/rocketmq/rocketmq-4.9.2-SNAPSHOT/bin/mqadmin clusterList -n "192.168.166