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







本文标签: rocketmq dledger模式 配置

内容版权声明:【蓝色网居】部分资源来源于网络,如有侵犯您的所有权,请随时告知我们,我们将立即删除!感谢配合!

转载请注明出处:https://blog.ff56.cn/dashuju/1658126587.html


【手机扫一扫查看文本】

手机扫一扫 手机扫一扫查看文本 手机扫一扫





单机多实例 zookeeper3.5 dledger模式 kafka2.5 日志系统 rocketmq ELK6.0 配置 集群配置