RocketMQ集群搭建(两主两从)总结

RocketMQ集群搭建(两主两从)

参考文章
搭建部署流程:https://www.jianshu.com/p/22235f54724f

graph LR
创建日志保存目录-->启动mqnamesrv  
启动mqnamesrv-->启动mqbroker   
启动mqbroker-->启动控制台

配置修改:

1. 修改broker-a.properties配置

#配置文件目录
/app/mid/rocketmq/conf/2m-2s-sync

配置文件内容:

#A主节点配置
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=10.249.2.6:9876;10.249.2.76:9876;10.249.2.118:9876
waitTimeMillsInSendQueue=3000
osPageCacheBusyTimeOutMills=5000  

#B主节点配置
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=0
deleteWhen=04
fileReservedTime=48
brokerRole=SYNC_MASTER
flushDiskType=ASYNC_FLUSH
namesrvAddr=10.249.2.6:9876;10.249.2.76:9876;10.249.2.118:9876
waitTimeMillsInSendQueue=3000
osPageCacheBusyTimeOutMills=5000

#A从节点配置
brokerClusterName=DefaultCluster
brokerName=broker-a
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=10.249.2.6:9876;10.249.2.76:9876;10.249.2.118:9876

waitTimeMillsInSendQueue=3000
osPageCacheBusyTimeOutMills=5000  

#B从节点配置
brokerClusterName=DefaultCluster
brokerName=broker-b
brokerId=1
deleteWhen=04
fileReservedTime=48
brokerRole=SLAVE
flushDiskType=ASYNC_FLUSH
namesrvAddr=10.249.2.6:9876;10.249.2.76:9876;10.249.2.118:9876

waitTimeMillsInSendQueue=3000
osPageCacheBusyTimeOutMills=5000

注意点:

brokerRole  #注意主从角色的设置
namesrvAddr #配置自己服务器地址  
brokerId=1  #从节点ID必须大于0
brokerName  #brokerName=broker-b主从节点名称必须一致，不然会返回找不到从节点的状态

2. 修改控制台启动配置修改

#修改配置文件中mqnamesr地址
application.properties

服务启动流程

#创建日志保存目录
mkdir -p /data/logs/rocketmqlogs

#启动四台mqnamesrv
cd /app/mid/rocketmq/bin/
nohup sh mqnamesrv > /data/logs/rocketmqlogs/mqnamesrv.log 2>&1 & 

#查看日否启动成功
ps -ef|grep mqnamesrv

#分别启动四台mqbroker
cd /app/mid/rocketmq/bin/
nohup sh mqbroker -c ../conf/2m-2s-sync/broker-a.properties > /data/logs/rocketmqlogs/broker-a.log 2>&1 &
nohup sh mqbroker -c ../conf/2m-2s-sync/broker-b.properties > /data/logs/rocketmqlogs/broker-b.log 2>&1 &
nohup sh mqbroker -c ../conf/2m-2s-sync/broker-a-s.properties > /data/logs/rocketmqlogs/broker-a-s.log 2>&1 &
nohup sh mqbroker -c ../conf/2m-2s-sync/broker-b-s.properties > /data/logs/rocketmqlogs/broker-b-s.log 2>&1 &
#查看mqbroker是否启动成功
ps -ef|grep mqbroker

#启动控制台  
/app/mid/rocketmq/rocketmq-console  
nohup java -jar rocketmq-console-ng-1.0.1.jar &

服务器启动结果

启动mqnamesrv结果

启动mqbroker结果

控制台修改

最终结果
浏览器输入访问地址和端口8080

注意点:

 vim bin/runbroker.sh

// 根据机器实际内存调整，这里演示的机器内存比较小，配置的值比较小

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
# vim bin/runserver.sh

// 根据机器实际内存调整，这里演示的机器内存比较小，配置的值比较小

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
# vim bin/tools.sh

// 根据机器实际内存调整，这里演示的机器内存比较小，配置的值比较小

JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn256m -XX:PermSize=128m -XX:MaxPermSize=128m"