RocketMQ的事务消息是如何实现的？

RocketMQ 通过 TransactionListener 接口实现事务消息机制，其工作流程如下：

1. 发送半消息
   首先向 Broker 发送一条半消息（状态标记为"prepared"），该消息会被存储在事务日志中但暂不可消费。

2. 执行本地事务
   半消息发送成功后，应用程序执行本地事务逻辑并确定最终状态。

3. 提交/回滚

   • 本地事务成功：通知 Broker 提交消息（状态改为"committed"），消息转为可消费状态
   • 本地事务失败：通知 Broker 回滚消息（状态改为"rollback"），消息会被立即删除

异常处理机制

未收到确认指令时
若 Broker 未及时收到 COMMIT/ROLLBACK：

1. 主动发起事务状态检查
2. 应用程序通过回调返回处理结果
3. 若超时未响应则标记为"UNKNOW"状态
4. 最终过期后自动回滚

半消息发送失败
由于业务操作在半消息之后执行：

• 失败时业务尚未执行，不存在一致性问题
• 可通过重试机制解决（自主重试或依赖上游重试）

设计优势

相比"先提交事务再发消息"的传统方案，事务消息解决了：

1. 最终一致性
   即使 COMMIT 消息发送失败，MQ 仍能通过半消息状态反查确保最终一致
2. 防丢失
   本地事务提交与消息投递形成原子操作，避免"事务成功但消息丢失"的情况
3. 状态可追踪
   通过 prepared/committed/rollback 状态机明确消息生命周期