Linux 部署 RocketMQ 及公网访问配置指南
在 Linux 环境下部署 Apache RocketMQ 5.x 版本的完整流程,包括 JDK 环境准备、安装包解压、配置文件修改、服务启动验证及开机自启设置。针对外网访问需求,提供了基于内网穿透工具的公网地址配置方案,解决了本地调试时的网络隔离问题,确保服务可被异地连接。

在 Linux 环境下部署 Apache RocketMQ 5.x 版本的完整流程,包括 JDK 环境准备、安装包解压、配置文件修改、服务启动验证及开机自启设置。针对外网访问需求,提供了基于内网穿透工具的公网地址配置方案,解决了本地调试时的网络隔离问题,确保服务可被异地连接。

首先需要安装 JDK:
java -version
下载 RocketMQ 的源码包以及运行包:
RocketMQ 建议的运行环境需要至少 12G 的内存。
关于 RocketMQ 的版本:这里采用最新的 5.3.4 版本。4.x 系列版本已停止维护,不建议使用。
将下载后的文件上传到 /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
修改 runserver.sh 脚本:
vi /app/rocketmq/rocketmq/bin/runserver.sh
将原来的参数改为红框内参数(如果你的机器内存够大这一步可以不配置):
JDK 路径必须修改为自己的 JDK 路径:
which java
修改 runbroker.sh 脚本:
vi /app/rocketmq/rocketmq/bin/runbroker.sh
将原来的参数改为红框内参数(如果你的机器内存够大这一步可以不配置):
JDK 路径必须修改为自己的 JDK 路径。
编辑 broker.conf 配置文件:
vi /app/rocketmq/rocketmq/conf/broker.conf
内容如下:
namesrvAddr = localhost:9876
brokerIP1 = localhost
创建日志目录:
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=https://rocketmq.apache.org/
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=https://rocketmq.apache.org/
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
此时 rocketmq 是关闭状态,使用 systemctl 方式启动测试:
# 依次执行启动 namesrv
systemctl daemon-reload
systemctl enable rocketmqnamesrv.service
systemctl start rocketmqnamesrv.service
systemctl status rocketmqnamesrv.service
# 依次执行启动 broker
systemctl daemon-reload
systemctl enable rocketmqbroker.service
systemctl start rocketmqbroker.service
systemctl status rocketmqbroker.service
你已在内网 Linux 服务器上部署了 Apache RocketMQ,执行 mqnamesrv 和 mqbroker 成功启动了消息服务。但默认情况下,这些服务仅监听本地或局域网,外网客户端无法连接。
此时,无需申请公网 IP 或配置复杂端口映射,只需借助内网穿透工具(如 cpolar),将 RocketMQ 的关键端口安全暴露到公网。一旦隧道建立,任何外网设备都能像在内网一样,直接连接并使用你刚刚启动的 RocketMQ 服务。
通过配置,你可以在本地 WSL 或 Linux 系统上运行 SSH 服务,并通过内网穿透工具将其映射到公网,从而实现从任意设备远程连接开发环境的目的。
创建成功后,打开在线隧道列表,可以看到刚刚通过创建隧道生成了公网地址,接下来就可以在其他电脑或者移动端设备(异地)上,使用任意一个地址在终端中访问即可。
现在我们用另一台虚拟机启动一下我们的 rocketmq:
nohup sh /app/rocketmq/rocketmq/bin/mqbroker -n 2.tcp.cpolar.top:11242 autoCreateTopicEnable=true > /data/logs/rocketmq/broker.log &
如图可见启动成功。
使用内网穿透工具为其配置 TCP 地址,该地址为固定地址,不会随机变化。
选择区域和描述,当前选择的是'China Top'。右侧输入框用于填写描述信息。点击'保留'按钮可以保留所选的 TCP 地址。
登录管理界面,点击左侧仪表盘的隧道管理——隧道列表,找到所要配置的隧道 rocketmq,点击右侧的编辑。
修改隧道信息,将保留成功的 TCP 端口配置到隧道中。
点击更新。
创建完成后,打开在线隧道列表,此时可以看到随机的公网地址已经发生变化,地址名称也变成了保留和固定的 TCP 地址。
这样我们的地址就永远不会发生变化啦!

微信公众号「极客日志」,在微信中扫描左侧二维码关注。展示文案:极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具,Keycode 信息在线工具,online
JavaScript 字符串转义/反转义;Java 风格 \uXXXX(Native2Ascii)编码与解码。 在线工具,Escape 与 Native 编解码在线工具,online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具,JavaScript / HTML 格式化在线工具,online
Terser 压缩、变量名混淆,或 javascript-obfuscator 高强度混淆(体积会增大)。 在线工具,JavaScript 压缩与混淆在线工具,online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具,Base64 字符串编码/解码在线工具,online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具,Base64 文件转换器在线工具,online