主要拦截器 – TransactionInterceptor

`TransactionInterceptor` 实现了 MethodInterceptor。是声明式交易背后的环绕通知实现。

public class TransactionInterceptor extends TransactionAspectSupport implements MethodInterceptor,Serializable {
@Override
public Object invoke throws Throwable{
Class targetClass =!=null，AopUtils.getTargetClass) : null);// 在这里完成开启/提交/回滚的完整流程
return invokeWithinTransaction。targetClass,invocation::proceed);}
}

其中 invokeWithinTransaction 位于父类 TransactionAspectSupport负责读取注解属性、获取对应 PlatformTransactionManager 并委托其执行。

ThreadLocal 容器 – TransactionSynchronizationManager

`TransactionSynchronizationManager` 用于把当前线程绑定的资源还有同步回调保存起来实现跨多个组件共享同一事物上下文。

public abstract class TransactionSynchronizationManager{
private static final ThreadLocal resources =
new NamedThreadLocal<>;private static final ThreadLocal synchronizations =
new NamedThreadLocal<>;怎么说呢，private static final ThreadLocal currentTransactionName =
new NamedThreadLocal<>;private static final ThreadLocal currentTransactionReadOnly =
new NamedThreadLocal<>;private static final ThreadLocal;private static final ThreadLocal;}

再看主要方法，

java // 把 Connection 等资源绑定到当前线程 public static void bindResource{...}

// 注册同步回调。用于 commit/rollback 前后通知 public static void registerSynchronization{...}

痛点在自定义线程池或异步任务中，如果忘记把上下文复制到子线程，会导致 “No transactional resource bound to thread”。方法是使用 TaskExecutorBuilder#transactionAware 或手动复制 resources。

同步回调 – TransactionSynchronization

`TransactionSynchronization` 是针对单个绑定到线程的事物提供的细粒度回调接口，例如保存点、flush 等。

public interface TransactionSynchronization extends Ordered,Flushable{
default void suspend{ }
default void resume{ }
default void flush{ }
default void savepoint{ }
default void savepointRollback{ }
default void beforeCommit{ }
default void beforeCompletion{ }
default void afterCommit{ }
default void afterCompletion{ }
}

保存点示例

java @Transactional public void demoSavepoint{ Object sp = TransactionAspectSupport.currentTransactionStatus .createSavepoint;// ，部分业务失败 …if{ TransactionAspectSupport.currentTransactionStatus .rollbackToSavepoint;return，} }

痛点不少开发者误以为 MySQL 的 SEPOINT 能跨不同 Connection 使用，只能在同一 JD娱乐 Connection 上生效；若使用连接池切换连接，会导致 “Invalid savepoint”。务必确保同一事物期间不切换数据源。

全局监听 – TransactionExecutionListener

`TransactionExecutionListener` 是 Spring 6 新增，用于全局感知所有事物生命周期事件。按理说，它由抽象类 `AbstractPlatformTransactionManager` 持有。并在每一步骤遍历调用，

java public interface TransactionExecutionListener{ default void beforeBegin{ } default void afterBegin{ } default void beforeCommit{ } default void afterCommit{ } default void beforeRollback{ } default void afterRollback{ } }

自动装配方法

1. 收集自定义 Listener Bean → ExecutionListenersTransactionManagerCustomizer
2. 在 DataSource‑based Tx Manager 创建时 → 调用 transactionManager.addListener

java @Bean public TransactionExecutionListener myListener{ return new TransactionExecutionListener{ @Override public void beforeCommit{ log.info;} // ，其他方法…}，}

对比痛点 * Scope: Listener 全局生效；Synchronization 则仅对当前线程绑定的事物有效。* 异常影响: Listener 抛出的异常会导致整个事物回滚，需要自行捕获；而 Synchronization 的异常通常被忽略，不影响主事物。

监听器 vs 同步器 对比表格

注册方式?，?，

...