Apache-RocketMQ

RocketMQ 使用笔记

https://rocketmq.apache.org/

RocketMQ 事务消息

Apache RocketMQ 4.3.0版本开始支持事务消息。

• 事务消息：MQ 提供类似 X/Open XA 的分布事务功能，通过 MQ 事务消息能达到分布式事务的最终一致。
• 半消息：Half(Prepare) Message，暂不能投递的消息，发送方已经将消息成功发送到了 MQ 服务端，但是服务端未收到生产者对该消息的二次确认，此时该消息被标记成“暂不能投递”状态，处于该种状态下的消息即半消息。
• 消息回查：由于网络闪断、生产者应用重启等原因，导致某条事务消息的二次确认丢失，MQ 服务端通过扫描发现某条消息长期处于“半消息”时，需要主动向消息生产者询问该消息的最终状态（Commit 或是 Rollback），该过程即消息回查。

RocketMQ 事务消息原理如图：

RocketMQ事务消息原理

其中：

1. 发送方向 MQ 服务端发送消息。
2. MQ Server 将消息持久化成功之后，向发送方 ACK 确认消息已经发送成功，此时消息为 半消息。
3. 发送方开始执行本地事务逻辑。
4. 发送方根据本地事务执行结果向 MQ Server 提交二次确认（Commit 或是 Rollback），MQ Server 收到 Commit 状态则将半消息标记为可投递，订阅方最终将收到该消息；MQ Server 收到 Rollback 状态则删除半消息，订阅方将不会接受该消息。
5. 在断网或者是应用重启的特殊情况下，上述步骤 4 提交的二次确认最终未到达 MQ Server，经过固定时间后 MQ Server 将对该消息发起消息回查。
6. 发送方收到消息回查后，需要检查对应消息的本地事务执行的最终结果。
7. 发送方根据检查得到的本地事务的最终状态再次提交二次确认，MQ Server 仍按照步骤4对半消息进行操作。

事务消息发送对应步骤1、2、3、4，事务消息回查对应步骤5、6、7。

事务消息是为了为了解决Producer端发送消息与本地事务执行的原子性问题。
与本地事务表的思路一致，都是将消息先找一个地方暂存起来，只不过暂存的地方不一样，RocketMQ将消息暂存到了内部的主题中。
为了支持事务消息，RocketMQ引入了Half Topic 以及Operation Topic 两个内部队列来存储事务消息推进状态。其中：
Half Topic对应队列中存放着prepare消息，也就是预发送的消息，消息会不直接发到目标Topic，因此消费者不可见，实现暂存
Operation Topic对应的队列则存放了prepare message对应的commit/rollback消息，消息体中则是prepare message对应的offset。

Rocket MQ 4.3.0分布式事务消息初析
https://blog.csdn.net/feeltouch/article/details/81610560

可靠消息一致性的奇淫技巧
https://mp.weixin.qq.com/s/yxYCybFPMrFp465FVg15TQ