本文主要是介绍rocketmq集群部署DLedger Controller，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
目录
- rockermq集群部署DLedger Controller
- 到官网下载rockermq
- 集群模式：3切片主从
- 建目录
- 配置Nameserver
- 先修改内存
- 启动NameServer
- 停止NameServer
- 配置Broker
- 启动Broker
- 启动管制台直接docker 启动即可，修改 -e 后面 nameserver 参数即可
- 端口列表
- 导入
rockermq集群部署DLedger Controller
准备3台机器,IP分别是192.168.4.87，192.168.4.74，192.168.4.124
到官网下载rockermq
rocketmq-all-5.1.4-bin-release.zip
分别解压RockerMq到3台机器的/data/rockermq目录下
集群模式：3切片主从
先停止防火墙
用3组BrokerName
主从自动选择
| IP | BrokerName | 目录 | 说明 |
|---|---|---|---|
| 192.168.4.87 | RaftNode00 | rocketmq-a-s | A主 |
| 192.168.4.87 | RaftNode22 | rocketmq-c-s | C从 |
| 192.168.4.74 | RaftNode11 | rocketmq-b-s | B主 |
| 192.168.4.74 | RaftNode00 | rocketmq-a-s | A从 |
| 192.168.4.124 | RaftNode22 | rocketmq-c-m | C主 |
| 192.168.4.124 | RaftNode11 | rocketmq-b-c | B从 |
建目录
cd /data/rockermq/#192.168.4.87
mkdir -p rocketmq-nameserver/DledgerController
rm -rf rocketmq-a-m/store/
mkdir -p rocketmq-a-m/store/commitlog
mkdir -p rocketmq-a-m/store/consumequeue
rm -rf rocketmq-c-s/store/
mkdir -p rocketmq-c-s/store/commitlog
mkdir -p rocketmq-c-s/store/consumequeue#192.168.4.74
mkdir -p rocketmq-nameserver/DledgerController
rm -rf rocketmq-b-m/store/
mkdir -p rocketmq-b-m/store/commitlog
mkdir -p rocketmq-b-m/store/consumequeue
rm -rf rocketmq-a-s/store/
mkdir -p rocketmq-a-s/store/commitlog
mkdir -p rocketmq-a-s/store/consumequeue#192.168.4.124
mkdir -p rocketmq-nameserver/DledgerController
rm -rf rocketmq-c-m/store/
mkdir -p rocketmq-c-m/store/commitlog
mkdir -p rocketmq-c-m/store/consumequeue
rm -rf rocketmq-b-s/store/
mkdir -p rocketmq-b-s/store/commitlog
mkdir -p rocketmq-b-s/store/consumequeue
配置Nameserver
每台配置的controllerDLegerSelfId 分别是n0,n1,n2
87 vim rocketmq-nameserver/conf/nameserver.conf
#Namesrv config
listenPort = 9876
# Nameserver 中是否开启 controller，默认 false
enableControllerInNamesrv = true#controller config
# DLedger Raft Group 的名字，同一个 DLedger Raft Group 保持一致即可。
controllerDLegerGroup = group1
# DLedger Group 内各节点的端口信息，同一个 Group 内的各个节点配置必须要保证一致。
controllerDLegerPeers = n0-192.168.4.87:9873;n1-192.168.4.74:9873;n2-192.168.4.124:9873
# 节点 id，必须属于 controllerDLegerPeers 中的一个；同 Group 内各个节点要唯一。
controllerDLegerSelfId = n0
# controller 日志存储位置。controller 是有状态的，controller 重启或宕机需要依靠日志来恢复数据，该目录非常重要，不可以轻易删除。
controllerStorePath = /data/rocketmq/rocketmq-nameserver/DledgerController
enableElectUncleanMaster = false
notifyBrokerRoleChanged = true74 vim rocketmq-nameserver/conf/nameserver.conf
...
controllerDLegerSelfId = n1
...
124 vim rocketmq-nameserver/conf/nameserver.conf
...
controllerDLegerSelfId = n2
...
先修改内存
vim bin/runserver.sh
-server -Xms256m -Xmx1g -Xmn256mvim bin/runbroker.sh
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx1g"
启动NameServer
vim start_nameserver.sh
#!/bin/sh#cd `dirname $0`
#获取软连接的真实路径
DIR=`S=\`readlink "$0"\`; [ -z "$S" ] && S=$0; dirname $S`
cd "$DIR"echo `pwd`today=`date +"%Y%m%d"`
datetime=`date +"%Y%m%d%H%M%S"`#nohup sh bin/mqnamesrv > nohubNameserv &
nohup sh bin/mqnamesrv -c ./rocketmq-nameserver/conf/nameserver.conf > nohubNameserv.log & chmod +x ./start_nameserver.sh./start_nameserver.sh
日志如下：
(base) [root@server87 rocketmq]# tail -f nohubNameserv.log
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
load config properties file OK, ./rocketmq-nameserver/conf/nameserver.conf
The Name Server boot success. serializeType=JSON, address 0.0.0.0:9876
The ControllerManager boot success. serializeType=JSONNameServer和Controller已经启动成功
停止NameServer
vim ./stop_nameserver.sh
#!/bin/sh#cd `dirname $0`
#获取软连接的真实路径
DIR=`S=\`readlink "$0"\`; [ -z "$S" ] && S=$0; dirname $S`
cd "$DIR"echo `pwd`today=`date +"%Y%m%d"`
datetime=`date +"%Y%m%d%H%M%S"`sh bin/mqshutdown namesrvsh bin/mqshutdown controller配置Broker
注意配置：
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。在87
vim rocketmq-a-m/conf/broker.conf
## 集群名
brokerClusterName = RaftCluster
## broker组名，同一个RaftClusterGroup内，brokerName名要一样
brokerName=RaftNode00
#control可不用id和role
brokerId = 0
brokerRole = SLAVE## 监听的端口
listenPort=30911
## 你设置的NameServer地址和端口
namesrvAddr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876
#消息数据存放的根目录
storePathRootDir=/data/rocketmq/rocketmq-a-m/store
#commitlog保存目录
storePathCommitLog=/data/rocketmq/rocketmq-a-m/store/commitlog
#消费队列存储路径存储路径
#storePathConsumerQueue = /data/rocketmq/rocketmq-a-m/store/consumequeue
#enableDLegerCommitLog=true
dLegerGroup=RaftNode00
## n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
## 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
dLegerPeers=a0-192.168.4.87:9871;a1-192.168.4.74:9871
#dLegerPeers=a0-192.168.4.87:9871;a1-192.168.4.74:9871;a2-192.168.4.124:9871
## must be unique
## 这个值必须是在同一个RaftClusterGroup内唯一的
dLegerSelfId=a0
sendMessageThreadPoolNums=16
## 由于我的虚拟机配置了多个网卡，所以会绑定ip错误，因此我配置了这项，
#brokerIP1=192.168.161.11############################################ enableControllerMode：Broker controller 模式的总开关，只有该值为 true，自动主从切换模式才会打开。默认为 false。
enableControllerMode = true
# controllerAddr：controller 的地址，多个 controller 中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879
controllerAddr = 192.168.4.87:9873;192.168.4.74:9873;192.168.4.124:9873
# syncBrokerMetadataPeriod：向 controller 同步 Broker 副本信息的时间间隔。默认 5000（5s）。
syncBrokerMetadataPeriod = 5000
# checkSyncStateSetPeriod：检查 SyncStateSet 的时间间隔，检查 SyncStateSet 可能会 shrink SyncState。默认5000（5s）。
# syncControllerMetadataPeriod：同步 controller 元数据的时间间隔，主要是获取 active controller 的地址。默认10000（10s）。
# haMaxTimeSlaveNotCatchup：表示 Slave 没有跟上 Master 的最大时间间隔，若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000（15s）。
# storePathEpochFile：存储 epoch 文件的位置。epoch 文件非常重要，不可以随意删除。默认在 store 目录下。
storePathEpochFile = /data/rocketmq/rocketmq-a-m/store
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。
allAckInSyncStateSet=true
#syncFromLastFile：若 slave 是空盘启动，是否从最后一个文件进行复制。默认为 false。
#asyncLearner：若该值为 true，则该副本不会进入 SyncStateSet，也就是不会被选举成 Master，而是一直作为一个 learner 副本进行异步复制。默认为false。
#inSyncReplicas：需保持同步的副本组数量，默认为1，allAckInSyncStateSet=true 时该参数无效。
#minInSyncReplicas：最小需保持同步的副本组数量，若 SyncStateSet 中副本个数小于 minInSyncReplicas 则 putMessage 直接返回 PutMessageStatus.IN_SYNC_REPLICAS_NOT_ENOUGH，默认为1。在87
vim rocketmq-c-s/conf/broker.conf
## 集群名
brokerClusterName = RaftCluster
## broker组名，同一个RaftClusterGroup内，brokerName名要一样
brokerName=RaftNode22
## 监听的端口
listenPort=30915
## 你设置的NameServer地址和端口
namesrvAddr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876
#消息数据存放的根目录
storePathRootDir=/data/rocketmq/rocketmq-c-s/store
#commitlog保存目录
storePathCommitLog=/data/rocketmq/rocketmq-c-s/store/commitlog
#消费队列存储路径存储路径
#storePathConsumerQueue = /data/rocketmq/rocketmq-a-m/store/consumequeue
#enableDLegerCommitLog=true
dLegerGroup=RaftNode22
## n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
## 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
dLegerPeers=c0-192.168.4.87:9875;c2-192.168.4.124:9875
## must be unique
## 这个值必须是在同一个RaftClusterGroup内唯一的
dLegerSelfId=c0
sendMessageThreadPoolNums=16
## 由于我的虚拟机配置了多个网卡，所以会绑定ip错误，因此我配置了这项，
#brokerIP1=192.168.161.11############################################ enableControllerMode：Broker controller 模式的总开关，只有该值为 true，自动主从切换模式才会打开。默认为 false。
enableControllerMode = true
# controllerAddr：controller 的地址，多个 controller 中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879
controllerAddr = 192.168.4.87:9873;192.168.4.74:9873;192.168.4.124:9873
# syncBrokerMetadataPeriod：向 controller 同步 Broker 副本信息的时间间隔。默认 5000（5s）。
syncBrokerMetadataPeriod = 5000
# checkSyncStateSetPeriod：检查 SyncStateSet 的时间间隔，检查 SyncStateSet 可能会 shrink SyncState。默认5000（5s）。
# syncControllerMetadataPeriod：同步 controller 元数据的时间间隔，主要是获取 active controller 的地址。默认10000（10s）。
# haMaxTimeSlaveNotCatchup：表示 Slave 没有跟上 Master 的最大时间间隔，若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000（15s）。
# storePathEpochFile：存储 epoch 文件的位置。epoch 文件非常重要，不可以随意删除。默认在 store 目录下。
storePathEpochFile = /data/rocketmq/rocketmq-c-s/store
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。
allAckInSyncStateSet=true
#syncFromLastFile：若 slave 是空盘启动，是否从最后一个文件进行复制。默认为 false。
#asyncLearner：若该值为 true，则该副本不会进入 SyncStateSet，也就是不会被选举成 Master，而是一直作为一个 learner 副本进行异步复制。默认为false。
#inSyncReplicas：需保持同步的副本组数量，默认为1，allAckInSyncStateSet=true 时该参数无效。
#minInSyncReplicas：最小需保持同步的副本组数量，若 SyncStateSet 中副本个数小于 minInSyncReplicas 则 putMessage 直接返回 PutMessageStatus.IN_SYNC_REPLICAS_NOT_ENOUGH，默认为1。
在74
vim rocketmq-b-m/conf/broker.conf
## 集群名
brokerClusterName = RaftCluster
## broker组名，同一个RaftClusterGroup内，brokerName名要一样
brokerName=RaftNode11
brokerId = 1
brokerRole = SLAVE
## 监听的端口
listenPort=30911
## 你设置的NameServer地址和端口
namesrvAddr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876
#消息数据存放的根目录
storePathRootDir=/data/rocketmq/rocketmq-b-m/store
#commitlog保存目录
storePathCommitLog=/data/rocketmq/rocketmq-b-m/store/commitlog
#消费队列存储路径存储路径
#storePathConsumerQueue = /data/rocketmq/rocketmq-b-m/store/consumequeue
#enableDLegerCommitLog=true
dLegerGroup=RaftNode11
## n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
## 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
dLegerPeers=b1-192.168.4.74:9874;b2-192.168.4.124:9874
#dLegerPeers=a0-192.168.4.87:9871;a1-192.168.4.74:9871;a2-192.168.4.124:9871
## must be unique
## 这个值必须是在同一个RaftClusterGroup内唯一的
dLegerSelfId=b1
sendMessageThreadPoolNums=16
## 由于我的虚拟机配置了多个网卡，所以会绑定ip错误，因此我配置了这项，
#brokerIP1=192.168.161.11############################################ enableControllerMode：Broker controller 模式的总开关，只有该值为 true，自动主从切换模式才会打开。默认为 false。
enableControllerMode = true
# controllerAddr：controller 的地址，多个 controller 中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879
controllerAddr = 192.168.4.87:9873;192.168.4.74:9873;192.168.4.124:9873
# syncBrokerMetadataPeriod：向 controller 同步 Broker 副本信息的时间间隔。默认 5000（5s）。
syncBrokerMetadataPeriod = 5000
# checkSyncStateSetPeriod：检查 SyncStateSet 的时间间隔，检查 SyncStateSet 可能会 shrink SyncState。默认5000（5s）。
# syncControllerMetadataPeriod：同步 controller 元数据的时间间隔，主要是获取 active controller 的地址。默认10000（10s）。
# haMaxTimeSlaveNotCatchup：表示 Slave 没有跟上 Master 的最大时间间隔，若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000（15s）。
# storePathEpochFile：存储 epoch 文件的位置。epoch 文件非常重要，不可以随意删除。默认在 store 目录下。
storePathEpochFile = /data/rocketmq/rocketmq-b-m/store
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。
allAckInSyncStateSet=true
#syncFromLastFile：若 slave 是空盘启动，是否从最后一个文件进行复制。默认为 false。
#asyncLearner：若该值为 true，则该副本不会进入 SyncStateSet，也就是不会被选举成 Master，而是一直作为一个 learner 副本进行异步复制。默认为false。
#inSyncReplicas：需保持同步的副本组数量，默认为1，allAckInSyncStateSet=true 时该参数无效。
#minInSyncReplicas：最小需保持同步的副本组数量，若 SyncStateSet 中副本个数小于 minInSyncReplicas 则 putMessage 直接返回 PutMessageStatus.IN_SYNC_REPLICAS_NOT_ENOUGH，默认为1。
在74
vim rocketmq-a-s/conf/broker.conf
## 集群名
brokerClusterName = RaftCluster
## broker组名，同一个RaftClusterGroup内，brokerName名要一样
brokerName=RaftNode00
## 监听的端口
listenPort=30915
## 你设置的NameServer地址和端口
namesrvAddr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876
#消息数据存放的根目录
storePathRootDir=/data/rocketmq/rocketmq-a-s/store
#commitlog保存目录
storePathCommitLog=/data/rocketmq/rocketmq-a-s/store/commitlog
#消费队列存储路径存储路径
#storePathConsumerQueue = /data/rocketmq/rocketmq-b-m/store/consumequeue
#enableDLegerCommitLog=true
dLegerGroup=RaftNode00
## n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
## 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
dLegerPeers=a0-192.168.4.87:9871;a1-192.168.4.74:9871
## must be unique
## 这个值必须是在同一个RaftClusterGroup内唯一的
dLegerSelfId=a1
sendMessageThreadPoolNums=16
## 由于我的虚拟机配置了多个网卡，所以会绑定ip错误，因此我配置了这项，
#brokerIP1=192.168.161.11############################################ enableControllerMode：Broker controller 模式的总开关，只有该值为 true，自动主从切换模式才会打开。默认为 false。
enableControllerMode = true
# controllerAddr：controller 的地址，多个 controller 中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879
controllerAddr = 192.168.4.87:9873;192.168.4.74:9873;192.168.4.124:9873
# syncBrokerMetadataPeriod：向 controller 同步 Broker 副本信息的时间间隔。默认 5000（5s）。
syncBrokerMetadataPeriod = 5000
# checkSyncStateSetPeriod：检查 SyncStateSet 的时间间隔，检查 SyncStateSet 可能会 shrink SyncState。默认5000（5s）。
# syncControllerMetadataPeriod：同步 controller 元数据的时间间隔，主要是获取 active controller 的地址。默认10000（10s）。
# haMaxTimeSlaveNotCatchup：表示 Slave 没有跟上 Master 的最大时间间隔，若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000（15s）。
# storePathEpochFile：存储 epoch 文件的位置。epoch 文件非常重要，不可以随意删除。默认在 store 目录下。
storePathEpochFile = /data/rocketmq/rocketmq-a-s/store
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。
allAckInSyncStateSet=true
#syncFromLastFile：若 slave 是空盘启动，是否从最后一个文件进行复制。默认为 false。
#asyncLearner：若该值为 true，则该副本不会进入 SyncStateSet，也就是不会被选举成 Master，而是一直作为一个 learner 副本进行异步复制。默认为false。
#inSyncReplicas：需保持同步的副本组数量，默认为1，allAckInSyncStateSet=true 时该参数无效。
#minInSyncReplicas：最小需保持同步的副本组数量，若 SyncStateSet 中副本个数小于 minInSyncReplicas 则 putMessage 直接返回 PutMessageStatus.IN_SYNC_REPLICAS_NOT_ENOUGH，默认为1。在124
vim rocketmq-c-m/conf/broker.conf
## 集群名
brokerClusterName = RaftCluster
## broker组名，同一个RaftClusterGroup内，brokerName名要一样
brokerName=RaftNode22
## 监听的端口
listenPort=30911
## 你设置的NameServer地址和端口
namesrvAddr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876
#消息数据存放的根目录
storePathRootDir=/data/rocketmq/rocketmq-c-m/store
#commitlog保存目录
storePathCommitLog=/data/rocketmq/rocketmq-c-m/store/commitlog
#消费队列存储路径存储路径
#storePathConsumerQueue = /data/rocketmq/rocketmq-a-m/store/consumequeue
#enableDLegerCommitLog=true
dLegerGroup=RaftNode22
## n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
## 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
dLegerPeers=c0-192.168.4.87:9875;c2-192.168.4.124:9875
#dLegerPeers=a0-192.168.4.87:9871;a1-192.168.4.74:9871;a2-192.168.4.124:9871
## must be unique
## 这个值必须是在同一个RaftClusterGroup内唯一的
dLegerSelfId=c2
sendMessageThreadPoolNums=16
## 由于我的虚拟机配置了多个网卡，所以会绑定ip错误，因此我配置了这项，
#brokerIP1=192.168.161.11############################################ enableControllerMode：Broker controller 模式的总开关，只有该值为 true，自动主从切换模式才会打开。默认为 false。
enableControllerMode = true
# controllerAddr：controller 的地址，多个 controller 中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879
controllerAddr = 192.168.4.87:9873;192.168.4.74:9873;192.168.4.124:9873
# syncBrokerMetadataPeriod：向 controller 同步 Broker 副本信息的时间间隔。默认 5000（5s）。
syncBrokerMetadataPeriod = 5000
# checkSyncStateSetPeriod：检查 SyncStateSet 的时间间隔，检查 SyncStateSet 可能会 shrink SyncState。默认5000（5s）。
# syncControllerMetadataPeriod：同步 controller 元数据的时间间隔，主要是获取 active controller 的地址。默认10000（10s）。
# haMaxTimeSlaveNotCatchup：表示 Slave 没有跟上 Master 的最大时间间隔，若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000（15s）。
# storePathEpochFile：存储 epoch 文件的位置。epoch 文件非常重要，不可以随意删除。默认在 store 目录下。
storePathEpochFile = /data/rocketmq/rocketmq-c-m/store
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。
allAckInSyncStateSet=true在124
vim rocketmq-b-s/conf/broker.conf
brokerName=RaftNode11
## 监听的端口
listenPort=30915
## 你设置的NameServer地址和端口
namesrvAddr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876
#消息数据存放的根目录
storePathRootDir=/data/rocketmq/rocketmq-b-s/store
#commitlog保存目录
storePathCommitLog=/data/rocketmq/rocketmq-b-s/store/commitlog
#消费队列存储路径存储路径
#storePathConsumerQueue = /data/rocketmq/rocketmq-a-m/store/consumequeue
#enableDLegerCommitLog=true
dLegerGroup=RaftNode11
## n0 n1 n2 分别是broker1,broker2,broker3 的 dLegerSelfId
## 例如：dLegerPeers=n0-服务器1的IP:40911;n1-服务器2的IP:40912;n2-服务器3的IP:40913
dLegerPeers=b1-192.168.4.74:9874;b2-192.168.4.124:9874
## must be unique
## 这个值必须是在同一个RaftClusterGroup内唯一的
dLegerSelfId=b2
sendMessageThreadPoolNums=16
## 由于我的虚拟机配置了多个网卡，所以会绑定ip错误，因此我配置了这项，
#brokerIP1=192.168.161.11############################################ enableControllerMode：Broker controller 模式的总开关，只有该值为 true，自动主从切换模式才会打开。默认为 false。
enableControllerMode = true
# controllerAddr：controller 的地址，多个 controller 中间用分号隔开。例如controllerAddr = 127.0.0.1:9877;127.0.0.1:9878;127.0.0.1:9879
controllerAddr = 192.168.4.87:9873;192.168.4.74:9873;192.168.4.124:9873
# syncBrokerMetadataPeriod：向 controller 同步 Broker 副本信息的时间间隔。默认 5000（5s）。
syncBrokerMetadataPeriod = 5000
# checkSyncStateSetPeriod：检查 SyncStateSet 的时间间隔，检查 SyncStateSet 可能会 shrink SyncState。默认5000（5s）。
# syncControllerMetadataPeriod：同步 controller 元数据的时间间隔，主要是获取 active controller 的地址。默认10000（10s）。
# haMaxTimeSlaveNotCatchup：表示 Slave 没有跟上 Master 的最大时间间隔，若在 SyncStateSet 中的 slave 超过该时间间隔会将其从 SyncStateSet 移除。默认为 15000（15s）。
# storePathEpochFile：存储 epoch 文件的位置。epoch 文件非常重要，不可以随意删除。默认在 store 目录下。
storePathEpochFile = /data/rocketmq/rocketmq-b-s/store
#allAckInSyncStateSet：若该值为 true，则一条消息需要复制到 SyncStateSet 中的每一个副本才会向客户端返回成功，可以保证消息不丢失。默认为 false。
allAckInSyncStateSet=true
#syncFromLastFile：若 slave 是空盘启动，是否从最后一个文件进行复制。默认为 false。
#asyncLearner：若该值为 true，则该副本不会进入 SyncStateSet，也就是不会被选举成 Master，而是一直作为一个 learner 副本进行异步复制。默认为false。
#inSyncReplicas：需保持同步的副本组数量，默认为1，allAckInSyncStateSet=true 时该参数无效。
#minInSyncReplicas：最小需保持同步的副本组数量，若 SyncStateSet 中副本个数小于 minInSyncReplicas 则 putMessage 直接返回 PutMessageStatus.IN_SYNC_REPLICAS_NOT_ENOUGH，默认为1。启动Broker
在87vim start_broker.sh
#!/bin/sh#cd `dirname $0`
#获取软连接的真实路径
DIR=`S=\`readlink "$0"\`; [ -z "$S" ] && S=$0; dirname $S`
cd "$DIR"echo `pwd`today=`date +"%Y%m%d"`
datetime=`date +"%Y%m%d%H%M%S"`#nohup sh bin/mqnamesrv > nohubNameserv &
nohup sh bin/mqbroker -c ./rocketmq-a-m/conf/broker.conf > nohubBroker-a-m.log &
nohup sh bin/mqbroker -c ./rocketmq-c-s/conf/broker.conf > nohubBroker-c-s.log & chmod +x ./vim start_broker.sh./vim start_broker.sh
日志：
(base) [root@server87 rocketmq]# tail -f nohubBroker-*.log
==> nohubBroker-a-m.log <==
10:24:43,072 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender] to Logger[io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingMetricExporter]
10:24:43,072 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [io.opentelemetry.exporter.logging.LoggingMetricExporter] to INFO
10:24:43,072 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [io.opentelemetry.exporter.logging.LoggingMetricExporter] to false
10:24:43,072 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender] to Logger[io.opentelemetry.exporter.logging.LoggingMetricExporter]
10:24:43,072 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.RootLoggerModelHandler - Setting level of ROOT logger to INFO
10:24:43,072 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [DefaultSiftingAppender] to Logger[ROOT]
10:24:43,073 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.DefaultProcessor@7a9273a8 - End of configuration.
10:24:43,074 |-INFO in org.apache.rocketmq.common.logging.JoranConfiguratorExt@26a7b76d - Registering current configuration as safe fallback pointThe broker[RaftNode00, 192.168.4.87:30911] boot success. serializeType=JSON and name server is 192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876==> nohubBroker-c-s.log <==
10:24:43,089 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender] to Logger[io.opentelemetry.exporter.logging.otlp.OtlpJsonLoggingMetricExporter]
10:24:43,089 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting level of logger [io.opentelemetry.exporter.logging.LoggingMetricExporter] to INFO
10:24:43,089 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.LoggerModelHandler - Setting additivity of logger [io.opentelemetry.exporter.logging.LoggingMetricExporter] to false
10:24:43,089 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [RocketmqBrokerMetricsSiftingAppender] to Logger[io.opentelemetry.exporter.logging.LoggingMetricExporter]
10:24:43,089 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.classic.model.processor.RootLoggerModelHandler - Setting level of ROOT logger to INFO
10:24:43,089 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.AppenderRefModelHandler - Attaching appender named [DefaultSiftingAppender] to Logger[ROOT]
10:24:43,090 |-INFO in org.apache.rocketmq.logging.ch.qos.logback.core.model.processor.DefaultProcessor@7a9273a8 - End of configuration.
10:24:43,090 |-INFO in org.apache.rocketmq.common.logging.JoranConfiguratorExt@26a7b76d - Registering current configuration as safe fallback pointThe broker[RaftNode22, 192.168.4.87:30915] boot success. serializeType=JSON and name server is 192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876启动管制台直接docker 启动即可，修改 -e 后面 nameserver 参数即可
docker run -d \
--name rocketmq-dashboard \
--restart always \
-e "JAVA_OPTS=-Drocketmq.namesrv.addr=192.168.4.87:9876;192.168.4.74:9876;192.168.4.124:9876" \
-p 8088:8080 \
-t apacherocketmq/rocketmq-dashboard:latest
http://192.168.4.87:8088/#/cluster
端口列表
30909
30911
30912
30913
30915
309169876
9871
9873
9874
9875
9877
导入
如果你想加载一篇你写过的.md文件，在上方工具栏可以选择导入功能进行对应扩展名的文件导入，
继续你的创作。
这篇关于rocketmq集群部署DLedger Controller的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
