事务提交后逻辑需用TransactionSynchronizationAdapter的afterCommit()注册,确保数据库已提交且变更可见;直接写代码或误用TransactionSynchronizationManager将失效。

事务提交后执行逻辑总被跳过或不生效
直接在 @Transactional 方法末尾写 Redis 更新、MQ 发送等代码,大概率会失败——因为事务还没真正提交,底层连接可能仍处于挂起状态。Spring 的事务传播和同步机制决定了:**只有注册到当前事务同步器中的回调,才能在 commit 成功后稳定触发**。否则你写的代码只是“事务内普通语句”,跟事务生命周期无关。
TransactionSynchronizationManager 不是拿来直接 new 的
它是个静态工具类,所有操作都基于当前线程绑定的事务资源(TransactionSynchronizationManager.bindResource() 等方法仅用于框架内部)。你要用的是它的配套抽象:TransactionSynchronizationAdapter,而不是手动操作这个 manager。
- 别写
new TransactionSynchronizationManager()—— 它没构造函数,也不该实例化 - 别试图调用
registerSynchronization()前先检查isActualTransactionActive()—— 如果没事务,注册会静默失败,且不会抛异常 - 必须确保当前线程确实在一个活跃事务中(比如方法被
@Transactional包裹,且未被Propagation.NOT_SUPPORTED等传播行为中断)
正确注册 afterCommit 回调的三步动作
核心是把自定义逻辑包装成 TransactionSynchronization 实现,并在事务上下文就绪时注册。最简路径如下:
- 继承
TransactionSynchronizationAdapter,重写afterCommit()方法,把你要做的事后操作放进去(如更新缓存、发消息) - 在业务方法内,用
TransactionSynchronizationManager.registerSynchronization()注册该实例 - 确保该方法运行在 Spring 管理的事务中(例如加了
@Transactional,且调用链没脱离代理)
示例片段:
public void updateUser(User user) {
userRepository.save(user);
TransactionSynchronizationManager.registerSynchronization(
new TransactionSynchronizationAdapter() {
@Override
public void afterCommit() {
redisTemplate.delete("user:" + user.getId());
rabbitTemplate.convertAndSend("user.update", user);
}
}
);
}
注意:这个匿名内部类不能有状态依赖(比如捕获局部变量需 final 或 effectively final),且不可复用——每次事务都要新注册一个实例。
为什么 afterCompletion(int status) 不够用
afterCompletion() 会在事务结束时无条件触发(无论 commit 还是 rollback),而 status 参数只告诉你结果,无法区分「已提交」和「已回滚」之外的中间态(比如系统异常导致的未知终止)。更关键的是:它不保证数据库变更已对其他事务可见——某些隔离级别下,MVCC 快照可能还未刷新。
-
afterCommit()是唯一明确表示“事务已成功落库、JDBC Connection 已提交、二级缓存可安全失效”的钩子 - 如果你需要同时处理成功和失败场景,应分别注册两个同步器:一个用
afterCommit(),另一个用afterCompletion(int status)并判断status == TransactionSynchronization.STATUS_COMMITTED - 不要在
afterCompletion()里做幂等性弱的操作(如发 MQ),否则 rollback 后也会发一次
真正容易被忽略的点:这些同步器只对当前事务有效,且注册时机必须在事务 active 期间;如果在异步线程(如 @Async)里调用,TransactionSynchronizationManager 查不到事务资源,注册直接失效。










