rocketmq集群部署DLedger Controller

news2024/11/24 17:57:55

目录

  • 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 -Xmn256m

 vim 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 namesrv
 sh 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

在87
 vim 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 point

The 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 point

The 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
30916

9876
9871
9873
9874
9875
9877

导入

如果你想加载一篇你写过的.md文件，在上方工具栏可以选择导入功能进行对应扩展名的文件导入，
继续你的创作。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1123423.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

h5插件_h5页面嵌入客户端调试

h5插件_h5页面嵌入客户端调试

当h5页面嵌入客户端之后&#xff0c;若是遇到问题无法调试&#xff0c;比如点击按钮无反应 —> 但是开发却看不到控制台、看不到接口返回值… 此时可以使用调试工具来查看… edura 引入1 <script src"https://cdn.jsdelivr.net/npm/eruda"></script&g…
阅读更多...
向某文件中逐秒追加带序号输入当前时间 fgets fputs fprintf sprintf

向某文件中逐秒追加带序号输入当前时间 fgets fputs fprintf sprintf

//向某文件中逐秒追加带序号输入当前时间 #include<stdio.h> #include<stdlib.h> #include<time.h> #include<string.h> #include <unistd.h> int main(int argc, char const *argv[]) { time_t tv; // time(&tv);//法1:获取秒数 …
阅读更多...
2023面试经典 Redis未授权漏洞与组合拳

2023面试经典 Redis未授权漏洞与组合拳

文前漫谈 之前面试里碰见过&#xff0c;属于面试经典了&#xff0c;有空了了解一下 2015年的洞了&#xff0c;从以前乌云一个师傅的文章那了解到 Redis 有关的漏洞具有明显的时间分段性&#xff0c;在15年11月之前&#xff0c;主要是未授权导致的数据泄露&#xff0c;获得一些…
阅读更多...
自增还是UUID，数据库主键的类型该如何选择?

自增还是UUID，数据库主键的类型该如何选择?

一、自增(auto_increment)和UUID优缺点 自增 &#xff08;auto_increment&#xff09;的优点: 1.字段长度较uuid小很多&#xff0c;可以是bigint甚至是int类型&#xff0c;这对检索的性能会有所影响。 2.在写的方面&#xff0c;因为是自增的&#xff0c;所以主键是趋势自增的&…
阅读更多...
小游戏外包开发流程及费用

小游戏外包开发流程及费用

小游戏的开发流程和费用会因项目的规模、复杂性和所选技术平台而有所不同。以下是一般的小游戏开发流程和可能的费用因素&#xff0c;希望对大家有所帮助。北京木奇移动技术有限公司&#xff0c;专业的软件外包开发公司&#xff0c;欢迎交流合作。 开发流程&#xff1a; 概念和…
阅读更多...
Android Studio Gradle中没有Task任务，没有Assemble任务，不能方便导出aar包

Android Studio Gradle中没有Task任务，没有Assemble任务，不能方便导出aar包

Gradle中&#xff0c;没有Assemble任务 1. 在编译aar包或者编译module的时候&#xff0c;没有release包&#xff0c;我们一般都是通过assemble进行编译。 如果在Gradle中找不到task。 可以通过设置File->setting -->Experimental→取消勾选“Do not build Gradle task …
阅读更多...
TransactionScope的使用

TransactionScope的使用

TransactionScope的使用 简介1. 命名空间2.创建事务范围3.嵌套事务4.事务提交和回滚5.支持分布式事务6.配置选项7.资源管理器8.分布式事务协调器 应用1.未设置分布式事务2.设置分布式事务 简介 TransactionScope 是 .NET Framework 和 .NET Core 中的一个类&#xff0c;用于简化…
阅读更多...
Java数组—精讲篇

Java数组—精讲篇

Java数组—精讲篇 先进行专栏介绍 二维数组定义格式初始化静态初始化动态初始化 举例声明并初始化一个3行4列的整型二维数组访问二维数组元素访问二维数组array中第2行第3列的元素 遍历二维数组遍历二维数组array并打印每个元素的值强调 应用举例总结 程序展示二维数组元素打乱…
阅读更多...
ThingsBoard的版本控制整合gitee

ThingsBoard的版本控制整合gitee

1、注册gitee账号，创建自己的空间，并且创建一个用于存储ThingsBoard相关的仓库 2、进入ThingsBoard的租户层，然后找到版本控制,进行配置 输入gitee的仓库地址 仓库URL：指定你的gitee的参考地址 仓库分支：master 身份验证：密码、访问令牌 用户名：登录账号 密码/访问令…
阅读更多...
【LeetCode刷题】1两数之和

【LeetCode刷题】1两数之和

