SpringBoot使用@Async异步更新DB报无事务错误、数据未入库问题

算力阿峰

2026-8-29

问题产生原因

Spring的@Async和@Transactional都是基于AOP动态代理实现的，只有通过Spring容器托管的代理对象调用标注了这两个注解的方法时，对应的切面逻辑（提交异步任务、开启/提交/回滚事务）才会生效。如果代码中ServiceB的实例是手动new出来的、没有交给Spring容器管理，performApproval方法上的@Transactional会完全失效，方法执行时没有Spring绑定的数据库事务，调用JPA的saveAll方法就会抛出无事务异常。
事务上下文默认是通过ThreadLocal绑定在当前执行线程上的，不会自动跨线程传递。当前实现把@Transactional只加在异步方法内部调用的ServiceB方法上，而@Async标记的入口方法本身没有事务配置，异步线程启动后没有被事务切面拦截，无法正确绑定JPA需要的EntityManager和数据库连接，即使配置了REQUIRES_NEW传播级别也无法正常新建事务。
Controller层调用异步方法后直接返回，没有处理异步任务提交的逻辑，部分场景下请求线程提前释放数据库连接资源，会导致异步线程拿不到可用连接开启事务。

解决方案

首先确认基础配置和Bean托管状态
- 启动类上添加@EnableAsync注解开启异步功能，如果项目没有自动装配事务管理器，手动补充@EnableTransactionManagement注解。
- 确认ServiceA、ServiceB、Repository层的实现类都添加了@Service、@Repository等注解交给Spring托管，所有依赖的Bean都通过构造器或者@Autowired注入，禁止手动new持久层、服务层的Bean实例。

调整事务注解的位置，在异步入口方法上绑定事务
把事务注解直接加在ServiceA的异步入口方法上，让异步线程启动时就被事务切面拦截、绑定独立事务，ServiceB内部的业务方法不需要重复加事务注解，默认加入外层事务即可。调整后的ServiceA方法代码示例：

@Async
@Transactional(readOnly = false, propagation = Propagation.REQUIRES_NEW, rollbackFor = { Throwable.class })
@Override
public Future<MyResponseModel> myMethodForApproval(parameterList) {
    MyResponseModel myResponseModel= new MyResponseModel();
    serviceClassB.performApproval(parameterList); 
    myResponseModel.setStatus("Success");
    myResponseModel.setMessage("Approval process initiated successfully");
    return new AsyncResult<MyResponseModel>(myResponseModel);
}

注意：Propagation类要导入org.springframework.transaction.annotation.Propagation包，避免导包错误导致事务配置失效。

修正Controller层逻辑
调用异步方法时处理任务提交阶段的异常，不要直接无返回调用，避免线程池满、任务提交失败时前端拿到错误的成功响应。不需要等待异步任务执行完成，直接返回受理成功的响应即可，调整后代码示例：

@RequestMapping(value = "/approveProcess", method = RequestMethod.POST, consumes = { "application/json" })
public ResponseEntity<MyResponseModel> approveProcess(@RequestBody parameterList) {
    MyResponseModel resp = new MyResponseModel();
    try {
        serviceClassA.myMethodForApproval(parameterList);
        resp.setStatus("Success");
        resp.setMessage("Approval process initiated successfully");
        return ResponseEntity.ok(resp);
    } catch (Exception e) {
        resp.setStatus("Failed");
        resp.setMessage("Failed to initiate approval process");
        return ResponseEntity.status(500).body(resp);
    }
}

检查JPA相关配置
确认配置文件中数据源、JPA方言配置和实际使用的数据库匹配，项目中统一使用JpaTransactionManager作为事务管理器，不要混用JDBC、MyBatis等其他持久层框架的事务管理器操作JPA的Repository。

内容的提问来源于stack exchange，提问作者Sumit Ghosh