Spring Batch异步执行时出现无事务异常问题求助

这个问题我之前帮不少开发者排查过，核心原因是异步线程默认不会继承原线程的Spring事务上下文——Spring的事务是基于ThreadLocal存储的，当你用自定义的ThreadPoolTaskExecutor执行Job时，新启动的异步线程无法获取到原线程的事务相关上下文，导致数据库操作时抛出no transaction is in progress异常。

下面给你一步步的解决方案：

1. 配置支持上下文传递的异步TaskExecutor #

首先要修改你的ThreadPoolTaskExecutor配置，添加一个TaskDecorator来传递原线程的RequestAttributes（里面包含事务同步所需的上下文信息）：

@Bean
public ThreadPoolTaskExecutor batchTaskExecutor() {
    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
    executor.setCorePoolSize(5); // 根据你的业务调整核心线程数
    executor.setMaxPoolSize(10); // 最大线程数
    executor.setQueueCapacity(25); // 任务队列容量
    executor.setThreadNamePrefix("batch-exec-"); // 线程名前缀，方便日志排查

    // 关键：添加任务装饰器，传递原线程的RequestAttributes
    executor.setTaskDecorator(runnable -> {
        RequestAttributes attributes = RequestContextHolder.getRequestAttributes();
        return () -> {
            try {
                RequestContextHolder.setRequestAttributes(attributes);
                runnable.run();
            } finally {
                RequestContextHolder.resetRequestAttributes();
            }
        };
    });

    executor.initialize();
    return executor;
}

2. 配置JobLauncher使用该异步TaskExecutor #

确保你的JobLauncher明确使用上面配置的TaskExecutor，而不是默认的同步执行器：

@Bean
public JobLauncher asyncJobLauncher(JobRepository jobRepository, ThreadPoolTaskExecutor batchTaskExecutor) {
    SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
    jobLauncher.setJobRepository(jobRepository);
    jobLauncher.setTaskExecutor(batchTaskExecutor);
    jobLauncher.afterPropertiesSet();
    return jobLauncher;
}

3. 验证Spring Batch的事务管理器配置 #

Spring Batch的JobRepository和Step执行依赖于正确的事务管理器配置，确保你已经配置了对应的PlatformTransactionManager，并且JobRepository关联了它：

@Bean
public PlatformTransactionManager batchTransactionManager(DataSource dataSource) {
    return new DataSourceTransactionManager(dataSource);
}

@Bean
public JobRepository jobRepository(DataSource dataSource, PlatformTransactionManager batchTransactionManager) throws Exception {
    JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
    factoryBean.setDataSource(dataSource);
    factoryBean.setTransactionManager(batchTransactionManager);
    factoryBean.setIsolationLevelForCreate("ISOLATION_REPEATABLE_READ"); // Spring Batch默认的隔离级别
    factoryBean.setTablePrefix("BATCH_"); // 如果你用的是默认的表前缀，可根据实际调整
    return factoryBean.getObject();
}

4. 检查业务代码中的事务使用 #

如果你的数据库操作是在Step的ItemProcessor或ItemWriter中，Spring Batch默认会为每个Chunk自动开启事务，不需要额外加@Transactional；但如果是在JobListener、StepListener或者自定义的异步业务方法中，需要确保：

• 方法是public的（Spring代理只对public方法生效）
• 标注了@Transactional，并且指定了正确的事务管理器（如果有多个事务管理器的话）

比如：

@Component
public class CustomJobListener implements JobExecutionListener {

    private final YourRepository repository;

    public CustomJobListener(YourRepository repository) {
        this.repository = repository;
    }

    @Transactional(transactionManager = "batchTransactionManager")
    @Override
    public void afterJob(JobExecution jobExecution) {
        // 这里的数据库操作会被事务管理覆盖
        repository.updateStatus(jobExecution.getJobId(), jobExecution.getStatus());
    }
}

为什么这样能解决问题？ #

Spring的事务上下文（比如TransactionSynchronizationManager中的信息）是绑定在当前线程的ThreadLocal中的，异步线程默认不会继承这些信息。通过TaskDecorator把原线程的RequestAttributes传递到异步线程中，Spring Batch的Step执行逻辑就能正确识别并使用配置好的事务管理器，为数据库操作开启必要的事务。

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