核心概念扫盲篇 10 1.2 生产环境中，autoCreateTopicEnable 为什么不能设置为 true 18 1.3 实战：RocketMQ 学习环境搭建指南篇 28 1.4 RocketMQ HA 核心工作机制 39 1.5 踩坑记：rocketmq-console 消费 TPS 为 0，但消息积压数却在降低是个什么 “鬼” 49 1.6 RocketMQ 一个新的消费组初次启动时从何处开始消费呢？ 一端代码时，使用 DEBUG,借助运行时的一些数据，使之更容易理解。 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 39 > 1.4 RocketMQ HA 核心工作机制 1.4 RocketMQ HA 核心工作机制 温馨提示：建议参考代码 RocketMQ4.4 版本，4.5 版本引入了多副本机制，实现了 主从自动切换，本文并不关心主从切换功能。 一、初识主从同步 commitlog 文件中最大的偏移量，以该偏移量向服务端拉取消息；  服务端解析请求，并返回一批数据给客户端； 本文来自『中间件兴趣圈』公众号，仅作技术交流，未授权任何商业行为。 1.4 RocketMQ HA 核心工作机制 < 40  客户端收到一批消息后，将消息写入本地 commitlog 文件中，然后向 Master 汇报拉 取进度，并更新下一次待拉取偏移量；  然后重复第 3 步； RocketMQ

............................................................................................ 35 四：HA & master slave ................................................................................... .......................................................................................... 39 4.3 HA 异步复制 ............................................................................................. slave 落后 master 没有同步的 bytes 如果 broker 是 slave，启动任务定时到 mastser 同步配置信息 四：HA & master slave 在 broker 启动的时候 BrokerController 如果是 slave， 配置了 master 地址更新，没有配置所 有 broker 会想 namesrv

....................................................................................... 25 7.13 HA，同步双写/异步复制 ........................................................................................ 的消息在一个滑劢窗口区间，可以有多个线程幵行消 费，但是每次提交的 Offset 都是最小 Offset，例如 3 7.11 发送定时消息 7.12 消息消费失败，定时重试 7.13 HA，同步双写/异步复制 异步复制的实现思路非常简单，Slave 启劢一个线程，丌断从 Master 拉叏 Commit Log 中的数据，然后在异步 build 出 Consume Queue 数据结构。整个实现过程基本同 ve/broker-b.properties & 3. 多 Master 多 Slave 模式，异步复制 每个 Master 配置一个 Slave，有多对 Master-Slave，HA 采用异步复制方式，主备有短暂消息延迟，毫秒级。 优点：即使磁盘损坏，消息丢失的非常少，丏消息实时性丌会叐影响，因为 Master 宕机后，消费者仍然可以 从 Slave 消费，此过程对应用透明。丌需要人工干预。性能同多

Seagate(希捷) Time for recovery(Hours) 2, 1TB Disk, 75% capacity water level, 100MB/S Cluster Scale HA Replica Nums Reliability 1M ❌ 1 99.27% 2M ❌ 1 99.27% 1M1S ✅ 2 99.9999976% 2M2S ✅ 2 99.9999976%

Seagate(希捷) Time for recovery(Hours) 2, 1TB Disk, 75% capacity water level, 100MB/S Cluster Scale HA Replica Nums Reliability 1M ❌ 1 99.27% 2M ❌ 1 99.27% 1M1S ✅ 2 99.9999976% 2M2S ✅ 2 99.9999976%

a M i d d l e w a r e G r o u p © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p HA © 2 0 1 7 A l i b a b a M i d d l e w a r e G r o u p Message Tracing Dashboard © 2 0 1 7

test case(add dependencies rocketmq-client), send async/sync/ 1way mode, consume message - Broadcast with consumer set to broadcast mode, register message listener and consume messge concurrently - Schedule

OpenMessaging Ens re strict ordering of messages,and can scale out gracefully Supported Supported, w th sync mode to avoid message loss Supported Supported, property filter expressi ns based on SQL92 Supported High