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

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 的外网访问发愁,不妨试试这个方法,有任何实操中的问题,评论区咱们一起聊聊。

Read more

五大经典排序算法:插入、希尔、冒泡、选择、堆排序全攻略

五大经典排序算法:插入、希尔、冒泡、选择、堆排序全攻略

目录 --------------插入排序------------- 1、插入排序思想 2、示例代码 3、效率分析 --------------希尔排序------------- 1、希尔排序思想 2、示例代码 3、效率分析 --------------选择排序------------- 1、选择排序思想 2、示例代码 3、效率分析 ---------------堆排序-------------- 1、堆排序思想 2、示例代码 3、效率分析 --------------冒泡排序------------- 1、冒泡排序思想 2、示例代码 3、效率分析 上述五大排序性能对比: --------------插入排序------------- 1、插入排序思想 插入排序的核心思想是逐步构建有序序列: 将数组分为 “已排序” 和 “未排序” 两部分,初始时已排序部分只包含第一个元素。 每次从未排序部分取出第一个元素,将其向前插入到已排序序列中的正确位置,使得插入后的序列依然保持有序。

By Ne0inhk
Flutter 组件 humanize 的适配 鸿蒙Harmony 深度进阶 - 驾驭多语言复数逻辑算法、实现鸿蒙端中式大额单位感知与极致人性化文本渲染方案

Flutter 组件 humanize 的适配 鸿蒙Harmony 深度进阶 - 驾驭多语言复数逻辑算法、实现鸿蒙端中式大额单位感知与极致人性化文本渲染方案

欢迎加入开源鸿蒙跨平台社区:https://openharmonycrossplatform.ZEEKLOG.net Flutter 组件 humanize 的适配 鸿蒙Harmony 深度进阶 - 驾驭多语言复数逻辑算法、实现鸿蒙端中式大额单位感知与极致人性化文本渲染方案 前言 在前文我们掌握了 humanize 进行基础数据转换的方法。但在鸿蒙(OpenHarmony)面向全球市场的布局中,真正的技术挑战往往隐藏在极其琐碎的“语言表达”中。例如:在英文中我们说 1 items 是错误的,必须是 1 item 与 2 items;而在中文环境下,我们虽然没有复数形变,但却有“万、亿”这类独特的四位一级计数逻辑。 一个真正具备“高级感”的鸿蒙应用,不应在数据展示上显得僵硬且带有明显的机器翻译痕迹。 本文将作为 humanize 适配的进阶篇,带你攻克多语言复数(Pluralization)

By Ne0inhk
【数据结构与算法】链表超全分类!从结构入门到双向链表初始化实现

【数据结构与算法】链表超全分类!从结构入门到双向链表初始化实现

🔥小龙报:个人主页 🎬作者简介:C++研发,嵌入式,机器人等方向学习者 ❄️个人专栏:《C语言》《【初阶】数据结构与算法》 ✨ 永远相信美好的事情即将发生 文章目录 * 前言 * 一、链表的分类与说明 * 1.1 单向或者双向 * 1.2 带头或者不带头 * 1.3 循环或者不循环 * 二、双向链表 * 2.1 双向链表的定义 * 2.2 双向链表中哨兵位头节点的初始化 * 三、代码展现 * 3.1 List.h * 3.2 List.c * 3.3 test.c * 总结与每日励志 前言 链表是数据结构入门阶段的核心知识点,

By Ne0inhk

优选算法——链表

💁‍♂️个人主页:进击的荆棘 👇作者其它专栏: 《数据结构与算法》《算法》《C++起始之路》 相关题解 1.两数相加 算法思路(模拟): 两个链表都是逆序存储数字的,即两个链表的个位数、十位数等都已经对应,可以直接相加。在相加过程中,我们要注意是否产生进位,产生进位时需要将进位和链表数字一同相加。若产生进位的位置在链表底部,即答案位数比原链表位数长一位,还需要再new一个结点存储最高位。 /** * Definition for singly-linked list. * struct ListNode { * int val; * ListNode *next; * ListNode() : val(0), next(nullptr) {} * ListNode(int x) : val(x), next(nullptr) {} * ListNode(int x, ListNode *next) : val(

By Ne0inhk