rocketmq主从自动切换（Controller 嵌入 NameServer 部署）

rocketmq5以后，加入了主从自动切换的功能：
在这里插入图片描述

官网

https://rocketmq.apache.org/zh/docs/deploymentOperations/03autofailover

准备工作

1）关闭将要升级的nameserver、master、slave
2）复制master的store文件到其他两台机器，确保broker启动前数据的一致，不然主备无法切换

nameserver

三个配置相同，controllerDLegerSelfId 不相同。
嵌入 NameServer 部署时只需要在 NameServer 的配置文件中设置 enableControllerInNamesrv=true，并填上 Controller 的配置即可

在conf文件夹创建：

vim namesrv.conf

enableControllerInNamesrv = true
controllerDLegerGroup = broker-a-group
controllerDLegerPeers = n0-dev1.rocketmq.leve.com:9877;n1-dev1.rocketmq.leve.com:9877;n2-dev1.rocketmq.leve.com:9877
controllerDLegerSelfId = n0
controllerStorePath = /opt/rocketmq-store/dledgerController
enableElectUncleanMaster = false
notifyBrokerRoleChanged = true

参数解释：

enableControllerInNamesrv：Nameserver 中是否开启 controller，默认 false。
controllerDLegerGroup：DLedger Raft Group 的名字，同一个 DLedger Raft Group 保持一致即可。
controllerDLegerPeers：DLedger Group 内各节点的端口信息，同一个 Group 内的各个节点配置必须要保证一致。
controllerDLegerSelfId：节点 id，必须属于 controllerDLegerPeers 中的一个；同 Group 内各个节点要唯一。
controllerStorePath：controller 日志存储位置。controller 是有状态的，controller 重启或宕机需要依靠日志来恢复数据，该目录非常重要，不可以轻易删除。
enableElectUncleanMaster：是否可以从 SyncStateSet 以外选举 Master，若为 true，可能会选取数据落后的副本作为 Master 而丢失消息，默认为 false。
notifyBrokerRoleChanged：当 Broker 副本组上角色发生变化时是否主动通知，默认为 true

启动namesrv：

sh /opt/rocketmq/bin/mqnamesrv -c namesrv.conf

brokerA配置

1、增加enableControllerMode、controllerAddr

2、brokerId和brokerRole可以不需要

3、同一个节点配置文件除store地址外，其他参数最好完全保持一致

broker-a.properties：

#所属集群名字
brokerClusterName=rocketmq-cluster-dev
#broker名字，注意此处不同的节点配置文件填写的不一样
brokerName=broker-a-dev
#0 表示 Master，>0 表示 Slave
#brokerId=0
#nameServer地址，分号分割
namesrvAddr=dev1.rocketmq.leve.com:9876;dev2.rocketmq.leve.com:9876;dev3.rocketmq.leve.com:9876;

enableControllerMode=true
controllerAddr=dev1.rocketmq.leve.com:9877;dev2.rocketmq.leve.com:9877;dev3.rocketmq.leve.com:9877

#在发送消息时，自动创建服务器不存在的topic，默认创建的队列数
defaultTopicQueueNums=4
#是否允许 Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
#是否允许 Broker 自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true
#Broker 对外服务的监听端口
#listenPort=10911
listenPort=10911
#删除文件时间点，默认凌晨 4点
deleteWhen=04
#文件保留时间，默认 48 小时
fileReservedTime=120
#commitLog每个文件的大小默认1G
mapedFileSizeCommitLog=1073741824
#ConsumeQueue每个文件默认存30W条，根据业务情况调整
mapedFileSizeConsumeQueue=300000
#destroyMapedFileIntervalForcibly=120000
#redeleteHangedFileInterval=120000
#检测物理文件磁盘空间
diskMaxUsedSpaceRatio=88
#存储路径
storePathRootDir=/home/rocketmq-store/brokerA
#commitLog 存储路径 【commitLog存储真正消息的路径】
storePathCommitLog=/home/rocketmq-store/brokerA/commitlog
#消费队列存储路径存储路径【每条信息在commitLog存储的路径】
storePathConsumeQueue=/home/rocketmq-store/brokerA/consumequeue
#消息索引存储路径
storePathIndex=/home/rocketmq-store/brokerA/index
#checkpoint 文件存储路径
storeCheckpoint=/home/rocketmq-store/brokerA/checkpoint
#abort 文件存储路径
abortFile=/home/rocketmq-store/brokerA/abort
#限制的消息大小
maxMessageSize=4194304
#flushCommitLogLeastPages=4
#flushConsumeQueueLeastPages=2
#flushCommitLogThoroughInterval=10000
#flushConsumeQueueThoroughInterval=60000
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
#- SLAVE
#brokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘
#- SYNC_FLUSH 同步刷盘
flushDiskType=SYNC_FLUSH
#checkTransactionMessageEnable=false
#发消息线程池数量
#sendMessageThreadPoolNums=128
#拉消息线程池数量
#pullMessageThreadPoolNums=128
#messageDelayLevel = 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s 1s
#是否支持根据属性过滤 如果使用基于标准的sql92模式过滤消息则改参数必须设置为true
enablePropertyFilter=true
slaveReadEnable=true