rocketmq集群2m-2s-async搭建

1.环境准备

ip地址                             角色
192.168.2.32                  nameserver  broker-a  broker-b-s 
192.168.2.35                  nameserver  broker-b  broker-a-s

console部署到2台中的任一台上

集群配置

第一台机器

修改broker-a.properties主要内容为如下:

namesrvAddr=192.168.2.32:8600;192.168.2.35:8600
#集群名称，主从要一样
brokerClusterName=ttparkCluster
#broker名称，主从要一样，根据BrokerRole来确定谁是主谁是从
brokerName=broker-a
#brokerID 0是主，>0是从
brokerId=0
#删除日志时间为凌晨4点
deleteWhen=04
#文件保留时间48小时
fileReservedTime=48
#主从关系，异步复制
brokerRole=ASYNC_MASTER
#刷盘模式，异步刷盘
flushDiskType=ASYNC_FLUSH
defaultTopicQueueNums=4
#存储路径
storePathRootDir=/data/rocketmq-a/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq-a/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq-a/store/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq-a/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq-a/store/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq-a/store/abort
listenPort=10911

修改broker-b-s.properties主要内容为如下:

namesrvAddr=192.168.2.32:8600;192.168.2.35:8600
#集群名称，主从要一样
brokerClusterName=ttparkCluster
#broker名称，主从要一样，根据BrokerRole来确定谁是主谁是从
brokerName=broker-b
#brokerID 0是主，>0是从
brokerId=1
#删除日志时间为凌晨4点
deleteWhen=04
#文件保留时间48小时
fileReservedTime=48
#主从关系，异步复制
brokerRole=SLAVE
#刷盘模式，异步刷盘
flushDiskType=ASYNC_FLUSH
defaultTopicQueueNums=4
#存储路径
storePathRootDir=/data/rocketmq-b/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq-b/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq-b/store/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq-b/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq-b/store/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq-b/store/abort
listenPort=10921

第二台机器

修改broker-b.properties主要内容为如下:

namesrvAddr=192.168.2.32:8600;192.168.2.35:8600
#集群名称，主从要一样
brokerClusterName=ttparkCluster
#broker名称，主从要一样，根据BrokerRole来确定谁是主谁是从
brokerName=broker-b
#brokerID 0是主，>0是从
brokerId=0
#删除日志时间为凌晨4点
deleteWhen=04
#文件保留时间48小时
fileReservedTime=48
#主从关系，异步复制
brokerRole=ASYNC_MASTER
#刷盘模式，异步刷盘
flushDiskType=ASYNC_FLUSH
defaultTopicQueueNums=4
#存储路径
storePathRootDir=/data/rocketmq-b/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq-b/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq-b/store/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq-b/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq-b/store/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq-b/store/abort
listenPort=10911

修改broker-a-s.properties主要内容为如下:

namesrvAddr=192.168.2.32:8600;192.168.2.35:8600
#集群名称，主从要一样
brokerClusterName=ttparkCluster
#broker名称，主从要一样，根据BrokerRole来确定谁是主谁是从
brokerName=broker-a
#brokerID 0是主，>0是从
brokerId=1
#删除日志时间为凌晨4点
deleteWhen=04
#文件保留时间48小时
fileReservedTime=48
#主从关系，异步复制
brokerRole=SLAVE
#刷盘模式，异步刷盘
flushDiskType=ASYNC_FLUSH
defaultTopicQueueNums=4
#存储路径
storePathRootDir=/data/rocketmq-a/store
#commitLog 存储路径
storePathCommitLog=/data/rocketmq-a/store/commitlog
#消费队列存储路径存储路径
storePathConsumeQueue=/data/rocketmq-a/store/consumequeue
#消息索引存储路径
storePathIndex=/data/rocketmq-a/store/index
#checkpoint 文件存储路径
storeCheckpoint=/data/rocketmq-a/store/checkpoint
#abort 文件存储路径
abortFile=/data/rocketmq-a/store/abort
listenPort=10921

启动

创建commitLog,队列,日志等的存储路径

mkdir commitlog consumequeue index

启动第一台机器的nameserver

nohup sh bin/mqnamesrv -c conf/namesrv.properties &

启动第二台机器的nameserver

nohup sh bin/mqnamesrv -c conf/namesrv.properties &

启动broker-a

nohup bin/mqbroker -c conf/2m-2s-async/broker-a.properties &

启动broker-b

nohup bin/mqbroker -c conf/2m-2s-async/broker-b.properties &

启动broker-a-s

nohup bin/mqbroker -c conf/2m-2s-async/broker-a-s.properties &

启动broker-b-s

nohup bin/mqbroker -c conf/2m-2s-async/broker-b-s.properties &

查看集群的启动状况

[root@base-master bin]# ./mqadmin clusterList -n 192.168.2.32:8600
#Cluster Name     #Broker Name            #BID  #Addr                  #Version                #InTPS(LOAD)       #OutTPS(LOAD) #PCWait(ms) #Hour #SPACE
ttparkCluster     broker-a                0     192.168.2.32:10911     V4_4_0                   0.00(0,0ms)         0.00(0,0ms)          0 444721.04 0.1022
ttparkCluster     broker-a                1     192.168.2.35:10921     V4_4_0                   0.00(0,0ms)         0.00(0,0ms)          0 444721.04 0.0586
ttparkCluster     broker-b                0     192.168.2.35:10911     V4_4_0                   0.00(0,0ms)         0.00(0,0ms)          0 444721.04 0.0586
ttparkCluster     broker-b                1     192.168.2.32:10921     V4_4_0                   0.00(0,0ms)         0.00(0,0ms)          0 444721.04 0.1022