rocketmq之dledger模式配置


概述:操作环境,3台机器,3broker + 2nameserver + 1adminconsle ,dledger模式,相当于1主两从。 保障高可用性。



rcmq路径:/usr/local/rcmq/rcmq-48dledger/



配置文件:
conf/dledger/broker-n0.conf
conf/dledger/broker-n1.conf
conf/dledger/broker-n2.conf


节点分布:
n0-172.11.84.248:40911; broker、namesrv
n1-172.11.84.247:40921; broker、namesrv
n2-172.11.85.0:40931; broker、adminconsole


节点一具体配置内容:

[root@mq-01 dledger]# more broker-n0.conf
brokerClusterName = rcmqprddle
brokerName=RaftNode00
brokerId=0

namesrvAddr=172.11.84.248:9876;172.11.84.247:9876
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true

listenPort=30911
deleteWhen=04
fileReservedTime=48
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
diskMaxUsedSpaceRatio=88
maxTransferBytesOnMessageInMemory=2097152
maxTransferCountOnMessageInMemory=256
maxTransferBytesOnMessageInDisk=262144
maxTransferCountOnMessageInDisk=64
storePathRootDir=/rcmqdata01/rmqstore/node00
storePathCommitLog=/rcmqdata01/rmqstore/node00/commitlog
#storePathRootDir=/rcmqdata1/rmqstore/node00
#storePathCommitLog=/rcmqdata1/rmqstore/node00/commitlog

maxMessageSize=65536
sendMessageThreadPoolNums=64
useReentrantLockWhenPutMessage=true
waitTimeMillsInSendQueue=350

enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-172.11.84.248:40911;n1-172.11.84.247:40921;n2-172.11.85.0:40931
## must be unique
dLegerSelfId=n0
#sendMessageThreadPoolNums=4




节点二具体配置内容:

[root@mq-02 dledger]# more broker-n1.conf
brokerClusterName = rcmqprddle
brokerName=RaftNode00

namesrvAddr=172.11.84.248:9876;172.11.84.247:9876
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true

listenPort=30921
deleteWhen=04
fileReservedTime=48
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
diskMaxUsedSpaceRatio=88
maxTransferBytesOnMessageInMemory=2097152
maxTransferCountOnMessageInMemory=256
maxTransferBytesOnMessageInDisk=262144
maxTransferCountOnMessageInDisk=64
storePathRootDir=/rcmqdata01/rmqstore/node00
storePathCommitLog=/rcmqdata01/rmqstore/node00/commitlog
#storePathRootDir=/rcmqdata1/rmqstore/node00
#storePathCommitLog=/rcmqdata1/rmqstore/node00/commitlog

maxMessageSize=65536
sendMessageThreadPoolNums=64
useReentrantLockWhenPutMessage=true
waitTimeMillsInSendQueue=350

enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-172.11.84.248:40911;n1-172.11.84.247:40921;n2-172.11.85.0:40931
dLegerSelfId=n1
#sendMessageThreadPoolNums=4




节点三具体配置内容:

[root@mq-03 dledger]# more broker-n2.conf
brokerClusterName = rcmqprddle
brokerName=RaftNode00

namesrvAddr=172.11.84.248:9876;172.11.84.247:9876
defaultTopicQueueNums=4
autoCreateTopicEnable=true
autoCreateSubscriptionGroup=true

listenPort=30931
deleteWhen=04
fileReservedTime=48
mapedFileSizeCommitLog=1073741824
mapedFileSizeConsumeQueue=300000
diskMaxUsedSpaceRatio=88
maxTransferBytesOnMessageInMemory=2097152
maxTransferCountOnMessageInMemory=256
maxTransferBytesOnMessageInDisk=262144
maxTransferCountOnMessageInDisk=64
storePathRootDir=/rcmqdata02/rmqstore/node00
storePathCommitLog=/rcmqdata02/rmqstore/node00/commitlog
#storePathRootDir=/rcmqdata2/rmqstore/node00
#storePathCommitLog=/rcmqdata2/rmqstore/node00/commitlog

maxMessageSize=65536
sendMessageThreadPoolNums=64
useReentrantLockWhenPutMessage=true
waitTimeMillsInSendQueue=350

enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-172.11.84.248:40911;n1-172.11.84.247:40921;n2-172.11.85.0:40931
dLegerSelfId=n2
#sendMessageThreadPoolNums=4




分别启动2个nameserver节点:
#cd /usr/local/rcmq/rcmq-48dledger/
#nohup sh bin/mqnamesrv > ./logs/namesrv.log 2>&1 &


分别启动3个broker节点:
#nohup sh bin/mqbroker -c conf/dledger/broker-n0.conf > ./logs/broker-n0.log 2>&1 &

#nohup sh bin/mqbroker -c conf/dledger/broker-n1.conf > ./logs/broker-n1.log 2>&1 &

#nohup sh bin/mqbroker -c conf/dledger/broker-n2.conf > ./logs/broker-n2.log 2>&1 &


启动管理后台(去github上拿文件进行编译):
#nohup java -jar rocketmq-console-ng-2.0.0.jar --rocketmq.config.namesrvAddr=172.11.84.247:9876 > rcmqadmin.log 2>&1 &


关于内存调整(根据实际比例调整):
runbroker.sh : JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g"
runserver.sh : JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"


关于停止服务:
#./bin/mqshutdown broker
#./bin/mqshutdown namesrv



源于:https://blog.ff56.cn/dashuju/1658126587.html

发表评论
留言与评论(共有 0 条评论) “”
   
验证码:

相关文章

推荐文章