前置条件
安装好java环境
下载、上传、解压
下载二进制包 传送门
上传到服务器,这里上传到了/usr/local
目录下
解压:
unzip rocketmq-all-4.9.4-bin-release.zip
移动到新的文件夹
mv /rocketmq-all-4.9.4-bin-release /rocketmq
修改配置
修改conf
下的broker.conf
,追加
storePathRootDir=/data/rocketmq/rootdir-a-m
storePathCommitLog=/data/rocketmq/commitlog-a-m
autoCreateSubscriptionGroup=true
traceTopicEnable=true
listenPort=10911
#必须配置
namesrvAddr=ip1:9876
brokerIP1=ip2
其中ip1为服务器的外网地址,ip2为本机的地址,格式类似192.168.12.12
修改启动内存大小
进入bin
目录
修改runbroker.sh
文件
修改runserver.sh
文件
如果出现错误
Please set the JAVA_HOME variable in your environment, We need java(x64)!
修改对应sh文件的
启动
nohup sh mqnamesrv -n 59.110.105.152:9876 &
tail -f ~/logs/rocketmqlogs/namesrv.log
我们可以在namesrv.log 中看到 ‘The Name Server boot success…’, 表示NameServer 已成功启动。
nohup sh mqbroker -c ../conf/broker.conf -n 59.110.105.152:9876 autoCreateTopicEnable=true &
tail -f ~/logs/rocketmqlogs/broker.log
我们可以在 Broker.log 中看到“The broker[brokerName,ip:port] boot success…”,这表明 broker 已成功启动。
查看jps进程
启动成功
参考链接
https://rocketmq.apache.org/zh/docs/4.x/introduction/02quickstart
https://blog.csdn.net/weixin_44919041/article/details/123547869