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

Spring Boot 事务失效问题：同一个 Service 类中方法调用导致事务失效的原因及解决方案

news 2025/7/11 14:23:58

在 Spring Boot 项目中，事务管理是确保数据一致性和完整性的重要机制。然而，很多开发者在实际开发中可能会遇到这样一个问题：同一个 Service 类中，一个有事务的方法 A 调用了另一个有事务的方法 B，结果发现方法 B 的事务并没有生效。这是为什么呢？本文将深入分析这个问题的原因，并提供几种有效的解决方案。

一、问题复现

我们先来看一个简单的示例：

@Service
public class UserService {@Autowiredprivate UserRepository userRepository;@Transactionalpublic void createUser(User user) {userRepository.save(user);this.updateUserStatus(user.getId()); // 调用同一个类中的方法}@Transactionalpublic void updateUserStatus(Long userId) {User user = userRepository.findById(userId).orElseThrow();user.setStatus("ACTIVE");userRepository.save(user);// 模拟异常throw new RuntimeException("更新状态失败");}
}

在上述代码中，createUser 方法调用了同一个类中的 updateUserStatus 方法。我们期望的是，当 updateUserStatus 方法抛出异常时，整个事务会回滚，包括 createUser 方法中的保存操作。然而，实际情况是，createUser 方法的事务会回滚，但 updateUserStatus 方法的事务并没有生效，导致数据不一致。

二、问题原因分析

Spring 的事务管理是基于 AOP（面向切面编程）实现的。当我们使用 @Transactional 注解时，Spring 会为被注解的类创建一个代理对象，通过代理对象来管理事务。

然而，在同一个 Service 类中，方法之间的调用是通过 this 关键字直接调用的，不会经过 Spring 的代理对象。因此，AOP 无法拦截这个调用，也就无法应用事务管理。

简单来说，就是：

通过代理对象调用方法：事务生效。
通过 this 调用同一个类中的方法：事务失效。

三、解决方案

针对这个问题，我们可以采用以下几种解决方案：

方案一：自我注入（Self-Injection）

将 Service 类注入到自身，然后通过注入的代理对象调用方法：

@Service
public class UserService {@Autowiredprivate UserRepository userRepository;@Autowiredprivate UserService self; // 自我注入@Transactionalpublic void createUser(User user) {userRepository.save(user);self.updateUserStatus(user.getId()); // 通过代理对象调用}@Transactionalpublic void updateUserStatus(Long userId) {User user = userRepository.findById(userId).orElseThrow();user.setStatus("ACTIVE");userRepository.save(user);throw new RuntimeException("更新状态失败");}
}

通过自我注入，我们获得了 Service 类的代理对象，从而确保了事务的正常工作。

方案二：使用 AopContext 获取当前代理对象

通过 AopContext.currentProxy() 获取当前代理对象，然后调用方法：

@Service
public class UserService {@Autowiredprivate UserRepository userRepository;@Transactionalpublic void createUser(User user) {userRepository.save(user);((UserService) AopContext.currentProxy()).updateUserStatus(user.getId()); // 通过代理对象调用}@Transactionalpublic void updateUserStatus(Long userId) {User user = userRepository.findById(userId).orElseThrow();user.setStatus("ACTIVE");userRepository.save(user);throw new RuntimeException("更新状态失败");}
}

注意：使用 AopContext.currentProxy() 需要在启动类上开启 @EnableAspectJAutoProxy(exposeProxy = true)：

@SpringBootApplication
@EnableAspectJAutoProxy(exposeProxy = true)
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);}
}

方案三：将方法拆分到另一个 Service 类中

将需要事务管理的方法放到另一个 Service 类中，然后通过依赖注入调用：

@Service
public class UserService {@Autowiredprivate UserRepository userRepository;@Autowiredprivate UserStatusService userStatusService;@Transactionalpublic void createUser(User user) {userRepository.save(user);userStatusService.updateUserStatus(user.getId()); // 通过另一个 Service 调用}
}@Service
public class UserStatusService {@Autowiredprivate UserRepository userRepository;@Transactionalpublic void updateUserStatus(Long userId) {User user = userRepository.findById(userId).orElseThrow();user.setStatus("ACTIVE");userRepository.save(user);throw new RuntimeException("更新状态失败");}
}