前提条件
安装 JDK:
java -version
下载 RocketMQ 源码包及运行包:
RocketMQ 建议的运行环境至少需要 12G 内存。采用最新 5.3.4 版本,4.x 系列已停止维护。
安装 RocketMQ
将下载后的文件上传到 /app/rocketmq:
mkdir -p rocketmq
cd rocketmq/
解压文件:
unzip rocketmq-all-5.3.4-bin-release.zip
修改目录名:
mv rocketmq-all-5.3.4-bin-release/ rocketmq
配置 RocketMQ
修改启动脚本
修改 runserver.sh 脚本:
vi /app/rocketmq/rocketmq/bin/runserver.sh
调整参数(若机器内存足够可忽略),需修改 JDK 路径:
which java
修改 runbroker.sh 脚本:
vi /app/rocketmq/rocketmq/bin/runbroker.sh
调整参数,同样需确认 JDK 路径。
新增 broker.conf 配置信息
编辑配置文件:
vi /app/rocketmq/rocketmq/conf/broker.conf
内容如下:
namesrvAddr = localhost:9876
brokerIP1 = localhost
启动与关闭 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


