签到成功

知道了

CNDBA社区CNDBA社区

RocketMQ Dledger集群模式安装

2023-03-11 08:41 1064 0 原创 RocketMQ
作者： hbhe0316
本文链接：http://www.cndba.cn/hbhe0316/article/116483

192.168.56.100 Namesrv Server、RaftNode00-n0、RaftNode00-n1、RaftNode00-n2
192.168.56.101 Namesrv Server、RaftNode01-n0、RaftNode01-n1、RaftNode01-n2http://www.cndba.cn/hbhe0316/article/116483http://www.cndba.cn/hbhe0316/article/116483

1.修改brocker配置文件http://www.cndba.cn/hbhe0316/article/116483

[root@node01 dledger]# cd /opt/rocketmq/conf/dledger
[root@node01 dledger]# cat broker-n0.conf 
brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30911
namesrvAddr=node01:9876;node02:9876
storePathRootDir=/tmp/rmqstore/node00
storePathCommitLog=/tmp/rmqstore/node00/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
## must be unique
dLegerSelfId=n0
sendMessageThreadPoolNums=16

[root@node01 dledger]# cd /opt/rocketmq/conf/dledger
[root@node01 dledger]# cat broker-n1.conf 
brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30921
namesrvAddr=node01:9876;node02:9876
storePathRootDir=/tmp/rmqstore/node01
storePathCommitLog=/tmp/rmqstore/node01/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
## must be unique
dLegerSelfId=n1
sendMessageThreadPoolNums=16

[root@node01 dledger]# cd /opt/rocketmq/conf/dledger
[root@node01 dledger]# cat broker-n2.conf 
brokerClusterName = RaftCluster
brokerName=RaftNode00
listenPort=30931
namesrvAddr=node01:9876;node02:9876
storePathRootDir=/tmp/rmqstore/node02
storePathCommitLog=/tmp/rmqstore/node02/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode00
dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
## must be unique
dLegerSelfId=n2
sendMessageThreadPoolNums=16

参数解释
配置文件参数解释:
##n0-broker-n0.conf
#集群名称
brokerClusterName = RaftCluster
#broker集群名称
brokerName=RaftNode00
#brokerip
brokerIP1=192.168.56.100
#监听端口
listenPort=10911
#namesrv地址列表
namesrvAddr=192.168.56.100:9876;192.168.56.101:9876
#主题不存在时是否自动创建主题
autoCreateTopicEnable=false
#订阅组不存在时是否自动创建订阅组
autoCreateSubscriptionGroup=false
#数据存储根路径
storePathRootDir=/tmp/rmqstore/node00
#commitlog数据存储根路径
storePathCommitLog=/tmp/rmqstore/node00/commitlog
#broker检测队列中的消息等待时间（默认是200毫秒，自行配置）
waitTimeMillsInSendQueue=200
#是否启用DLeger集群模式
enableDLegerCommitLog=true
#与brokerName保持一致就好
dLegerGroup=RaftNode00
#dLeger集群下的节点配置
dLegerPeers=n0-192.168.56.100:40911;n1-192.168.56.100:40912;n2-192.168.56.100:40913
## must be unique
#当前节点在dLeger集群下的标识
dLegerSelfId=n0
#服务端处理消息发送线程池数量
sendMessageThreadPoolNums=16

2.启动node01节点

http://www.cndba.cn/hbhe0316/article/116483
http://www.cndba.cn/hbhe0316/article/116483http://www.cndba.cn/hbhe0316/article/116483

[root@node01 dledger]# cd /opt/rocketmq/bin/dledger
[root@node01 dledger]# ./fast-try.sh start
[root@node01 dledger]# jps 
24704 BrokerStartup
6075 NamesrvStartup
24700 BrokerStartup
24701 BrokerStartup
26350 Jps

3.修改Node02节点brocker文件http://www.cndba.cn/hbhe0316/article/116483

[root@node02 dledger]# cd /opt/rocketmq/conf/dledger
[root@node02 dledger]# cat broker-n0.conf 
brokerClusterName = RaftCluster
brokerName=RaftNode01
listenPort=30911
namesrvAddr=node01:9876;node02:9876
storePathRootDir=/tmp/rmqstore/node00
storePathCommitLog=/tmp/rmqstore/node00/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode01
dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
## must be unique
dLegerSelfId=n0
sendMessageThreadPoolNums=16

[root@node02 dledger]# cd /opt/rocketmq/conf/dledger
[root@node02 dledger]# cat broker-n1.conf 
brokerClusterName = RaftCluster
brokerName=RaftNode01
listenPort=30921
namesrvAddr=node01:9876;node02:9876
storePathRootDir=/tmp/rmqstore/node01
storePathCommitLog=/tmp/rmqstore/node01/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode01
dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
## must be unique
dLegerSelfId=n1
sendMessageThreadPoolNums=16

[root@node02 dledger]# cd /opt/rocketmq/conf/dledger
[root@node02 dledger]# cat broker-n2.conf 
brokerClusterName = RaftCluster
brokerName=RaftNode01
listenPort=30931
namesrvAddr=node01:9876;node02:9876
storePathRootDir=/tmp/rmqstore/node02
storePathCommitLog=/tmp/rmqstore/node02/commitlog
enableDLegerCommitLog=true
dLegerGroup=RaftNode01
dLegerPeers=n0-127.0.0.1:40911;n1-127.0.0.1:40912;n2-127.0.0.1:40913
## must be unique
dLegerSelfId=n2
sendMessageThreadPoolNums=16

4.启动node02节点brockerhttp://www.cndba.cn/hbhe0316/article/116483http://www.cndba.cn/hbhe0316/article/116483http://www.cndba.cn/hbhe0316/article/116483

[root@node02 dledger]# cd /opt/rocketmq/bin/dledger/
[root@node02 dledger]# ./fast-try.sh start
[root@node02 dledger]# jps
24657 Jps
6423 NamesrvStartup
23897 BrokerStartup
23898 BrokerStartup
23900 BrokerStartup

版权声明：本文为博主原创文章，未经博主允许不得转载。

RocketMQ

用户评论
* 以下用户言论只代表其个人观点，不代表CNDBA社区的观点或立场
hbhe0316

hbhe0316

关注

1.只有承认无知，才能装下新的东西； 2.进步来自一点点滴滴的积累； 3.广博让你更优秀，而专业让你无法替代； 4.挫折和失败能够转换为一种财富。

  • 889
    原创
  • 1
    翻译
  • 13
    转载
  • 24
    评论
  • 访问：1143027次
  • 积分：1523
  • 等级：核心会员
  • 排名：第6名
精华文章

    达梦数据库运维实战

    Oracle 18c 必须掌握的新特性：管理与实战

    Oracle数据库问题解决方案和故障排除手册
    最新问题
    查看更多+
    热门文章
      热门用户
      推荐用户
        友情链接： CNDBA社区 | openGauss | openEuler | openAnolis | 广告联系: database@ustc.edu
        Copyright © 2016 All Rights Reserved. Powered by CNDBA · 皖ICP备2022006297号-1·

        QQ交流群

        注册联系QQ