主从模式集群构建

保障消息的即时性和可靠性并存

投递一条消息后，关闭主节点，故障演练，数据一致性能否保证

（同步刷盘和异步刷盘）

从节点可以继续提供消费者继续消费，不能接收消息

主节点重新上线后进行消费进度的offset同步

开始构建主从模式架构
1.在构建过的虚拟机中修改配置
vi /etc/hosts

172.19.24.103 rocketmq-nameserver1
172.19.24.103 rocketmq-master1
172.19.24.113 rocketmq-nameserver2
172.19.24.113 rocketmq-master-slave1

两台机器都配置hosts如上

2.slave机器修改配置文件如下

brokerClusterName=rocketmq-cluster

brokerName=broker-a

brokerId=1

namesrvAddr=rocketmq-nameserver1:9876;rocketmq-nameserver2:9876

defaultTopicQueueNums=4

autoCreateTopicEnable=true

autoCreateSubScriptionGroup=true

listenPosr=10911

deleteWhen=04

fileReservedTime=120

mapedFileSizeCommitLog=1073741824

mapedFileSizeConsumeQueue=300000

diskMaxUsedSpaceRatio=88

storePathRootDir=/usr/local/rocketmq/store

storePathCommitLog=/usr/local/rocketmq/store/commitLog

storePathConsumeQueue=/usr/local/rocketmq/store/consumequeue

storePathIndex=/usr/local/rocketmq/store/index

storeCheckpooint=/usr/local/rocketmq/store/checkpoint

abortFile=/usr/local/rocketmq/store/abort

maxMessageSize=65536

brokerRole=SLAVE

flushDiskType=ASYNC_FLUSH

同步到两台机器

相关单机搭建请参考RocketMQ环境搭建一文
3.增加相关日志信息配置，详见Rocket单机的环境配置

第一台机器启动NameServer
nohup sh mqnamesrv &
第一台机器启动Broker
nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a.properties > /dev/null 2>&1 &

第一台机器启动NameServer
nohup sh mqnamesrv &
第二台机器启动Broker
nohup sh mqbroker -c /usr/local/rocketmq/conf/2m-2s-async/broker-a-s.properties > /dev/null 2>&1 &

值得注意的是放火墙需要打开10912端口，HA主要使用该端口同步数据。
查看防火墙端口是否打开
firewall-cmd --query-port=10912/tcp

（1）首先启动完成master和slave
（2）用Producer发送消息到集群
（3）将主节点关闭，模拟主节点宕机
（4）Consumer启动之后还是能消费到Producer发送的数据
（5）再次启动Master节点，没有消费到新的数据
证明主从架构能够保证主节点宕机之后，能够保证数据不丢失。具备高可用特性，可避免单点故障。