HTTP 服务器，幵更新本地的 Name Server 地址。 URL 已经在代码中写死，可通过修改/etc/hosts 文件来改发要访问的服务器，例如在/etc/hosts 增加如下配 置 10.232.22.67 jmenv.taobao.net 推荐使用 HTTP 静态服务器寻址方式，好处是客户端部署简单，丏 Name Server 集群可以热升级。 11.2 自定义客户端行为 Broker 重启可能会导致正在収往返台机器的的消息収送失败，RocketMQ 提供了一种优雅关闭 Broker 的方法，通过 执行以下命令会清除 Broker 的写权限，过 40s 后，所有客户端都会更新 Broker 路由信息，此时再关闭 Broker 就丌 会収生収送消息失败的情冴，因为所有消息都収往了其他 Broker。 sh mqadmin wipeWritePerm -b brokerName

topic，如果 producer 集合中没有会根据指定 topic 到 namesrv 获取 topic 发布信息 TopicPublishInfo，并放入本地集合 2. 定时从 namesrv 更新 topic 路由信息， Producer 与 broker 间的心跳 Producer 定时发送心跳将 producer 信息（其实就是 procduer 的 group）定时发送到， brokerAddrTable 分发消息位置信息到 ConsumeQueue : 事物状态为 preparedType 和 rollbackType 的消息 不会将请求分发到 ConsumeQueue 中去，即不处理， 所以不会被消息 更新 transaction stable table： 如果是 prepared 消息记，通过 TransactionStateService 服 务将消息加到存储事务状态的表格 tranStateTable 建 一 个 Runnable 任 务 异 步 执 行 producer 注 册 的 回 调 接 口 ， 处 理 回 调 ， 在 调 endTransactionOneway 向 broker 发送请求更新事物消息的最终状态 无 Prepared 消息，且遍历完，则终止扫描这个文件的定时任务 2.2.5 事物消息的 load&recover TransactionStateService

注册存储在该服务器上的路由信息，并每隔 30s 向 Nameserver 发送心跳包，并更新路由信息。 Nameserver 每隔 10s 扫描路由表，如果检测到 Broker 服务宕机，则移除对应的路 由信息。 消息生产者每隔 30s 会从 Nameserver 重新拉取 Topic 的路由信息并更新本地路由 表；在消息发送之前，如果本地路由表中不存在对应主题的路由消息时，会主动向 Nameserver 为什么不能设置为 true 备注：该 topicConfigTable 中所有的路由信息，会随着 Broker 向 Nameserver 发 送心跳包中，Nameserver 收到这些信息后，更新对应 Topic 的路由信息表。 注意：BrokerConfig 的 defaultTopicQueueNum 默认为 8。两台 Broker 服务器都 会运行上面的过程，故最终 Nameserver NameServer， 于此同时，Broker 端还会有一个定时任务，定时将内存中的路由信息，持久化到 Broker 端的磁盘上。 3. 消息发送者会每隔 30s 向 NameServer 更新路由信息，如果消息发送端一段时间内 未发送消息，就不会有消息发送集群内的第二台 Broker，那么 NameServer 中新创 建的 Topic 的路由信息只会包含 Broker-a，然后消息发送者会向

Page 1 of 18 Apache RocketMQ on Amazon Web Services 部署手册 顾明 版本：v1.0.0 最后更新时间: 2021 年 01 月 Copyright (c) 2021 by Amazon.com, Inc. or its affiliates. Page RocketMQ 集群。 架构 AMAZON CloudFormation 提供了一种创建和管理相关 AMAZON WEB SERVICES 资源的简 便方法，并通过有序 且可预测的方式进⾏资源配置和更新。本快速⼊⻔提供两种部署 选项，一种是将 Apache RocketMQ 部署到新 VPC 环境中，另一种是 部署到已有 VPC 环 境中。使用默认参数为在新 VPC 环境中 部署以下资源。如果您选择的是将此方案部署 态，点击【输 出】标签栏您将看到创建的资源细节。 步骤四：查看堆栈 您可以在 AMAZON CloudFormation 控制台的【状态】列中查看堆栈 的状态，并点击右上 方的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈状态变 为 CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及其他需要的组 件均已创建完毕。下图列出了默认设置部署完成后在

Page 1 of 21 快速部署高可用的 Apache RocketMQ 集群 部署手册 顾明 版本：v1.2.0 最后更新时间: 2023 年 11 月 Copyright (c) 2021 by Amazon.com, Inc. or its affiliates. Page 2 of 21 RocketMQ 集群。 架构 Amazon CloudFormation 提供了⼀种创建和管理相关 AMAZON WEB SERVICES 资源的简便⽅法，并通过有序 且可预测的⽅式进⾏资源配置和更新。本快速⼊⻔提供 两种部署选项，⼀种是将 Apache RocketMQ 部署到新 VPC 环境中，另⼀种是 部署 到已有 VPC 环境中。使⽤默认参数为在新 VPC 环境中 部署以下资源。如果您选择的 Page 15 of 21 步骤四：查看堆栈 您可以在 Amazon CloudFormation 控制台的【状态】列中查看 堆栈的状态，并点击右上 ⽅的刷新按钮更新状态。⼤约 15 分钟后，您可以看到堆栈 状态变为 CREATE_COMPLETE，此时堆栈创建成功。Apache RocketMQ 集群以及 其他需要的组件均已创建完毕。下图列出了默认设置部署完成后在