请解释 RocketMQ 事务消息的具体实现机制，包括其整体流程、关键组件以及如何处理消息发送与本地事务的一致性？

回答思路

1. 【回答框架 1】事务消息用于解决分布式事务中本地事务与消息发送的一致性问题，核心思路是将消息发送分为预备阶段和确认阶段，通过状态检查和回调机制保证最终一致性。
2. 【回答框架 2】流程上，生产者先发送半消息（Half Message），Broker 存储后对消费者不可见；生产者执行本地事务，根据结果向 Broker 提交 Commit 或 Rollback。
3. 【回答框架 3】若 Broker 长时间未收到确认，会主动回查生产者，通过检查本地事务状态来决定消息的提交或回滚，从而确保消息与本地事务最终一致。
4. 【回答框架 4】实现上，RocketMQ 通过事务状态检查、消息回查和队列管理机制（如 TransactionListener 接口）来协调，生产端需实现对应的监听器处理本地事务执行和状态检查。
5. 【回答框架 5】整个机制不保证强一致，而是通过补偿和重试达到最终一致性，适用于对实时性要求不高的场景，如订单创建与积分发放。
6. 【关键点 1】事务消息依赖半消息机制，先对消费者不可见，后根据本地事务结果提交或回滚。
7. 【关键点 2】Broker 通过回查机制向生产者询问本地事务状态，实现最终一致性。
8. 【关键点 3】生产端需实现 TransactionListener，提供执行本地事务和检查状态的回调。
9. 【关键点 4】半消息在未确认前不会投递给消费者，避免消息与业务操作不一致。
10. 【关键点 5】事务消息不保证强一致，依赖重试和补偿，适合最终一致场景。
11. 【易错点 1】事务消息不等于分布式事务解决方案，只保证消息生产与本地事务一致，消费者侧的一致性需另行处理。
12. 【易错点 2】回查机制依赖业务实现检查本地事务状态，若状态记录不全可能导致消息无限回查。
13. 【易错点 3】半消息在特殊情况下（如网络异常）可能出现延迟投递，需评估对业务的影响。