RocketMQ多主多从集群部署实战：Docker Compose高可用架构详解

1. 为什么非得搞“多主多从”——从单点故障说到消息堆积的现实压力RocketMQ不是装上就能高枕无忧的中间件。我最早在某电商模拟项目X里用单NameServer加单Broker跑订单通知测试环境风平浪静一上预发就崩了两次一次是Broker进程被OOM Killer干掉订单状态同步延迟超40秒另一次更绝——NameServer容器因磁盘IO打满触发健康检查失败K8s直接把它踢出Service Endpoints整个集群瞬间“失联”下游消费方集体报No route info of this topic。那会儿我才真正明白RocketMQ的“高可用”不是配置里写个replicas: 3就自动生效的它是一整套拓扑设计、角色协同和故障转移机制的落地结果。而“多主多从”这个架构正是为解决两个核心痛点而生的一是Broker单点失效导致消息写入中断二是单主Broker无法线性扩展吞吐面对大促流量洪峰时消息积压雪崩。注意“多主”指多个Broker都具备写入能力即每个Broker都是Master而“多从”指每个Master都有至少一个Slave节点实时同步数据——这和Kafka的“分区副本”逻辑不同RocketMQ的主从是按Broker实例维度复制的Topic和Queue的分布策略也由此决定。很多人误以为“只要docker-compose.yml里写上replicas: 3再配个depends_on就完事了”实测下来根本跑不通。问题出在三个隐性依赖上第一NameServer必须先于所有Broker启动并稳定运行否则Broker注册失败第二Broker之间不能靠容器名直连如broker-a:10911因为Docker网络中服务发现是动态的需通过NameServer做中心路由第三主从Broker的brokerId必须严格区分Master为0Slave为1且Slave必须明确指定其Master的brokerName否则同步链路建立不起来。这些细节在官方文档里散落在不同章节新手照着QuickStart跑Demo没问题但一到集群部署就卡在slave not found或no broker available这种报错上。我后来在某物流系统重构中把集群从单主升级为双主双从2 Master 2 Slave实测QPS从1.2万提升到3.8万消息端到端延迟P99从850ms压到210ms。关键不是机器多了而是主从切换时间从分钟级降到秒级——当Broker-A-Master宕机Consumer会自动从Broker-A-Slave拉取历史消息读写分离Producer则由NameServer重定向到Broker-B-Master继续写入整个过程对业务无感。这才是“多主多从”真正的价值锚点它不是堆资源而是构建一条有冗余、可切换、能降级的消息通路。提示别被“多主”二字误导。RocketMQ的“主”指的是可写入的Broker实例但Topic的Queue分布仍由NameServer统一分配。一个Topic默认建4个Queue双主集群下Queue会均匀分布在两个Master上如Broker-A-Master持Queue 0/2Broker-B-Master持Queue 1/3Slave只负责数据同步不参与Queue分配。这点和Elasticsearch的分片主从逻辑完全不同。2. Docker Compose文件怎么写——避开网络模式、卷挂载与环境变量的三重陷阱写docker-compose.yml不是拼积木而是给RocketMQ各组件“搭舞台”。我见过太多人把官网的单机版yaml复制过来改几个IP就往生产环境扔结果集群起不来日志里全是java.net.UnknownHostException。根源在于没吃透Docker网络模型和RocketMQ的通信契约。下面这份配置是我在线上压测环境反复验证过的精简版重点标注了所有易踩坑的参数version: 3.8 services: # NameServer必须独立部署且至少2个实现高可用 namesrv-a: image: apache/rocketmq:5.1.4 container_name: rmq-namesrv-a ports: - 9876:9876 volumes: - ./data/namesrv-a/logs:/home/rocketmq/logs - ./data/namesrv-a/store:/home/rocketmq/store environment: - JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64 - ROCKETMQ_HOME/home/rocketmq command: sh mqnamesrv restart: always namesrv-b: image: apache/rocketmq:5.1.4 container_name: rmq-namesrv-b ports: - 9877:9876 volumes: - ./data/namesrv-b/logs:/home/rocketmq/logs - ./data/namesrv-b/store:/home/rocketmq/store environment: - JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64 - ROCKETMQ_HOME/home/rocketmq command: sh mqnamesrv restart: always # Broker-A Master节点 broker-a-master: image: apache/rocketmq:5.1.4 container_name: rmq-broker-a-master ports: - 10911:10911 # Broker对外服务端口 - 10912:10912 # Broker HA端口主从同步用 volumes: - ./data/broker-a/master/logs:/home/rocketmq/logs - ./data/broker-a/master/store:/home/rocketmq/store - ./conf/broker-a.properties:/home/rocketmq/conf/broker.conf environment: - JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64 - ROCKETMQ_HOME/home/rocketmq - NAMESRV_ADDRrmq-namesrv-a:9876;rmq-namesrv-b:9876 - JAVA_OPT_EXT-server -Xms2g -Xmx2g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m command: sh mqbroker -c /home/rocketmq/conf/broker.conf depends_on: - namesrv-a - namesrv-b restart: always # Broker-A Slave节点必须与Master在同一宿主机或共享网络 broker-a-slave: image: apache/rocketmq:5.1.4 container_name: rmq-broker-a-slave ports: - 10921:10911 - 10922:10912 volumes: - ./data/broker-a/slave/logs:/home/rocketmq/logs - ./data/broker-a/slave/store:/home/rocketmq/store - ./conf/broker-a-s.properties:/home/rocketmq/conf/broker.conf environment: - JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64 - ROCKETMQ_HOME/home/rocketmq - NAMESRV_ADDRrmq-namesrv-a:9876;rmq-namesrv-b:9876 - JAVA_OPT_EXT-server -Xms1g -Xmx1g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize256m command: sh mqbroker -c /home/rocketmq/conf/broker.conf depends_on: - namesrv-a - namesrv-b - broker-a-master # 关键Slave必须等Master启动后再拉起 restart: always # Broker-B Master节点同理 broker-b-master: image: apache/rocketmq:5.1.4 container_name: rmq-broker-b-master ports: - 10931:10911 - 10932:10912 volumes: - ./data/broker-b/master/logs:/home/rocketmq/logs - ./data/broker-b/master/store:/home/rocketmq/store - ./conf/broker-b.properties:/home/rocketmq/conf/broker.conf environment: - JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64 - ROCKETMQ_HOME/home/rocketmq - NAMESRV_ADDRrmq-namesrv-a:9876;rmq-namesrv-b:9876 - JAVA_OPT_EXT-server -Xms2g -Xmx2g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize320m command: sh mqbroker -c /home/rocketmq/conf/broker.conf depends_on: - namesrv-a - namesrv-b restart: always # Broker-B Slave节点 broker-b-slave: image: apache/rocketmq:5.1.4 container_name: rmq-broker-b-slave ports: - 10941:10911 - 10942:10912 volumes: - ./data/broker-b/slave/logs:/home/rocketmq/logs - ./data/broker-b/slave/store:/home/rocketmq/store - ./conf/broker-b-s.properties:/home/rocketmq/conf/broker.conf environment: - JAVA_HOME/usr/lib/jvm/java-8-openjdk-amd64 - ROCKETMQ_HOME/home/rocketmq - NAMESRV_ADDRrmq-namesrv-a:9876;rmq-namesrv-b:9876 - JAVA_OPT_EXT-server -Xms1g -Xmx1g -XX:MetaspaceSize128m -XX:MaxMetaspaceSize256m command: sh mqbroker -c /home/rocketmq/conf/broker.conf depends_on: - namesrv-a - namesrv-b - broker-b-master restart: always2.1 网络模式为什么不用host模式有人图省事把network_mode: host加进yaml结果发现Broker注册到NameServer的IP是宿主机内网地址如192.168.1.100而Consumer容器在Docker网络里解析不到这个IP。正确解法是彻底放弃host模式让所有服务走Docker默认bridge网络。此时关键在NAMESRV_ADDR环境变量——它必须填容器名端口rmq-namesrv-a:9876因为Docker内置DNS会把服务名解析成对应容器的虚拟IP。NameServer自身监听0.0.0.0:9876Broker连接时用服务名Consumer连接时同样用服务名整个链路完全在Docker网络内部闭环。注意ports映射只是为外部调试开放端口如用rocketmq-console连集群集群内部通信绝不依赖宿主机端口映射。我曾因在broker.conf里写了brokerIP1192.168.1.100导致Slave死活连不上Master查日志才发现它试图用这个IP去连Master的HA端口而该IP在Docker网络里根本不可达。2.2 卷挂载日志和存储目录必须分开RocketMQ的logs和store目录有本质区别logs存运行日志可删store存CommitLog、ConsumeQueue等核心数据绝不可删。在docker-compose中必须为每个Broker实例单独挂载store目录否则多个容器共用同一目录会导致数据覆盖。比如broker-a-master和broker-a-slave的store路径必须不同./data/broker-a/master/storevs./data/broker-a/slave/store否则Slave启动时会清空Master的数据目录——这是RocketMQ源码里写的硬逻辑Slave启动时会校验store目录是否为空非空则拒绝启动。2.3 环境变量JAVA_OPT_EXT里的内存参数是命门官方镜像默认JVM参数是-Xms512m -Xmx512m这对集群部署是灾难性的。Broker每接收一个Producer连接就要开一个Netty Channel每条Topic的Queue都要维护消费位点offset缓存内存不足直接触发Full GCGC停顿期间消息写入阻塞。我实测过双主双从集群下-Xms2g -Xmx2g是底线Slave可以设为-Xms1g -Xmx1g只读不写。MetaspaceSize也要调大否则加载大量Topic路由信息时容易OOM。3. Broker配置文件怎么配——broker.conf里藏着主从同步的生死线broker.conf不是模板填充游戏它是RocketMQ集群的“宪法”。我见过最离谱的案例某团队把Master的broker.conf直接拷贝给Slave只改了brokerId1结果集群跑了一周后突然全量消息积压查日志发现Slave的slaveReadEnabletrue没开Consumer全挤在Master上读Master磁盘IO被打满。下面逐项拆解双主双从场景下最关键的配置项附带参数背后的物理意义3.1 主从身份与同步策略brokerId和brokerRole是铁律# broker-a.properties (Master) brokerClusterNameDefaultCluster brokerNamebroker-a brokerId0 brokerRoleSYNC_MASTER # 同步主节点确保消息不丢失 flushDiskTypeSYNC_FLUSH # 同步刷盘牺牲性能保一致性# broker-a-s.properties (Slave) brokerClusterNameDefaultCluster brokerNamebroker-a # 必须和Master完全一致 brokerId1 # Slave必须为1且同一brokerName下只能有一个brokerId1 brokerRoleSLAVE # 角色必须是SLAVE flushDiskTypeASYNC_FLUSH # Slave可异步刷盘降低IO压力这里有两个致命细节第一brokerName是主从绑定的唯一标识Master和Slave必须相同否则NameServer认为这是两个无关Broker第二brokerId0是Master的身份证brokerId1是Slave的身份证且同一brokerName下不允许存在brokerId2的节点——RocketMQ不支持一主多从这是和Kafka的本质区别。如果你看到brokerId2的配置要么是旧版文档残留要么是人为错误。3.2 网络地址brokerIP1和brokerIP2决定谁来服务谁# broker-a.properties brokerIP1rmq-broker-a-master # 容器名供Producer/Consumer连接 brokerIP2rmq-broker-a-slave # Slave的容器名供Master同步数据时使用这个配置常被忽略但它决定了数据流向。brokerIP1是Broker向NameServer注册的地址也是客户端SDK连接时用的地址brokerIP2是Master向Slave发起同步请求时用的目标地址。如果brokerIP2填错了比如填成127.0.0.1Master会尝试连自己同步失败。正确做法是填Slave容器的服务名rmq-broker-a-slaveDocker DNS会解析成Slave容器的虚拟IP。3.3 主从读写控制slaveReadEnable和haTransferBatchSize# broker-a-s.properties (Slave) slaveReadEnabletrue # 关键开启后Consumer可从Slave读取消息 haTransferBatchSize256 # 主从同步批次大小单位KB默认32KBslaveReadEnabletrue是双主双从架构的“开关”。不开它Slave纯粹是冷备Consumer永远只连MasterMaster一挂整个集群读能力归零。开了它Consumer SDK会自动感知Slave状态在Master负载高时把部分读请求路由到Slave实现读写分离。haTransferBatchSize则影响同步效率值越大单次同步数据越多但网络抖动时重传成本越高值越小同步更细粒度但网络开销增大。线上我一般设为256KB262144字节平衡吞吐与稳定性。3.4 存储与清理diskMaxUsedSpaceRatio和fileReservedTime# 所有Broker通用 storePathRootDir/home/rocketmq/store storePathCommitLog/home/rocketmq/store/commitlog storePathConsumeQueue/home/rocketmq/store/consumequeue storePathIndex/home/rocketmq/store/index diskMaxUsedSpaceRatio85 # 磁盘使用率超85%时拒绝写入 fileReservedTime72 # CommitLog文件保留72小时3天diskMaxUsedSpaceRatio是安全阀。设太高如95%会导致磁盘写满Broker进程直接退出设太低如70%又浪费空间。85%是经验值留出15%空间给OS和临时文件。fileReservedTime决定消息可回溯时长72小时意味着Consumer最多能补拉3天内的消息。注意这个时间是CommitLog文件的保留时间不是消息TTL消息过期由Producer发送时设置的delayTimeLevel控制。4. 集群启动与验证从docker-compose up到mqadmin命令的完整链路写完docker-compose.yml和broker.conf别急着up -d。我总结了一套“三步启动法”每一步都有明确验证点避免盲目启动后陷入日志海洋4.1 第一步NameServer先行验证注册中心可用# 启动NameServer集群 docker-compose up -d namesrv-a namesrv-b # 等待30秒检查容器状态 docker-compose ps | grep namesrv # 验证NameServer是否正常提供服务返回空JSON表示健康 curl -s http://localhost:9876/namesrv/state | jq . # 正常输出{status:OK,timestamp:1712345678901} # 查看NameServer日志确认无ERROR docker-compose logs -f namesrv-a | grep -i error\|exception这一步卡住最常见的原因是端口冲突9876被占用或JAVA_OPT_EXT内存不足导致JVM启动失败。如果curl返回Connection refused先docker exec -it rmq-namesrv-a ps aux看Java进程是否存在如果进程存在但端口不通用docker exec -it rmq-namesrv-a netstat -tuln | grep 9876确认监听地址是否为0.0.0.0:9876。4.2 第二步Master启动验证Broker注册成功# 启动Master节点注意顺序先A后B docker-compose up -d broker-a-master sleep 10 docker-compose up -d broker-b-master # 检查Broker是否注册到NameServer docker exec -it rmq-namesrv-a sh -c cd /home/rocketmq sh bin/mqadmin clusterList -n localhost:9876 # 正常输出应包含 # DefaultCluster # broker-a 172.20.0.3:10911 MASTER # broker-b 172.20.0.4:10911 MASTERclusterList命令是集群健康的“听诊器”。如果只看到broker-a没看到broker-b说明Broker-B启动失败或注册超时。此时立刻查docker-compose logs broker-b-master90%的问题是NAMESRV_ADDR填错比如少写了一个分号或broker.conf里brokerName拼写错误。4.3 第三步Slave启动验证主从同步链路打通# 启动Slave节点必须等Master完全就绪后再启 docker-compose up -d broker-a-slave sleep 10 docker-compose up -d broker-b-slave # 检查主从同步状态关键 docker exec -it rmq-broker-a-master sh -c cd /home/rocketmq sh bin/mqadmin brokerStatus -n localhost:9876 -b rmq-broker-a-master:10911 # 关注输出中的 # haSyncState: SLAVE_SYNCED # 表示Slave已同步完成 # slaveFallBehindMaster: 0 # 落后字节数为0表示实时同步brokerStatus命令比clusterList更深入。slaveFallBehindMaster是核心指标如果大于0如10240说明Slave有延迟可能是网络抖动或Slave磁盘IO慢如果一直是-1说明主从未建立连接大概率是brokerIP2配置错误或Slave容器防火墙拦截了10912端口。4.4 终极验证用mqadmin发消息看消费是否跨主从# 创建测试Topic4个Queue均匀分布到2个Master docker exec -it rmq-broker-a-master sh -c cd /home/rocketmq sh bin/mqadmin updateTopic -n localhost:9876 -b rmq-broker-a-master:10911 -t test-topic -r 4 -w 4 # 发送100条消息Producer会自动轮询2个Master docker exec -it rmq-broker-a-master sh -c cd /home/rocketmq sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer -n localhost:9876 -t test-topic -a 100 # 启动Consumer会自动从2个Master和2个Slave拉取消息 docker exec -it rmq-broker-a-master sh -c cd /home/rocketmq sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer -n localhost:9876 -t test-topic观察Consumer日志你会看到类似ConsumeMessageThread_1 Receive New Messages: [MessageExt...], broker: rmq-broker-a-master ConsumeMessageThread_2 Receive New Messages: [MessageExt...], broker: rmq-broker-b-slave ConsumeMessageThread_3 Receive New Messages: [MessageExt...], broker: rmq-broker-a-slave这证明Consumer SDK已识别全部4个Broker节点并实现了跨主从消费。如果日志里只出现rmq-broker-a-master和rmq-broker-b-master说明slaveReadEnabletrue没生效回去检查Slave的broker.conf。5. 常见故障排查从NO_BROKER_TOPIC到slave not found的实战诊断树集群跑起来只是开始运维才是持久战。我把三年来处理过的高频故障整理成一张“症状-原因-解法”对照表按发生频率排序每一条都来自真实踩坑现场故障现象根本原因排查命令解决方案org.apache.rocketmq.client.exception.MQClientException: No route info of this topicTopic未创建或创建时指定的Broker不存在docker exec -it rmq-namesrv-a sh -c cd /home/rocketmq sh bin/mqadmin topicList -n localhost:9876用updateTopic命令显式创建Topic-b参数必须指定已注册的Broker名如rmq-broker-a-masterorg.apache.rocketmq.remoting.exception.RemotingConnectException: connect to ip:port failedBroker注册的IP是容器内网IP外部Consumer无法访问docker exec -it rmq-namesrv-a sh -c cd /home/rocketmq sh bin/mqadmin clusterList -n localhost:9876检查broker.conf中brokerIP1是否填了容器名如rmq-broker-a-master而非127.0.0.1或宿主机IPslave not foundSlave未启动或brokerName与Master不一致docker-compose ps | grep slavedocker exec -it rmq-broker-a-slave cat /home/rocketmq/conf/broker.conf | grep brokerName确认Slave容器正在运行且brokerName和Master完全一致大小写敏感broker is not availableBroker进程崩溃或brokerId冲突docker-compose logs broker-a-master | tail -20docker exec -it rmq-broker-a-master ps aux | grep java查日志找OOM或brokerId重复错误重启前删掉store目录下的abort文件强制Broker重新初始化Consumer消费延迟飙升Slave未启用读能力所有读请求压在Masterdocker exec -it rmq-broker-a-master sh -c cd /home/rocketmq sh bin/mqadmin brokerStatus -n localhost:9876 -b rmq-broker-a-master:10911 | grep slaveReadEnable确认Slave的broker.conf中slaveReadEnabletrue并重启Slave容器5.1 深度案例slave not found的完整排查链路这个报错看似简单但背后可能有五种不同原因。我以某次线上事故为例还原完整的诊断过程现象Consumer日志持续打印WARN RemotingUtil - getAvailableChannel: no channel found for brokerNamebroker-a, brokerId1brokerStatus显示haSyncState: NOT_SYNCED。第一步确认Slave进程存活docker-compose ps | grep broker-a-slave # 输出rmq-broker-a-slave ... Up 2 minutes # 进程活着排除容器崩溃第二步检查Slave配置docker exec -it rmq-broker-a-slave cat /home/rocketmq/conf/broker.conf | grep -E (brokerName|brokerId|brokerRole) # 输出brokerNamebroker-a, brokerId1, brokerRoleSLAVE # 配置正确排除参数错误第三步验证Master能否连通Slave# 进入Master容器telnet Slave的HA端口10912 docker exec -it rmq-broker-a-master telnet rmq-broker-a-slave 10912 # 返回Connection refused # 问题定位网络不通第四步查Slave端口监听docker exec -it rmq-broker-a-slave netstat -tuln | grep 10912 # 无输出说明Slave没监听HA端口第五步翻日志找根因docker-compose logs broker-a-slave | grep -A5 -B5 bind # 输出ERROR BrokerController - Start service failed. java.net.BindException: Address already in use # 原因Slave的10912端口被其他进程占用了解决方案docker exec -it rmq-broker-a-slave lsof -i:10912找出占用进程kill -9 pid干掉它docker-compose restart broker-a-slave注意lsof在官方镜像里默认没有需先docker exec -it rmq-broker-a-slave apk add --no-cache lsof安装。这也是为什么我建议在Dockerfile里提前装好lsof、net-tools等诊断工具。5.2 性能瓶颈预警当putMessage耗时超过100msRocketMQ监控的核心指标是putMessage耗时。用mqadmin可实时抓取# 每5秒刷新一次Broker-A的写入耗时 docker exec -it rmq-broker-a-master sh -c cd /home/rocketmq sh bin/mqadmin brokerStatus -n localhost:9876 -b rmq-broker-a-master:10911 | grep putMessage # 输出putMessageAverageTime: 125.345 # 单位毫秒如果这个值持续100ms说明写入有瓶颈。常见原因及对策磁盘IO瓶颈iostat -x 1看%util是否90%换SSD或增加RAID0阵列JVM GC频繁docker exec -it rmq-broker-a-master jstat -gc $(pgrep java) 1000 5若FGCT1s调大-Xmx网络延迟高ping rmq-broker-a-slave看延迟是否10ms跨机房部署需用专线。我在线上曾遇到putMessageAverageTime突增至2000ms查jstat发现FGCT达8s最终定位是-Xmx2g不够把JAVA_OPT_EXT改成-Xms4g -Xmx4g后恢复正常。6. 生产环境加固TLS加密、ACL权限与Prometheus监控的落地要点docker-compose部署的集群默认是裸奔状态直接暴露在内网也不安全。我在某金融类项目X中基于这套架构做了三层加固每一步都经过压测验证6.1 TLS双向认证让消息传输不再“裸泳”RocketMQ 5.x开始原生支持TLS但配置极其繁琐。核心是三步生成证书用OpenSSL为每个Broker和NameServer生成keystore.jks和truststore.jks修改broker.conf添加tlsEnabletrue、tlsTestModeEnablefalse、tlsKeyPath/home/rocketmq/conf/tls/keystore.jks等Client端配置Producer/Consumer SDK需设置rocketmq.client.tls.enabletrue和证书路径。实操心得千万别用自签名证书的truststore.jks否则Consumer启动时报PKIX path building failed。正确做法是把CA根证书导入JVM信任库keytool -import -alias rmq-ca -file ca.crt -keystore $JAVA_HOME/jre/lib/security/cacerts。6.2 ACL权限控制给Topic和Group上锁默认所有Producer都能发任意Topic所有Consumer都能订阅任意Group这在多租户场景是灾难。启用ACL只需两步在broker.conf中添加aclEnabletrue创建plain_acl.yml文件放在conf/目录下global: whiteRemoteAddress: accounts: - accessKey: producer-key secretKey: producer-secret admin: false defaultTopicPerm: DENY defaultGroupPerm: DENY topicPerms: - test-topicPUB - accessKey: consumer-key secretKey: consumer-secret admin: false defaultTopicPerm: DENY defaultGroupPerm: DENY topicPerms: - test-topicSUB groupPerms: - test-groupSUB然后Producer代码里加DefaultMQProducer producer new DefaultMQProducer(test-group); producer.setAccessChannel(AccessChannel.LOCAL); producer.setSessionCredentials(producer-key, producer-secret, null);6.3 Prometheus监控把brokerStatus变成可视化大盘RocketMQ自带rocketmq-exporter但默认只暴露基础指标。我做了定制化增强修改exporter配置增加putMessageAverageTime、getFoundTps等关键指标用Grafana导入社区模板ID: 13222重点关注“消息堆积量”、“主从同步延迟”、“Broker CPU使用率”三块设置告警规则当rocketmq_broker_ha_slave_fallback_bytes{brokerbroker-a} 1048576010MB时触发企业微信告警。这套监控上线后我们把故障平均发现时间MTTD从15分钟缩短到47秒真正实现了“未病先防”。最后分享一个小技巧每次docker-compose up前先执行docker-compose down -v清空所有volume再rm -rf data/删除本地存储目录。这不是矫情而是避免旧数据污染新集群——RocketMQ的store目录里有checkpoint文件记录刷盘位置残留它会导致新Broker启动时数据错乱。我踩过三次这个坑现在已写成pre-up.sh脚本自动执行。