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.sh
和 bin/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