当前位置: 首页 > news >正文

Centos9安装rocketmq

准备工作

安装 Java 环境:RocketMQ 需要 Java 运行环境(JDK 1.8 或更高版本)。

sudo dnf install -y java-17-openjdk-devel  # 或者 java-1.8.0-openjdk-devel
java -version  # 验证安装

防火墙配置:如果系统防火墙开启,需开放 RocketMQ 相关端口。

sudo firewall-cmd --permanent --add-port=9876/tcp  # Nameserver 默认端口
sudo firewall-cmd --permanent --add-port=10909/tcp --add-port=10911/tcp  # Broker 默认端口
sudo firewall-cmd --reload
# 如需后续使用控制台,还需开放其端口(如 8080)

二进制包安装(推荐用于生产环境)

下载并解压 RocketMQ: 访问 RocketMQ 下载页面 获取最新的二进制包下载链接。

wget https://archive.apache.org/dist/rocketmq/5.0.0/rocketmq-all-5.0.0-bin-release.zip  # 请替换为最新版本
unzip rocketmq-all-5.0.0-bin-release.zip
cd rocketmq-all-5.0.0-bin-release

调整 JVM 堆内存参数(重要!): RocketMQ 默认配置的 JVM 堆内存较大(例如 4GB),如果你的服务器内存资源不充足,务必修改 bin/runserver.shbin/runbroker.sh 中的相关参数,以避免内存不足无法启动。

  • 修改 runserver.sh (NameServer 和 Broker 的启动脚本):

# 查找并修改 JAVA_OPT 中的 -Xms, -Xmx, -Xmn 等参数
# 例如,设置为 256m:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=256m"

修改 runbroker.sh (Broker 的启动脚本):

# 同样修改 JVM 堆内存参数,例如:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

配置 Broker: 编辑 conf/broker.conf 文件,根据你的网络环境进行关键配置:

# 设置 NameServer 的地址,如果有多个用分号分隔
namesrvAddr=localhost:9876
# 设置 Broker 对外服务的 IP 地址。如果客户端不在本机,需设置为服务器公网 IP 或内网 IP
brokerIP1=你的服务器IP
# 允许自动创建 Topic(通常建议开发环境开启,生产环境谨慎使用)
autoCreateTopicEnable=true

启动 NameServer 和 Broker

启动 NameServer

# 先创建logs/namesrv.log,然后授权chmod 777 logs/namesrv.log,然后在启动mqnamesrv
nohup sh bin/mqnamesrv >> logs/namesrv.log 2>&1 &
tail -f logs/namesrv.log  # 查看日志,确认 "The Name Server boot success"

启动 Broker(指定配置文件):

# 先创建logs/broker.log,然后授权chmod 777 logs/broker.log,然后在启动mqbroker
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf >> logs/broker.log 2>&1 &
tail -f logs/broker.log  # 查看日志,确认 "The broker[...] boot success"

注意:如果 Broker 无法连接到 NameServer 或客户端无法连接 Broker,请务必检查 broker.conf 中的 brokerIP1 和防火墙设置

测试消息发送与消费: RocketMQ 提供了简单的测试工具。

# 设置 NameServer 地址环境变量
export NAMESRV_ADDR=localhost:9876
​
# 测试消息发送
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# 你应该能看到发送成功的日志
​
# 测试消息消费
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
# 你应该能看到消费到的消息

停止服务

sh bin/mqshutdown broker
sh bin/mqshutdown namesrv


文章转载自:

http://3yF7zIsv.rhjsx.cn
http://WrQrzzVL.rhjsx.cn
http://7AqXLJGD.rhjsx.cn
http://GKjwWZU1.rhjsx.cn
http://6ZscED2i.rhjsx.cn
http://UbRlmaxe.rhjsx.cn
http://N3Zqpp6g.rhjsx.cn
http://EG8xeEIO.rhjsx.cn
http://XaDpLEeS.rhjsx.cn
http://GbDahT29.rhjsx.cn
http://hqkfo1u5.rhjsx.cn
http://A6InPFwO.rhjsx.cn
http://qtbKGixf.rhjsx.cn
http://g2e2KEGc.rhjsx.cn
http://yr6q19GV.rhjsx.cn
http://MxYEjIyg.rhjsx.cn
http://2CU0GrCX.rhjsx.cn
http://sUKNoLJe.rhjsx.cn
http://irlw21NG.rhjsx.cn
http://oy1Q52zs.rhjsx.cn
http://hXYVPq1p.rhjsx.cn
http://0aG7iBGB.rhjsx.cn
http://MYfdFUuf.rhjsx.cn
http://EBO0Q281.rhjsx.cn
http://ID5xrJNU.rhjsx.cn
http://LY7dMccs.rhjsx.cn
http://u9IM1ieq.rhjsx.cn
http://XOqUxb7w.rhjsx.cn
http://SN4pnglS.rhjsx.cn
http://3yAPPIXe.rhjsx.cn
http://www.dtcms.com/a/374075.html

相关文章:

  • Docker | 一种使用 docker-compose 命令将 YAML 定义的配置文件导入到 Docker 的方法
  • 编译器构造:模拟器,汇编与反汇编
  • 自由学习记录(96)
  • Cy5-Tyramide, Cyanine 5 Tyramide;1431148-26-3
  • JMeter接口测试全流程解析
  • ARM处理器的小常识
  • Go语言极速入门与精要指南从零到精通的系统化学习路径
  • RK3576 android14 usb_audio_policy_configuration.xml解析
  • 本地安装部署svn服务,并设置外网远程访问内网svn,含路由器转发和端口映射工具教程
  • idea2025构建springboot项目能运行的样例
  • 【底层机制】std::unordered_map 扩容机制
  • Cpp::STL—位图bitset的使用与模拟实现(39)
  • 链表 (C/C++)
  • WinEdt编译tex文件失败解决办法
  • C语言第12讲
  • commons-email
  • (堆)347. 前 K 个高频元素
  • GitHub Release Monitor部署指南:实时追踪开源项目更新与自动通知
  • 重新定义音频编程:SoundFlow如何以模块化设计革新.NET音频开发生态
  • SQL 注入与防御-第八章:代码层防御
  • Miniflux 安全升级:绑定域名并开启 HTTPS
  • 标准 HTTP 状态码详解
  • STM32开发(创建工程)
  • MFC 图形设备接口详解:小白从入门到掌握
  • APM32芯得 EP.34 | 告别I2C“假死”——APM32F103硬件IIC防锁死设计
  • n8n入门
  • 静态住宅IP的特点
  • 数智之光燃盛景 共同富裕创丰饶
  • colmap+pycolmap带cuda编译
  • Nano-Bananary 搭建 使用 nano banana