RocketMQ的事务消息是如何实现的？
RocketMQ 通过 TransactionListener 接口实现事务消息机制，其工作流程如下：
发送半消息
首先向 Broker 发送一条半消息（状态标记为"prepared"），该消息会被存储在事务日志中但暂不可消费。执行本地事务
半消息发送成功后，应用程序执行本地事务逻辑并确定最终状态。提交/回滚
- 本地事务成功：通知 Broker 提交消息（状态改为"committed"），消息转为可消费状态
- 本地事务失败：通知 Broker 回滚消息（状态改为"rollback"），消息会被立即删除
异常处理机制
未收到确认指令时
若 Broker 未及时收到 COMMIT/ROLLBACK：
- 主动发起事务状态检查
- 应用程序通过回调返回处理结果
- 若超时未响应则标记为"UNKNOW"状态
- 最终过期后自动回滚
半消息发送失败
由于业务操作在半消息之后执行：
- 失败时业务尚未执行，不存在一致性问题
- 可通过重试机制解决（自主重试或依赖上游重试）
设计优势
相比"先提交事务再发消息"的传统方案，事务消息解决了：
- 最终一致性
即使 COMMIT 消息发送失败，MQ 仍能通过半消息状态反查确保最终一致 - 防丢失
本地事务提交与消息投递形成原子操作，避免"事务成功但消息丢失"的情况 - 状态可追踪
通过 prepared/committed/rollback 状态机明确消息生命周期