rocketmq集群部署DLedger Controller

news/2025/3/15 5:19:26/

目录

  • 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
主从自动选择

IPBrokerName目录说明
192.168.4.87RaftNode00rocketmq-a-sA主
192.168.4.87RaftNode22rocketmq-c-sC从
192.168.4.74RaftNode11rocketmq-b-sB主
192.168.4.74RaftNode00rocketmq-a-sA从
192.168.4.124RaftNode22rocketmq-c-mC主
192.168.4.124RaftNode11rocketmq-b-cB从

建目录

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 = true
74  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=JSON

NameServer和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文件，在上方工具栏可以选择导入功能进行对应扩展名的文件导入，
继续你的创作。


http://www.ppmy.cn/news/1171343.html

相关文章

如何开发一个 Safari 插件

如何开发一个 Safari 插件

本文字数&#xff1a;2493字 预计阅读时间&#xff1a;15分钟 由于常用浏览器是Safari&#xff0c;而Safari浏览器的插件比不上Chrome&#xff0c;所以就有了自己开发常用的Safari插件的想法。 打算开发当前页面生成二维码的Extension&#xff0c;因为网络原因&#xff0c;AirD…
阅读更多...
Pandas数据处理分析系列6-数据特征分析

Pandas数据处理分析系列6-数据特征分析

Pandas 数据特征分析 在前面章节学习了Pandas 两种数据结构Series、DataFrame，及Pandas如何读取Excel数据格式文件，数据预览、数据清洗及数据提取，接下来了解这些数据征分析。在实际工作中，财务、金融、制造业等数据，需从不同维度的指标进行分析，如合计数、最大数、最小数…
阅读更多...
塔望3W消费战略全案丨九代拉祜人，一饼古树茶

塔望3W消费战略全案丨九代拉祜人，一饼古树茶

存木香 客户&#xff1a;云南双江存木香茶叶商贸有限公司 品牌&#xff1a;存木香 时间&#xff1a;2019年 &#xff08;项目部分内容保密期&#xff09; 沧海桑田 存木香依然 存木香 CUNMUXIANG( 全称云南双江存木香茶业有限公司 ), 成立于2011 年 , 总部设于北回归线横…
阅读更多...
Java-IO流

Java-IO流

文章目录 Java-IO流文件字节流文件字符流File类缓冲流转换流打印流数据流对象流 Java-IO流 JDK提供了一套用于IO操作的框架&#xff0c;为了方便我们开发者使用&#xff0c;就定义了一个像水流一样&#xff0c;根据流的传输方向和读取单位&#xff0c;分为字节流InputStream和…
阅读更多...
Python学习--函数的参数

Python学习--函数的参数

三、函数的参数 1、函数的参数类型 设置与传递参数是函数的重点&#xff0c;而 Python 的函数对参数的支持非常的灵活。 主要的参数类型有&#xff1a;默认参数、关键字参数&#xff08;位置参数&#xff09;、不定长参数。 下面我们将一一了解这几种参数。 2、默认参数 …
阅读更多...
买充电桩你必须要知道三件事

买充电桩你必须要知道三件事

分享一套开源充电桩云平台&#xff08;v2.5.1&#xff09;-- 支持二轮(电动自行车)、四轮(电动汽车) 中国电动汽车充电基础设施促进联盟的信息部主任&#xff0c;仝宗旗&#xff0c;在2022年接受了《中国汽车报》采访的时候&#xff0c;提到过一个数据。 电动车主在小区成功安…
阅读更多...
Flutter的Don‘t use ‘BuildContext‘s across async gaps警告解决方法

Flutter的Don‘t use ‘BuildContext‘s across async gaps警告解决方法

文章目录 问题有问题的源码 问题原因问题分析Context的含义BuildContext的作用特殊情况 解决方法 问题 Flutter开发中遇到Don’t use BuildContext’s across async gaps警告 有问题的源码 if (await databaseHelper.isDataExist(task.title)) {showDialog(context: context,…
阅读更多...
C++前缀和算法：合并石头的最低成本原理、源码及测试用例

C++前缀和算法：合并石头的最低成本原理、源码及测试用例

本文涉及的基础知识点 C算法&#xff1a;前缀和、前缀乘积、前缀异或的原理、源码及测试用例 包括课程视频 动态规划&#xff0c;日后完成。 题目 有 n 堆石头排成一排&#xff0c;第 i 堆中有 stones[i] 块石头。 每次 移动 需要将 连续的 k 堆石头合并为一堆&#xff0c;而…
阅读更多...
最新文章

Copyright @ 2022~2023