前提条件
首先需要安装 JDK:
java -version
下载 RocketMQ 的源码包以及运行包:
RocketMQ 建议的运行环境需要至少 12G 的内存。我们这里采用最新的 5.3.4 版本。
注意:4.x 系列版本已停止维护,不建议使用。
安装 RocketMQ
将下载后的文件上传到 /app/rocketmq:
mkdir -p rocketmq
cd rocketmq/
解压该文件:
unzip rocketmq-all-5.3.4-bin-release.zip
修改 rocketmq 文件名:
mv rocketmq-all-5.3.4-bin-release/ rocketmq
配置 RocketMQ
3.1 修改启动脚本
修改 runserver.sh 脚本:
vi /app/rocketmq/rocketmq/bin/runserver.sh
调整参数(如机器内存足够可跳过部分配置),并修改 JDK 路径:
which java
修改 runbroker.sh 脚本:
vi /app/rocketmq/rocketmq/bin/runbroker.sh
同样调整参数并确认 JDK 路径。
3.2 新增 broker.conf 配置信息
编辑 broker.conf 配置文件:
vi /app/rocketmq/rocketmq/conf/broker.conf
内容如下:
namesrvAddr = localhost:9876
brokerIP1 = localhost
3.3 启动与关闭 RocketMQ
创建日志目录:
mkdir -p /data/logs/rocketmq
启动命令:
# 启动 namesrv 服务
nohup sh /app/rocketmq/rocketmq/bin/mqnamesrv > /data/logs/rocketmq/nameserver.log &
# 启动 broker 服务
nohup sh /app/rocketmq/rocketmq/bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true > /data/logs/rocketmq/broker.log &
验证是否启动成功:
jps
关闭命令:
# 关闭 namesrv 服务
/app/rocketmq/rocketmq/bin/mqshutdown namesrv
# 关闭 broker 服务
/app/rocketmq/rocketmq/bin/mqshutdown broker
配置开机自启动
编写 namesrv 服务配置:
vi /etc/systemd/system/rocketmqnamesrv.service
添加如下内容:
[Unit]
Description=rocketmq - nameserver
Documentation=rocketmq_nameserver
After=network.target
[Service]
Type=simple
User=root
ExecStart=/app/rocketmq/rocketmq/bin/mqnamesrv
ExecReload=/bin/kill -s HUP $MAINPID
ExecStop=/bin/kill -s QUIT $MAINPID
Restart=on-failure
LimitNOFILE=65535
[Install]
WantedBy=multi-user.target
编写 broker 服务配置:
vi /etc/systemd/system/rocketmqbroker.service
添加如下内容:
[Unit]
Description=rocketmq - broker
Documentation=rocketmq_broker
After=network.target
[Service]
Type=simple
User=root
ExecStart=/app/rocketmq/rocketmq/bin/mqbroker -n localhost:9876 /app/rocketmq/rocketmq/conf/broker.conf
ExecReload=/bin/kill -s HUP $MAINPID
ExecStop=/bin/kill -s QUIT $MAINPID
Restart=on-failure
LimitNOFILE=65535
[Install]
WantedBy=multi-user.target
测试启动:
systemctl daemon-reload
systemctl enable rocketmqnamesrv.service
systemctl start rocketmqnamesrv.service
systemctl status rocketmqnamesrv.service
systemctl daemon-reload
systemctl enable rocketmqbroker.service
systemctl start rocketmqbroker.service
systemctl status rocketmqbroker.service
此时 RocketMQ 已在内网 Linux 服务器上部署成功,但默认仅监听本地或局域网,外网客户端无法连接。
配置公网地址
借助 cpolar 内网穿透工具,将 RocketMQ 的关键端口安全暴露到公网。
安装 cpolar:
sudo curl https://get.cpolar.sh | sh
查看服务状态:
sudo systemctl status cpolar
登录管理界面:浏览器访问 http://<虚拟机主机 IP>:9200,使用账号登录后进入 Web 配置界面。
配置隧道:
- 隧道名称:rocketmq
- 协议:tcp
- 本地地址:9876
- 端口类型:随机临时 TCP 端口
- 地区:China Top
创建成功后,在在线隧道列表中获取公网地址(格式示例:tcp.cpolar.top + 端口号)。
远程连接测试:
使用另一台设备启动 RocketMQ Broker,指向公网地址:
nohup sh /app/rocketmq/rocketmq/bin/mqbroker -n <公网地址> autoCreateTopicEnable=true > /data/logs/rocketmq/broker.log &
保留固定 TCP 公网地址
如需固定公网地址,可在 cpolar Web UI 中操作:
- 点击'保留'按钮获取固定 TCP 地址。
- 进入隧道列表,找到对应隧道点击'编辑'。
- 端口类型选择'固定 TCP 端口',填入预留的 TCP 地址。
- 点击'更新'。
更新后,公网地址将不再随机变化。
总结
RocketMQ 部署本身并不复杂,核心在于解决网络隔离问题。通过基础部署配合内网穿透工具,可实现开发测试及小型生产场景下的外网访问需求。


