Linux分布式消息队列RocketMQ部署与监控–双Master

# tar zxf alibaba-rocketmq-3.2.4-beta1.tar.gz -C /usr/local/
# cd /usr/local/
# ln -s /usr/local/alibaba-rocketmq /usr/local/rocketmq
# cd rocketmq/

# hostname 
# vim conf/2m-noslave/broker-a.properties

1 #####################Master1 服务器配置文件 #####################    
 2 brokerClusterName=FusionCluster    
 3 brokerName=broker-a    
 4 brokerId=0    
 5 namesrvAddr=dbTest249:9876;webTest251:9876    
 6 deleteWhen=04    
 7 fileReservedTime=120    
 8 
 9 brokerRole=ASYNC_MASTER    
10 flushDiskType=ASYNC_FLUSH    
11 sstorePathRootDir=/data/rocketmq/store    
12 storePathCommitLog=/data/rocketmq/store/commitlog

1 #####################Master2 服务器配置文件 #####################    
 2 brokerClusterName=FusionCluster    
 3 brokerName=broker-b    
 4 brokerId=1    
 5 namesrvAddr=dbTest249:9876;webTest251:9876    
 6 deleteWhen=04    
 7 fileReservedTime=120    
 8 
 9 brokerRole=ASYNC_MASTER    
10 flushDiskType=ASYNC_FLUSH    
11 listenPort=10911 
12 sstorePathRootDir=/data/rocketmq/store    
13 storePathCommitLog=/data/rocketmq/store/commitlog

# vim bin/runbroker.sh

1 JAVA_OPT_1="-server -Xms512m -Xmx1g -XX:PermSize=128m -XX:MaxPermSize=320m"

# mkdir -p /data/rocketmq/store/commitlog
# mkdir /data/logs
# cd conf/
# sed -i 's#${user.home}#/data#g' *.xml      // 将 conf 目录下所有 xml 文件中的 ${user.home} 替换成 /data, 进入 rocketmq/conf 目录下执行该命令 

# cd ../bin/
# nohup sh mqnamesrv >/var/log/ns.log &
# nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties > /var/log/mq.log 2>&1 &

# tail -f /var/log/ns.log 
# tail -f /var/log/mq.log

# netstat -tunpl
# jps
# kill -9 22596
# kill -9 22564
# kill -9 9967
# netstat -tunpl
# netstat -tunpl |grep java

# sh mqshutdown

1 Useage: mqshutdown broker | namesrv

# sh mqshutdown broker
# sh mqshutdown namesrv

# nohup sh mqnamesrv >/var/log/ns.log &
# nohup sh mqbroker -c ../conf/2m-noslave/broker-a.properties > /var/log/mq.log 2>&1 &

# jps