rocketmq集群搭建

server/2024/10/18 16:50:47/

1准备机器

rocketmq1 192.168.88.21

rocketmq2 192.168.88.22

下载rockermq网址：下载 | RocketMQ (apache.org)

下载java 1.8.0及以上版本

2m-2s-async 2主2从异步复制

2m-noslave 2主无从

2m-2s-sync 2主2从同步复制

本次实验采用 2主2从异步复制，rocketmq1 充当master1和slave2，rocketmq2充当master2和slave1

rocketmq2配置中间2个

以下是配置参考

2.安装rocketmq

解压 tar -xf rocketmq-all-4.9.0-bin-release.zip

cd rocketmq-all-4.9.0-bin-release/bin

1.修改runbroker.sh和runserver.sh

vim +82 runserver.sh
修改为：
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"vim +67 runbroker.sh
修改为：
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

2修改集群配置文件

#rocketmq1,配置文件
#broker-a.properties
vim /root/rocketmq-all-4.9.0-bin-release/conf/2m-2s-async/broker-a.propertiesbrokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.88.21:9876;192.168.88.22:9876#broker-b-s.properties
vim /root/rocketmq-all-4.9.0-bin-release/conf/2m-2s-async/broker-b-s.propertiesbrokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.88.21:9876;192.168.88.22:9876
listenport=11911
storePathRootDir=~/store-s
storePathCommitLog=~/store-s/commitlog
storePathConsumeQueue=~/store-s/consumequeue 
storePathIndex=~/store-s/indes
storecheckpoint=~/store-s/checkpoint 
abortFile=~/store-s/abort

#rocketmqos2配置文件
#broker-b.properties 
vim /root/rocketmq-all-4.9.0-bin-release/conf/2m-2s-async/broker-b.properties brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=ASYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.88.21:9876;192.168.88.22:9876#broker-a-s.properties
vim /root/rocketmq-all-4.9.0-bin-release/conf/2m-2s-async/broker-a-s.propertiesbrokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=192.168.88.21:9876;192.168.88.22:9876
listenport=11911
storePathRootDir=~/store-s
storePathCommitLog=~/store-s/commitlog
storePathConsumeQueue=~/store-s/consumequeue
storePathIndex=~/store-s/indes
storecheckpoint=~/store-s/checkpoint
abortFile=~/store-s/abort

3启动nameserver

#启动nameserver并放入后台执行nohup sh bin/mqnamesrv &tail -f ~/logs/rocketmqlogs/namesrv.log ...
2024-04-21 10:47:11 INFO main - The Name Server boot success. serializeType=JSON
.....

4启动broker

#rocketmqos1 启动master1
nohup sh bin/mqbroker  -c conf/2m-2s-async/broker-a.properties &#rocketmqos2 启动master2
nohup sh bin/mqbroker  -c conf/2m-2s-async/broker-b.properties &#rocketmqos1 启动slave2
nohup sh bin/mqbroker  -c conf/2m-2s-async/broker-b-s.properties &#rocketmqos2 启动slave1
nohup sh bin/mqbroker  -c conf/2m-2s-async/broker-a-s.properties &#查看启动日志是否成功
tail -f ~/logs/rocketmqlogs/broker.log #main - The broker[broker-a, 192.168.88.21:10911] boot success. serializeType=JSON and name server is 192.168.88.21:9876;192.168.88.22:9876