为找工作&#xff0c;我的代码都是用的JAVA&#xff0c;慢慢学习中。 LeetCode刷题Day1 两数之和 给定一个整数数组 nums 和一个整数目标值 target&#xff0c;请你在该数组中找出 和为目标值 target 的那 两个 整数&#xff0c;并返回它们的数组下标。 你可以假设每种输入…
阅读更多...
【干货】Java函数式编程公式大全，收藏学习！

【干货】Java函数式编程公式大全，收藏学习！

函数操作是现代编程领域中的核心概念之一&#xff0c;它以类似 Excel 表格的方式进行数据处理和计算。它的特点是使用公式和函数来描述数据之间的关系和计算逻辑&#xff1b;它允许我们以更高效、更有组织的方式管理和处理数据。 在函数式编程中&#xff0c;数据被组织成表格的…
阅读更多...
UDP网络通信反复发收

UDP网络通信反复发收

package UDP2;import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; import java.util.Scanner;/* * 完成UDP 通信快速入门 实现发1收1*/ public class Client {public static void main(String[] args) throws Exception{// …
阅读更多...
统信操作系统UOS上安装arm64版nginx

统信操作系统UOS上安装arm64版nginx

原文链接&#xff1a;统信操作系统UOS上安装arm64版nginx hello&#xff0c;大家好啊&#xff0c;今天给大家带来一篇在统信桌面操作系统UOS上安装arm64版nginx的文章&#xff0c;本篇文章主要是给大家提供一种下载离线nginx软件包的方法&#xff0c;拿到软件包可以去不能链接互…
阅读更多...
Qt耗时操作添加动画等待加载效果

Qt耗时操作添加动画等待加载效果

Qt耗时操作添加动画等待加载效果_qt 等待动画-CSDN博客本例模拟耗时请求实现动画等待加载效果&#xff0c;采用QtConcurrent::run实现异步耗时操作&#xff0c;通过QFutureWatcher异步监测耗时操作结果的返回值做相应的动画演示。_qt 等待动画https://blog.csdn.net/qq_3666686…
阅读更多...
解决AndroidStudio Gradle只有testDebugUnitTest

解决AndroidStudio Gradle只有testDebugUnitTest

问题复现&#xff1a; 问题解决&#xff1a; 1:点击Task list not built... 2:取消勾选Configure all Gradle tasks during Gradle Sync... 大功告成&#xff0c;现在去看看Gradle&#xff0c;屏蔽的都显示出来了。
阅读更多...
CUDA学习笔记（九）Dynamic Parallelism

CUDA学习笔记（九）Dynamic Parallelism

本篇博文转载于https://www.cnblogs.com/1024incn/tag/CUDA/&#xff0c;仅用于学习。 Dynamic Parallelism 到目前为止&#xff0c;所有kernel都是在host端调用&#xff0c;CUDA Dynamic Parallelism允许GPU kernel在device端创建调用。Dynamic Parallelism使递归更容易实现…
阅读更多...
信钰证券：长江电力180亿市值，招商证券、摩根大通等浮盈超一成

信钰证券：长江电力180亿市值，招商证券、摩根大通等浮盈超一成

本周A股限售股解禁规划环比有所上升。 Wind数据核算闪现&#xff0c;除去新上市公司&#xff0c;本周共有64家公司限售股解禁&#xff0c;解禁数量51.52亿股&#xff0c;以最新收盘价核算&#xff08;下同&#xff09;&#xff0c;解禁市值776.21亿元。 本周解禁市值跨越10亿…
阅读更多...
C++二分算法的应用：寻找峰值原理、源码及测试用例

C++二分算法的应用：寻找峰值原理、源码及测试用例

说明 此文是课程https://edu.csdn.net/course/detail/38771 的讲义。 源码下载&#xff1a;https://download.csdn.net/download/he_zhidan/88458478 题目 长度为n的数组nums&#xff0c;请返回任意一峰值的索引。符合以下条件之一i便是峰值的索引。 n等于1 i等于0 n>…
阅读更多...
构建并训练单层神经网络模型

构建并训练单层神经网络模型

1. 单层神经网络 单层神经网络由一个层次中的多个神经元组成，总体来看，单层神经网络的结构是：一个输入层，一个隐含层，一个输出层。 图中描述的是前向网络，但其反向传播网络的结构也是一样的。蓝色方框表示输入层，绿色圆圈表示隐含层，输出层没有绘制出来。 1.1 加载…
阅读更多...
Linux安装Redis（这里使用Redis6，其它版本类似）

Linux安装Redis（这里使用Redis6，其它版本类似）

目录 一、选择需要安装的Redis版本二、下载并解压Redis三、编译安装Redis四、启动Redis4.1、修改配置文件4.2、启动 五、测试连接5.1、本地连接使用自带客户端redis-cli连接操作redis5.2、外部连接使用RedisDesktopManager操作redis 六、关闭Redis七、删除Redis 一、选择需要安…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023