启动NameServer前须确认JDK 8/11环境(JDK17+不兼容),并手动创建日志目录~/logs/rocketmqlogs/;NAMESRV_ADDR非NameServer所需,而是供Producer/Consumer使用。
启动 NameServer 前必须确认 Java 环境和日志目录
RocketMQ 5.x 全版本依赖 JDK 8 或 JDK 11,java -version 输出必须显示 1.8. 或 11. 开头;JDK 17+ 不兼容。没配好会卡在 Exception in thread "main" java.lang.UnsupportedClassVersionError。
日志路径默认是 ~/logs/rocketmqlogs/,但很多用户解压后直接运行,目录不存在会导致启动无声失败。务必手动创建:
mkdir -p ~/logs/rocketmqlogs/
另外,NAMESRV_ADDR 环境变量不是启动 NameServer 所需的,它是给 Producer/Consumer 用的——NameServer 自己不读这个变量。
Broker 启动失败常见于 broker.conf 缺失或 IP 配置错误
二进制包(如 rocketmq-all-5.3.2-bin-release.zip)自带默认配置,但默认监听 127.0.0.1,外网无法访问;源码编译包则根本没配 broker.conf,直接启动会报 No such file or directory。
正确做法是显式指定配置文件并填对本机 IP:
echo "brokerIP1=192.168.1.100 namesrvAddr=192.168.1.100:9876 brokerName=broker-a brokerId=0 deleteWhen=04 fileReservedTime=48 brokerRole=ASYNC_MASTER flushDiskType=ASYNC_FLUSH" > conf/broker.conf
-
brokerIP1必须写真实内网 IP,不能写0.0.0.0或主机名 -
namesrvAddr要跟实际 NameServer 启动地址一致,多个用分号隔开 - 若用多 Master 模式,每台机器的
brokerName必须不同(如broker-a、broker-b)
集群模式下 brokerId 和 brokerRole 必须成对设置
单节点测试时设 brokerId=0 + brokerRole=ASYNC_MASTER 就行;但部署 2m-2s 集群时,每对 Master-Slave 的 brokerName 相同,brokerId 必须不同:
Master 节点:brokerId=0,brokerRole=SYNC_MASTER(或 ASYNC_MASTER)
Facetune
一款在线照片和视频编辑工具,允许用户创建AI头像
下载
对应 Slave 节点:brokerId=1,brokerRole=SLAVE
漏掉 brokerRole=SLAVE 或把 Slave 的 brokerId 也设成 0,会导致 Slave 启动后注册为另一个 Master,NameServer 日志里会出现重复 broker-a 注册,Consumer 拉取队列时行为异常。
同步双写要求 flushDiskType=SYNC_FLUSH + brokerRole=SYNC_MASTER 同时生效,缺一不可。
验证集群是否真正就绪,别只看日志里的 “boot success”
tail -f ~/logs/rocketmqlogs/namesrv.log 出现 The Name Server boot success 只代表进程起来了;proxy.log 或 broker.log 里有 boot success 也不代表能收发消息。
真正有效的验证方式只有两个:
- 执行
./bin/mqadmin clusterList -n 192.168.1.100:9876,输出里必须包含所有预期的brokerName,且Broker列状态为OK - 用
./bin/tools.sh org.apache.rocketmq.example.quickstart.Producer发一条消息,再用./bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer拉出来——这步必须在目标机器上跑,不能只在本地跑
很多人卡在 Consumer 收不到消息,其实是 NAMESRV_ADDR 没导到 Consumer 进程环境里,或者防火墙拦了 10911(Broker 默认端口)、9876(NameServer 端口)。
