RocketMQ主备自动切换模式部署

本文主要介绍如何部署支持自动主从切换的RocketMQ集群，主要是增加支持自动主从切换的Controller组件，其可以独立部署也可以内嵌在NameServer中。

消息存储结构

RocketMQ消息存储默认路径：${user.home}\store\

消息存储结构包括：

• commitlog 消息存储目录
• config 运行期间的配置信息
• consumequeue 消息消费队列存储目录
• index 消息索引文件存储目录
• abort 如果存在abort文件，说明broker非正常关闭；该文件默认启动时创建，正常退出之前删除；
• checkpoint 文件检测点，存储commitlog文件最后一次刷盘时间戳、consumequeue最后一次刷盘时间、index索引文件最后一次刷盘时间戳。

RocketMQ部署主要有以下几种模式：

• 单master模式（Local模式或单点模式）
• 多master模式（无slave）
• 多master多slave模式-异步复制模式
• 多master多slave模式-同步双写模式

刷盘策略：同步刷盘/异步刷盘（指节点自身消息持久化是同步还是异步写入磁盘）
主从同步方式：同步双写/异步复制（指同一组主从节点之间数据的同步）

RocketMQ分布式事务解决方案

使用二阶段提交，半事务消息和事务回查来解决上下游数据的一致性。

事务消息发送

在一些对数据一致性有强需求的场景，可以使用RocketMQ事务消息来解决，从而保证上下游数据的一致性。

例如，A系统 --> RocketMQ --> B系统，如何保持A、B系统分布式事务的一致性？

消息属性

RocketMQ 消息构成非常简单，如下图所示。

topic，表示要发送的消息的主题。
body 表示消息的存储内容
properties 表示消息属性
transactionId 会在事务消息中使用。

Message 可以设置的属性值包括：