当前位置: 代码网 > 服务器>服务器>Linux > Linux部署RocketMQ的实操流程

Linux部署RocketMQ的实操流程

2026年03月24日 Linux 我要评论
前言做中间件开发的朋友应该都有过这样的经历:在 linux 服务器上搭好了 rocketmq,内网测试一切正常,可外网想连的时候却被网络隔离卡得死死的。要么得申请公网 ip,要么折腾端口映射,费时又费

前言

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

消息队列不再遥远——在linux上,rocketmq一跑就通。

1.前提条件

首先需要安装jdk

java -version

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

rocketmq建议的运行环境需要至少12g的内存

关于rocketmq的版本: 我们这里采用最新的5.3.4版本

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

2.安装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

3.配置rocketmq

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

修改runserver.sh脚本:

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

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

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

which java

修改runbroker.sh脚本:

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

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

jdk路径必须修改为自己的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

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 $mainpid
execstop=/bin/kill -s quit $mainpid
restart=0
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=sample
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=0
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服务。

5.安装cpolar内网穿透工具

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

以下是安装cpolar步骤:

使用一键脚本安装命令:

sudo curl https://get.cpolar.sh | sh

安装完成后,执行下方命令查看cpolar服务状态:(如图所示即为正常启动)

sudo systemctl status cpolar

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

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

6.配置公网地址

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

  • 隧道名称:可自定义,本例使用了:rocketmq,注意不要与已有的隧道名称重复
  • 协议:tcp
  • 本地地址:9876
  • 端口类型:随机临时tcp端口
  • 地区:china top

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

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

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

nohup sh /app/rocketmq/rocketmq/bin/mqbroker -n 2.tcp.cpolar.top:11242 autocreatetopicenable=true > /data/logs/rocketmq/broker.log &

如图可见 启动成功:

7.保留固定tcp公网地址

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

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

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

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

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

点击更新

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

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

总结

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

以上就是linux部署rocketmq的实操流程的详细内容,更多关于linux部署rocketmq的资料请关注代码网其它相关文章!

(0)

相关文章:

版权声明:本文内容由互联网用户贡献,该文观点仅代表作者本人。本站仅提供信息存储服务,不拥有所有权,不承担相关法律责任。 如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 2386932994@qq.com 举报,一经查实将立刻删除。

发表评论

验证码:
Copyright © 2017-2026  代码网 保留所有权利. 粤ICP备2024248653号
站长QQ:2386932994 | 联系邮箱:2386932994@qq.com