当前位置：首页 > ai >正文

Spring 事务的底层原理常见陷阱

ai 2025/5/8 4:19:23

一、Spring 事务的底层原理

1. 核心机制

动态代理（AOP）：
Spring 通过动态代理（JDK 或 CGLIB）生成代理对象，拦截被 @Transactional 注解标记的方法。
事务拦截器：
TransactionInterceptor 负责管理事务的生命周期（开启、提交、回滚）。
事务管理器：
PlatformTransactionManager 实现类（如 DataSourceTransactionManager）负责底层事务操作（如 JDBC 的 commit()）。
线程绑定：
通过 ThreadLocal（TransactionSynchronizationManager）存储当前事务的数据库连接，确保同一线程内多个操作共享同一事务。

2. 关键流程

// 伪代码：事务拦截器逻辑
public Object invoke(MethodInvocation invocation) {
// 1. 获取事务属性（@Transactional配置）
TransactionAttribute txAttr = getTransactionAttribute(invocation.getMethod());

// 2. 获取事务管理器
PlatformTransactionManager tm = determineTransactionManager(txAttr);// 3. 开启事务（根据传播行为决定是否新建事务）
TransactionStatus status = tm.getTransaction(txAttr);try {// 4. 执行目标方法Object result = invocation.proceed();// 5. 提交事务tm.commit(status);return result;
} catch (Exception ex) {// 6. 回滚事务（根据rollbackFor规则）completeTransactionAfterThrowing(txAttr, status, ex);throw ex;
}

}

二、常见陷阱及代码示例

陷阱 1：自调用导致事务失效

问题：同类内部方法调用（未经过代理对象），事务注解失效。

@Service
public class UserService {
public void createUser() {
// 直接调用内部方法，事务不生效！
this.insertUser();
}

@Transactional
public void insertUser() {// 插入用户到数据库
}

}

原因：this.insertUser() 是目标对象直接调用，未经过代理对象，事务拦截器未被触发。

解决：

方法 1：注入自身代理对象（通过 AopContext）：

@EnableAspectJAutoProxy(exposeProxy = true) // 启动类开启暴露代理
public class UserService {
public void createUser() {
UserService proxy = (UserService) AopContext.currentProxy();
proxy.insertUser(); // 通过代理对象调用
}
}

方法 2：拆分类，将 insertUser 放到另一个 Bean 中。

陷阱 2：异常被捕获未抛出

问题：事务方法中捕获异常但未重新抛出，导致事务无法回滚。

@Transactional
public void updateUser() {
try {
userDao.update(user); // 可能抛出SQLException
} catch (SQLException e) {
// 捕获异常但未抛出，事务不会回滚！
log.error(“更新失败”, e);
}
}

原因：Spring 默认只对 RuntimeException 和 Error 回滚，且必须抛出异常。

解决：

方法 1：抛出 RuntimeException：

catch (SQLException e) {
throw new RuntimeException(“更新失败”, e); // 触发回滚
}

方法 2：配置 @Transactional(rollbackFor = SQLException.class)。

陷阱 3：事务传播行为误解

问题：嵌套事务未按预期回滚。

@Transactional
public void outerMethod() {
userDao.insertUser();
try {
innerService.innerMethod();
} catch (Exception e) {
// 期望 innerMethod 回滚，但 outerMethod 继续提交
}
}

@Service
public class InnerService {
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void innerMethod() {
userDao.updateUser(); // 抛出异常
}
}

现象：如果 innerMethod 抛出异常，innerMethod 的事务会回滚，但 outerMethod 的事务仍会提交（因为 innerMethod 的事务是独立的）。

解决：