跳到主要内容

二十、RocketMQ源码分析之从官方示例窥探RocketMQ事务消息实现基本思想



RocketMQ事务消息阅读目录指引:
RocketMQ源码分析之从官方示例窥探RocketMQ事务消息实现基本思想
RocketMQ源码分析之RocketMQ事务消息实现原理上篇
RocketMQ源码分析之RocketMQ事务消息实现原理中篇—-事务消息状态回查
RocketMQ源码分析之事务消息实现原理下篇-消息服务器Broker提交回滚事务实现原理

RocketMQ事务消息实战


  RocketMQ4.3.0版本开始支持事务消息,本节开始将剖析事务消息的实现原理,首先将从官方给出的Demo实例入手,以此通往RocketMQ事务消息的世界中。
  官方版本未发布之前,从apache rocketmq第一个版本上线后,代码中存在者与事务消息相关的代码,例如COMMIT、ROLLBACK、PREPARED, 网上对于事务消息的“声音”基本上是使用类似二阶段提交,消息系统标志MessageSysFlag中定义的:TRANSACTION_PREPARED_TYPE、TRANSACTION_COMMIT_TYPE、
TRANSACTION_ROLLBACK_TYPE,消息发送者首先发送TRANSACTION_PREPARED_TYPE类型的消息,然后事务介绍后,发送commit请求或rollback请求,如果commit,rollback消息丢失的话,rocketmq会在一定超时时间后会查,应用程序需要告知该消息是提交还是回滚。让我们各自带着自己的理解和猜出,先重点看一下Demo程式,大概可以窥探一些大体的信息。