Spring Boot多数据库环境下@Async方法导致JPA INSERT语句无法执行

我正在开发一个使用Spring Data JPA连接多数据库的Spring Boot应用。同步执行时，保存实体到某数据库的save()方法正常运行，但添加@Async注解后，INSERT查询不再执行，SELECT查询却能正常工作。单数据库场景下@Async注解可正常使用。

已尝试的操作：

• 确保事务管理正确：方法已添加@Transactional注解。
• 检查只读事务：确认事务未标记为只读。
• 验证实体状态：确保实体为新实体，应触发INSERT操作。
• 手动刷新EntityManager：调用entityManager.flush()时，遇到错误：
  org.springframework.dao.InvalidDataAccessApiUsageException: no transaction is in progress
• 查看SQL日志：已启用SQL日志，但异步方法下未生成INSERT查询。
• 检查异常：未抛出其他异常。

相关代码：

@Async("asyncTaskExecutor")
@EventListener
public void eventHandler(Event log) throws InterruptedException {
    Thread.sleep(5000);
    eventLogWsRepo.save(log);
    eventLogWsRepo.flush();
    log.info("Event Log save successful");
}

@EnableAsync
@Configuration
public class AsyncConfiguration {

    @Bean("asyncTaskExecutor")
    public Executor asyncTaskExecutor(){
        ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
        taskExecutor.setCorePoolSize(4);
        taskExecutor.setQueueCapacity(150);
        taskExecutor.setMaxPoolSize(4);
        taskExecutor.setThreadNamePrefix("AsyncTaskThread - ");
        taskExecutor.initialize();
        return taskExecutor;
    }
}

核心原因 #

多数据库场景下，异步线程无法自动绑定正确的事务管理器，且@EventListener与@Async组合时，事务上下文不会自动传递到异步线程中，导致@Transactional注解失效，JPA无法在事务内执行INSERT操作。

步骤1：明确指定事务管理器 #

多数据库配置时，你肯定定义了多个PlatformTransactionManager Bean，需要在事务注解中明确指定对应保存Event实体的数据库事务管理器。

步骤2：重构代码，确保事务注解生效 #

不要直接在@EventListener方法上同时叠加@Async和@Transactional，建议将业务逻辑抽离到单独的Service方法中，让事务和异步的代理逻辑正常生效：

1. 新增Service类

@Service
public class EventLogService {

    private final EventLogWsRepo eventLogWsRepo;

    public EventLogService(EventLogWsRepo eventLogWsRepo) {
        this.eventLogWsRepo = eventLogWsRepo;
    }

    // 替换为你配置的对应数据库事务管理器Bean名称，比如"wsTransactionManager"
    @Transactional(value = "wsTransactionManager")
    public void saveEventLog(Event log) {
        eventLogWsRepo.save(log);
        eventLogWsRepo.flush();
        log.info("Event Log save successful");
    }
}

2. 修改EventListener方法

@Async("asyncTaskExecutor")
@EventListener
public void eventHandler(Event log) throws InterruptedException {
    Thread.sleep(5000);
    eventLogService.saveEventLog(log);
}

步骤3：确保异步线程的上下文传递 #

自定义线程池时，需要显式启用上下文传递，保证事务等上下文能同步到异步线程：

@Bean("asyncTaskExecutor")
public Executor asyncTaskExecutor(){
    ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor();
    taskExecutor.setCorePoolSize(4);
    taskExecutor.setQueueCapacity(150);
    taskExecutor.setMaxPoolSize(4);
    taskExecutor.setThreadNamePrefix("AsyncTaskThread - ");
    // 启用上下文传递
    taskExecutor.setTaskDecorator(new ContextDecorator());
    taskExecutor.initialize();
    return taskExecutor;
}

private static class ContextDecorator implements TaskDecorator {
    @Override
    public Runnable decorate(Runnable runnable) {
        RequestAttributes context = RequestContextHolder.currentRequestAttributes();
        return () -> {
            try {
                RequestContextHolder.setRequestAttributes(context);
                runnable.run();
            } finally {
                RequestContextHolder.resetRequestAttributes();
            }
        };
    }
}

步骤4：验证Repository的数据源绑定 #

确认EventLogWsRepo属于目标数据库的Repository范围，比如你在多数据源配置时，通过@EnableJpaRepositories指定了basePackages和transactionManagerRef，要保证该Repository在对应的包下，且关联的事务管理器正确。

1. 重启应用，触发事件后查看SQL日志，确认INSERT语句生成。
2. 检查目标数据库，确认数据是否成功插入。
3. 若仍有问题，在saveEventLog方法中添加日志，打印当前事务状态，确认事务是否正常开启。

内容的提问来源于stack exchange，提问作者Tharindu Weerasinghe