不能直接在@transactional方法里sendmq()，因为事务提交发生在方法返回后，此时sendmq()执行时数据库事务尚未真正落盘，导致消费者查不到数据；应使用@transactionaleventlistener(phase = transactionphase.after_commit)确保事务已刷盘后再发消息。
事务提交后发消息，为什么不能直接在 @Transactional 方法里 sendMQ()？
因为 @Transactional 方法的“提交动作”发生在方法返回之后、Spring 事务拦截器收尾阶段，而你写的 sendMQ() 是同步调用，执行时数据库事务大概率还没真正落盘。消费者一查库，数据不存在——不是 MQ 没发，是发得太早了。
常见错误现象：org.springframework.dao.EmptyResultDataAccessException 或业务侧反复重试；日志里能看到“MQ 发送成功”，但下游查不到对应记录。
- 事务传播行为必须是
REQUIRED（默认），否则@TransactionalEventListener不会绑定到当前事务上下文 - 事件发布必须在同一个 Spring 容器内（不能跨 JVM 或跨服务）
- 监听器类必须被 Spring 扫描到（
@Component或显式注册）
@TransactionalEventListener 的 phase 参数怎么选？
核心就两个值：TransactionPhase.AFTER_COMMIT（默认）和 TransactionPhase.AFTER_COMPLETION。别碰 BEFORE_COMMIT 或 AFTER_ROLLBACK —— 前者仍可能回滚，后者只在失败时触发，不满足“成功后发消息”的需求。
AFTER_COMMIT 表示：事务已刷盘、连接已释放、所有 JDBC 资源归还，此时发 MQ 最稳妥；AFTER_COMPLETION 是事务彻底结束（含回滚/提交），但无法区分结果，不适合做“成功才发”的逻辑。
- 必须显式写
@TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)，靠默认值容易误读 - 如果监听器方法抛异常，不会导致主事务回滚（它已结束），但你的 MQ 发送失败需要自己捕获并记录
- 监听器方法本身不带事务，别在里面加
@Transactional
事件对象为什么建议用不可变类（immutable）？
因为事件发布和监听是异步解耦的，监听器执行时，原始业务对象可能已被 GC 或修改。若事件里存的是 Order 实体引用，监听器里调 order.getStatus() 可能拿到脏值或 NPE。
正确做法是把关键字段拷贝进事件：ID、金额、状态码、时间戳等。Spring 不会帮你深拷贝，全靠你定义的构造函数或 Builder。
- 避免在事件类里放
transient字段或懒加载集合（如 Hibernate 的LazyInitializationException） - 不要在事件里传 Service 或 Repository 引用——监听器方法里没法用
- 如果事件要带附件（如文件路径、URL），确保这些路径在监听器执行时依然有效
KafkaTemplate.send() 失败了怎么办？
@TransactionalEventListener 只保证“事务提交后触发”，不保证“MQ 一定发成功”。Kafka 网络抖动、序列化失败、Topic 不存在都会让 kafkaTemplate.send() 抛异常，而这个异常不会传播回主流程。
必须在监听器里手动处理失败：记录告警、写入死信表、触发补偿任务。别指望 Spring 自动重试——它连重试机制都不提供。
- 用
CompletableFuture包裹kafkaTemplate.send()并whenComplete()捕获回调结果 - 失败时写入本地
outbox_event表（状态为FAILED），由定时任务捞取重发 - 别用
try-catch(Exception e)吞掉所有异常，至少log.error("MQ send failed", e)
@TransactionalEventListener 提供了钩子，但怎么用、怎么兜底，得你自己画线。
