RocketMQ4.5.1搭建主从

配置

NameServer：3台机器

Broker：3台机器

机器IP：192.168.6.128，192.168.6.130，192.168.6.131

构建RocketMQ

下载地址

构建命令
之后在rocketmq-all-4.5.1\distribution\target目录下找到压缩包，上传到服务器

部署

以128服务器为例

• 修改配置文件

  runbroker.sh和runserver.sh文件中堆配置都修改为1g(根据自己机器动态配置)

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g -Xmn1g"

• 创建数据存储目录

  (在服务器130为xxx/node01，131为xxx/node02文件目录和名称根据自己需要修改)

/usr/local/rocketmq-4.5.1/store/node00

• 修改broker启动文件

  目录地址：/usr/local/rocketmq-4.5.1/conf/dledger/broker-n0.conf(在服务器130上为broker-n1.conf，131为broker-n0.conf)

#集群名称，整个broker集群都用这个名称
brokerClusterName = RaftCluster
#Broker的名称，Master和它Slave的Broker名称必须一样
brokerName=RaftNode00
#Broker监听的端口号
listenPort=30911
#NameServer的地址
namesrvAddr=192.168.6.128:9876;192.168.6.130:9876;192.168.6.131:9876
#存放Broker数据的地方
storePathRootDir=/usr/local/rocketmq-4.5.1/store/node00
storePathCommitLog=/usr/local/rocketmq-4.5.1/store/node00/commitlog
#是否启用DLeger技术
enableDLegerCommitLog=true
#建议和Broker名字保持一致
dLegerGroup=RaftNode00
#DLedgerGroup内各节点的端口信息，同一个Group内的各个节点配置必须要保证一致
dLegerPeers=n0-192.168.6.128:40911;n1-192.168.6.130:40912;n2-192.168.6.131:40913
#节点id, 必须属于dLegerPeers中的一个；同Group内各个节点要唯一
dLegerSelfId=n0 #注意：服务器不同这里的配置也不一样
#发送线程个数，建议配置成Cpu核数
sendMessageThreadPoolNums=16

• 启动nameserver

nohup sh bin/mqnamesrv &

• 启动broker

nohup sh bin/mqbroker -c conf/dledger/xxx-n0.conf &
nohup sh bin/mqbroker -c conf/dledger/xxx-n1.conf &
nohup sh bin/mqbroker -c conf/dledger/xxx-n2.conf &

查看结果

在128服务器上执行

sh mqadmin clusterList -n 192.168.6.128:9876

部署结果