1. 下载
官网:http://rocketmq.apache.org/
下载最新版本:https://rocketmq.apache.org/release-notes/2023/09/22/5.1.4
将最新的二进制安装包放到Centos服务器上。
或者:
| 12
 
 | cd /usr/local/toolswget https://mirror.bit.edu.cn/apache/rocketmq/5.1.4/rocketmq-all-5.1.4-bin-release.zip
 
 | 

解压
解压二进制包,修改文件夹名称
| 12
 
 | unzip rocketmq-all-5.1.4-bin-release.zipmv rocketmq-all-5.1.4-bin-release rocketmq
 
 | 
创建目录
| 1
 | mkdir -p /usr/local/tools/rocketmq/store/broker-a /usr/local/tools/rocketmq/store/broker-a/consumequeue /usr/local/soft/rocketmq/store/broker-a/commitlog /usr/local/soft/rocketmq/store/broker-a/index /usr/local/tools/rocketmq/broker-a/logs 
 | 
修改配置文件
| 12
 
 | cd /usr/local/tools/rocketmq/confvim broker.conf
 
 | 
增加内容:
| 12
 3
 4
 5
 6
 7
 8
 9
 10
 11
 12
 13
 14
 15
 16
 17
 18
 19
 20
 
 | listenPort=10911
 
 autoCreateTopicEnable=true
 
 autoCreateSubscriptionGroup=true
 
 namesrvAddr=localhost:9876
 
 storePathRootDir=/usr/local/tools/rocketmq/store/broker-a
 
 storePathCommitLog=/usr/local/tools/rocketmq/store/broker-a/commitlog
 
 storePathConsumeQueue=/usr/local/tools/rocketmq/store/broker-a/consumequeue
 
 storePathIndex=/usr/local/tools/rocketmq/store/broker-a/index
 
 storeCheckpoint=/usr/local/tools/rocketmq/store/broker-a/checkpoint
 
 abortFile=/usr/local/tools/rocketmq/store/broker-a/abort
 
 | 
在虚拟机有可能因为内存不够而启动失败, 修改bin目录下的runbroker.sh和runserver.sh文件,比如把8g改成512m,4g改成256m


启动
依次启动nameserver和broker,这两个命令可以做成alias
| 12
 3
 
 | cd /usr/local/tools/rocketmq/binnohup sh mqnamesrv &
 nohup sh ./mqbroker -c /usr/local/tools/rocketmq/conf/broker.conf &
 
 | 
查看日志
启动成功后查看mq动态日志
| 12
 
 | tail -f ~/logs/rocketmqlogs/namesrv.logtail -f ~/logs/rocketmqlogs/broker.log
 
 | 
关闭服务
| 12
 3
 
 | cd /usr/local/tools/rocketmq/binsh mqshutdown namesrv
 sh mqshutdown broker
 
 |