Linux系统安装配置RocketMQ 消息队列集群部署

2026-05-15电脑数码225052

启动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-abroker-b

集群模式下 brokerIdbrokerRole 必须成对设置

单节点测试时设 brokerId=0 + brokerRole=ASYNC_MASTER 就行;但部署 2m-2s 集群时,每对 Master-Slave 的 brokerName 相同,brokerId 必须不同:

Master 节点:brokerId=0brokerRole=SYNC_MASTER(或 ASYNC_MASTER

Facetune

一款在线照片和视频编辑工具,允许用户创建AI头像

下载

对应 Slave 节点:brokerId=1brokerRole=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.logbroker.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 端口)。

《Linux系统安装配置RocketMQ 消息队列集群部署.doc》

下载本文的Word格式文档,以方便收藏与打印。