RocketMQ部署教程:Linux单机环境从零搭建与验证
RocketMQ 单机部署的核心是把 JDK、NameServer 和 Broker 三件事跑通:安装 JDK 后解压 RocketMQ 安装包,先启动 NameServer,再启动 Broker,最后用自带的 tools 脚本验证消息能否收发。
本文按 Linux 服务器环境演示,适合零基础用户照做,默认你已有一台可登录的 Linux 机器和基础命令行操作能力。
部署前先确认这几项环境条件
RocketMQ 依赖 Java 运行环境,动手前先检查系统是否已装 JDK。
推荐使用 JDK 8 或 JDK 11,两者在常见 RocketMQ 版本中兼容性较好。
检查命令:
java -version
echo $JAVA_HOME
如果 java -version 没有输出,说明未安装 JDK,需要先安装并配置 JAVA_HOME。
同时确认服务器内存:单机跑 NameServer 和 Broker,建议至少 2GB 可用内存,否则 Broker 容易因内存不足启动失败。
还需要准备一个安装目录,例如 /usr/local/rocketmq,后续解压和启动都基于这个路径,避免文件散落各处。
下载与解压 RocketMQ
从 Apache RocketMQ 官方发布页获取二进制包,选择带 bin 目录的二进制版本,不要选源码包。
下载后上传到服务器,或用 wget 直接拉取。
cd /usr/local
wget https://dist.apache.org/repos/dist/release/rocketmq/rocketmq-all-5.1.4-bin-release.zip
unzip rocketmq-all-5.1.4-bin-release.zip
mv rocketmq-all-5.1.4-bin-release rocketmq
解压完成后进入目录查看结构:
cd /usr/local/rocketmq
ls
应能看到 bin、conf、lib 等目录。bin 里存放启动脚本,conf 里是配置文件,后面调整内存参数和 Broker 配置都在这里。
启动 NameServer 与 Broker
RocketMQ 的 NameServer 相当于注册中心,Broker 是真正存储和转发消息的服务。
启动顺序必须是先 NameServer,再 Broker。
启动 NameServer:
cd /usr/local/rocketmq/bin
nohup sh mqnamesrv &
查看启动日志确认是否成功:
tail -f ~/logs/rocketmqlogs/namesrv.log
看到 The Name Server boot success 字样即表示启动成功。
启动 Broker 前,建议先修改默认内存参数。
RocketMQ 默认给 Broker 分配的内存较大,小内存服务器容易启动失败。
编辑 bin/runbroker.sh,找到 JAVA_OPT 相关行,把 -Xms8g -Xmx8g 调整为适合你服务器的值,例如:
JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m"
同样地,bin/runserver.sh 中 NameServer 的默认内存也可按需调小。
修改完成后启动 Broker,并指定 NameServer 地址:
nohup sh mqbroker -n localhost:9876 &
查看 Broker 日志:
tail -f ~/logs/rocketmqlogs/broker.log
出现 The broker ... boot success 即表示 Broker 已注册到 NameServer。
端口放行与启动失败排查
RocketMQ 默认使用多个端口,服务器防火墙或安全组未放行时,客户端会连不上。
常见端口包括:
9876:NameServer 监听端口10911:Broker 主端口10909:Broker 快速失败端口
如果使用 firewalld,放行命令示例:
firewall-cmd --permanent --add-port=9876/tcp
firewall-cmd --permanent --add-port=10911/tcp
firewall-cmd --permanent --add-port=10909/tcp
firewall-cmd --reload
云服务器还需在控制台安全组中放行相同端口。
启动失败时优先看日志,不要反复重启。
常见原因有:内存不足导致 JVM 无法启动、JAVA_HOME 未配置、端口被占用。
检查端口占用:
netstat -tlnp | grep 9876
netstat -tlnp | grep 10911
如果 Broker 启动报 connect to nameserver failed,先确认 NameServer 是否真的在运行,再检查 -n 参数地址是否写对。
用自带工具验证消息收发
部署完成后必须验证消息能否正常发送和消费,否则不能算部署成功。
RocketMQ 自带 tools.sh 脚本可用于生产者和消费者测试。
发送测试消息:
cd /usr/local/rocketmq/bin
sh tools.sh org.apache.rocketmq.example.quickstart.Producer
正常会输出多条 SendResult 信息。
另开一个终端启动消费者:
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer
消费者会持续拉取并打印消息。
如果能同时看到发送成功和消费成功,说明 NameServer、Broker 和消息链路都已正常。
常见疑问
Broker 启动后客户端连不上怎么办?
先检查 9876 和 10911 是否对客户端网络放行,再确认 Broker 配置中的 brokerIP1 是否指向服务器可被访问的 IP。
如果服务器有多张网卡,Broker 可能注册了内网 IP,导致外部客户端无法连接,需要在 conf/broker.conf 中显式指定。
单机部署能否用于生产环境?
单机模式适合开发测试和学习验证,不具备高可用能力。
生产环境通常需要多 NameServer、多 Broker 主从或 Dledger 模式,并配合监控和磁盘规划,不能直接用本文的单机步骤上线。
启动脚本提示 JAVA_HOME 未设置怎么处理?
在 /etc/profile 或当前用户环境变量中配置 JAVA_HOME 指向 JDK 安装目录,然后执行 source /etc/profile 使其生效,再重新启动服务。
完成以上步骤后,RocketMQ 单机环境即可运行。
后续如需调整消息保留时间、刷盘策略或开启 ACL,再基于 conf 目录下的配置文件逐步修改,每次改动后重启对应服务并复查日志,确认没有新的报错再继续。