必须在@transactional方法内注册transactionsynchronization,依托threadlocal绑定当前事务线程;回调需按场景选aftercommit、beforecommit等方法;推荐继承transactionsynchronizationadapter简化实现;跨线程操作须在aftercommit中异步处理。

要在 Java 事务管理中配合 Spring 的 TransactionSynchronization 监听事务回调,关键不是“等事务结束再手动调”,而是把监听逻辑注册进当前事务的生命周期钩子中——必须在事务活跃时注册,且依赖线程级上下文。
必须在事务方法内注册同步器
Spring 的事务同步机制基于 ThreadLocal,只对当前事务线程生效。如果你在事务方法外部(比如异步线程、定时任务里)调用 registerSynchronization(),会抛出异常或静默失效。
- 注册位置:只能在
@Transactional方法体内,或其直接调用链中(确保TransactionSynchronizationManager.isActualTransactionActive()返回true) - 典型写法:
TransactionSynchronizationManager.registerSynchronization(new TransactionSynchronizationAdapter() { ... }); - 错误示例:在
@Async方法里注册 —— 此时已脱离原事务线程,synchronizationsThreadLocal 为空
按需选择回调时机和方法
不同业务场景对应不同回调点,选错会导致逻辑执行失败或与预期不符:
- afterCommit():事务真正落库后触发,适合发 MQ、短信、更新缓存等“旁路操作”;此时数据库已提交,但连接可能已释放,不能执行 DB 操作
-
afterCompletion(int status):无论提交还是回滚都会执行,可用
status == TransactionSynchronization.STATUS_COMMITTED判断结果,适合统一清理或记录日志 - beforeCommit(boolean readOnly):提交前最后一刻,仍可修改数据(如补全字段、校验状态),但要避免耗时操作
- beforeCompletion():事务完成前(含回滚前),适合预释放资源、标记状态,但不区分成败
推荐继承 TransactionSynchronizationAdapter
直接实现 TransactionSynchronization 接口需重写全部 7 个方法,实际往往只关心一两个。用 TransactionSynchronizationAdapter 可以只覆盖需要的方法,代码更干净:
- 它提供了所有回调的空实现,避免冗余方法体
- 例如只需事务提交后发消息,就只重写
afterCommit(),其余自动忽略 - 注意:它不处理
suspend/resume/flush等高级场景,普通业务够用
注意线程与资源隔离边界
事务同步器绑定的是当前线程,跨线程传递需显式处理:
- 若主事务中启动新线程(如
new Thread(...).start()),新线程无法感知原事务,也不能注册同步器 - 如需跨线程触发后续动作,应在
afterCommit()中通过线程池提交任务,或发消息交由其他服务消费 - 不要在回调里尝试获取
DataSource或执行 JPA 查询——连接很可能已被归还,容易报错
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











