Linux 部署 RocketMQ 实操：从内网到公网，搞定远程消息服务

Ne0inhk

— 9 min read
Linux 部署 RocketMQ 实操：从内网到公网，搞定远程消息服务

前言

做中间件开发的朋友应该都有过这样的经历：在 Linux 服务器上搭好了 RocketMQ，内网测试一切正常，可外网想连的时候却被网络隔离卡得死死的。要么得申请公网 IP，要么折腾端口映射，费时又费力。最近我踩遍了坑，终于找到了一套极简的部署 + 外网访问方案，不用复杂配置，几分钟就能让你的 RocketMQ 从内网走向公网，今天就把这套实操流程全部分享出来。

消息队列不再遥远——在Linux上，RocketMQ一跑就通。

image-20251230161049877

1.前提条件

首先需要安装jdk：

java-version
image-20251229151957506

首先下载RocketMQ的源码包以及运行包：

RocketMQ建议的运行环境需要至少12G的内存。

关于RocketMQ的版本： 我们这里采用最新的5.3.4版本

image-20251229152351264

这里需要小伙伴注意一下，4.x的系列版本已经停止了维护。这意味着目前已经不建议使用4.x的版本了。

2.安装RocketMQ

将下载后的文件上传到/app/rocketmq

mkdir-p rocketmq cd rocketmq/
image-20251229160346183

解压该文件：

unzip rocketmq-all-5.3.4-bin-release.zip
image-20251229160719226

修改rocketmq文件名：

mv rocketmq-all-5.3.4-bin-release/ rocketmq
image-20251229160943531

3.配置RocketMQ

3.1修改runserver.sh和runbroker.sh启动脚本

修改runserver.sh脚本：

vi /app/rocketmq/rocketmq/bin/runserver.sh

将原来的参数就改为红框内参数，如果你的机器内存够大这一步可以不配置：

image-20251229162620052

jdk路径必须修改为自己的jdk路径：

whichjava
image-20251229172431450
image-20251229172335938

修改runbroker.sh脚本：

vi /app/rocketmq/rocketmq/bin/runbroker.sh

将原来的参数就改为红框内参数，如果你的机器内存够大这一步可以不配置：

image-20251229172751318

jdk路径必须修改为自己的jdk路径：

image-20251229173906545

3.2新增broker.conf配置信息

编辑broker.conf配置文件：

vi /app/rocketmq/rocketmq/conf/broker.conf namesrvAddr = localhost:9876 brokerIP1 = localhost
image-20251229174847155

3.3启动关闭rocketmq

创建日志目录：

mkdir-p /data/logs/rocketmq
image-20251229175048880

启动命令：

#启动namesrv服务nohupsh /app/rocketmq/rocketmq/bin/mqnamesrv > /data/logs/rocketmq/nameserver.log &#启动broker服务nohupsh /app/rocketmq/rocketmq/bin/mqbroker -n localhost:9876 autoCreateTopicEnable=true > /data/logs/rocketmq/broker.log &
image-20251230112136664

验证是否启动成功：

jps
image-20251230112617524

关闭命令:

#关闭namesrv服务 /app/rocketmq/rocketmq/bin/mqshutdown namesrv #关闭broker服务 /app/rocketmq/rocketmq/bin/mqshutdown broker
image-20251230112736456

4.配置开机自启动

编写namesrv服务：

#创建配置文件vi /etc/systemd/system/rocketmqnamesrv.service #添加如下内容[Unit]Description=rocketmq - nameserver Documentation=rocketmq_nameserver After=network.target [Service]Type=sample User=root ExecStart=/app/rocketmq/rocketmq/bin/mqnamesrv ExecReload=/bin/kill -s HUP $MAINPIDExecStop=/bin/kill -s QUIT $MAINPIDRestart=0LimitNOFILE=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=sample User=root ExecStart=/app/rocketmq/rocketmq/bin/mqbroker -n localhost:9876 /app/rocketmq/rocketmq/conf/broker.conf ExecReload=/bin/kill -s HUP $MAINPIDExecStop=/bin/kill -s QUIT $MAINPIDRestart=0LimitNOFILE=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服务。

5.安装cpolar内网穿透工具

cpolar 可以将你本地电脑中的服务（如 SSH、Web、数据库）映射到公网。即使你在家里或外出时，也可以通过公网地址连接回本地运行的开发环境。

❤️以下是安装cpolar步骤：

使用一键脚本安装命令：

sudocurl https://get.cpolar.sh |sh
image-20250814101639846

安装完成后，执行下方命令查看cpolar服务状态：（如图所示即为正常启动）

sudo systemctl status cpolar
22e5adfaf290a17fc3384bb296055259

Cpolar安装和成功启动服务后，在浏览器上输入虚拟机主机IP加9200端口即:【ip:9200】访问Cpolar管理界面，使用Cpolar官网注册的账号登录,登录后即可看到cpolar web 配置界面,接下来在web 界面配置即可：

打开浏览器访问本地9200端口，使用cpolar账户密码登录即可,登录后即可对隧道进行管理。

8a6698b1bf26d64ba3645827fbfb1c29

6.配置公网地址

通过配置，你可以在本地 WSL 或 Linux 系统上运行 SSH 服务，并通过 Cpolar 将其映射到公网，从而实现从任意设备远程连接开发环境的目的。

  • 隧道名称：可自定义，本例使用了:rocketmq，注意不要与已有的隧道名称重复
  • 协议：tcp
  • 本地地址：9876
  • 端口类型：随机临时TCP端口
  • 地区：China Top
image-20251230153622707

创建成功后，打开左侧在线隧道列表,可以看到刚刚通过创建隧道生成了公网地址，接下来就可以在其他电脑或者移动端设备（异地）上，使用任意一个地址在终端中访问即可。

  • tcp 表示使用的协议类型
  • 2.tcp.cpolar.top是 Cpolar 提供的域名
  • 11242是随机分配的公网端口号
image-20251230153725059

现在我们用另一台虚拟机启动一下我们的rocketmq：

nohupsh /app/rocketmq/rocketmq/bin/mqbroker -n2.tcp.cpolar.top:11242 autoCreateTopicEnable=true > /data/logs/rocketmq/broker.log &

如图可见 启动成功：

image-20251230155141996

7.保留固定TCP公网地址

使用cpolar为其配置TCP地址，该地址为固定地址，不会随机变化。

image-20251230155719242

选择区域和描述：有一个下拉菜单，当前选择的是“China Top”。
右侧输入框，用于填写描述信息。
保留按钮：在右侧有一个橙色的“保留”按钮，点击该按钮可以保留所选的TCP地址。
列表中显示了一条已保留的TCP地址记录。

登录cpolar web UI管理界面，点击左侧仪表盘的隧道管理——隧道列表，找到所要配置的隧道rocketmq，点击右侧的编辑。

image-20251230155748257

修改隧道信息，将保留成功的TCP端口配置到隧道中。

  • 端口类型：选择固定TCP端口
  • 预留的TCP地址：填写保留成功的TCP地址

点击更新。

image-20251230155819333

创建完成后，打开在线隧道列表，此时可以看到随机的公网地址已经发生变化，地址名称也变成了保留和固定的TCP地址。

image-20251230155851314

这样我们的地址就永远不会发生变化啦！

总结

其实 RocketMQ 的部署本身并不复杂，难的是解决网络隔离的痛点。这套从基础部署到内网穿透的完整流程，亲测在开发测试、小型生产场景下都很好用。如果你也在为 RocketMQ 的外网访问发愁，不妨试试这个方法，有任何实操中的问题，评论区咱们一起聊聊。

Could not load content