Spring Boot2.7.10下Spring Batch4中JPA事务管理器创建受阻的解决办法

核心问题原因 #

在Spring Batch 4中，自定义BatchConfigurer会覆盖Spring Boot自动配置的JPA相关事务管理器设置，导致JPA无法正常参与批处理的事务管理，进而出现持久化操作失效、事务异常等问题。

可行解决办法 #

1. 复用自动配置组件，继承DefaultBatchConfigurer #

不要完全从零实现BatchConfigurer，而是继承Spring Boot提供的DefaultBatchConfigurer，仅覆盖需要自定义的部分，保留原有JPA事务管理的关联逻辑：

import org.springframework.batch.core.configuration.annotation.DefaultBatchConfigurer;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import javax.sql.DataSource;

@Configuration
public class CustomBatchConfigurer extends DefaultBatchConfigurer {

    public CustomBatchConfigurer(@Autowired(required = false) DataSource dataSource) {
        super(dataSource);
    }

    // 仅覆盖你需要自定义的方法（比如配置JobLauncher异步执行），不要重写getTransactionManager()
    /*
    @Override
    public JobLauncher getJobLauncher() throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
        jobLauncher.setJobRepository(getJobRepository());
        jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor());
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }
    */
}

这种方式的核心是保留父类中自动绑定的JpaTransactionManager，避免手动替换事务管理器导致JPA上下文断裂。

2. 显式绑定JPA事务管理器到自定义BatchConfigurer #

如果必须完全自定义BatchConfigurer，要确保Spring Batch使用的事务管理器是JPA的JpaTransactionManager，而非默认的DataSourceTransactionManager：

import org.springframework.batch.core.configuration.annotation.BatchConfigurer;
import org.springframework.batch.core.explore.JobExplorer;
import org.springframework.batch.core.explore.support.JobExplorerFactoryBean;
import org.springframework.batch.core.launch.JobLauncher;
import org.springframework.batch.core.launch.support.SimpleJobLauncher;
import org.springframework.batch.core.repository.JobRepository;
import org.springframework.batch.core.repository.support.JobRepositoryFactoryBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.orm.jpa.JpaTransactionManager;
import javax.sql.DataSource;

@Configuration
public class CustomJpaBatchConfigurer implements BatchConfigurer {

    private final DataSource dataSource;
    private final JpaTransactionManager transactionManager;

    @Autowired
    public CustomJpaBatchConfigurer(DataSource dataSource, JpaTransactionManager transactionManager) {
        this.dataSource = dataSource;
        this.transactionManager = transactionManager;
    }

    @Override
    public JobRepository getJobRepository() throws Exception {
        JobRepositoryFactoryBean factory = new JobRepositoryFactoryBean();
        factory.setDataSource(dataSource);
        // 绑定JPA事务管理器到批处理仓库
        factory.setTransactionManager(transactionManager);
        factory.setDatabaseType("MYSQL"); // 根据你的数据库类型调整
        factory.afterPropertiesSet();
        return factory.getObject();
    }

    @Override
    public JobLauncher getJobLauncher() throws Exception {
        SimpleJobLauncher launcher = new SimpleJobLauncher();
        launcher.setJobRepository(getJobRepository());
        launcher.afterPropertiesSet();
        return launcher;
    }

    @Override
    public JobExplorer getJobExplorer() throws Exception {
        JobExplorerFactoryBean factory = new JobExplorerFactoryBean();
        factory.setDataSource(dataSource);
        factory.afterPropertiesSet();
        return factory.getObject();
    }

    @Override
    public JpaTransactionManager getTransactionManager() {
        return transactionManager;
    }
}

这里的关键是将Spring Boot自动配置的JpaTransactionManager注入并传递给JobRepositoryFactoryBean，确保批处理事务与JPA事务上下文一致。

3. 配置文件指定事务管理器优先级 #

如果不需要自定义BatchConfigurer，只是默认配置导致冲突，可以在配置文件中指定Spring Batch使用的事务管理器Bean名称：

# application.properties
spring.batch.transaction-manager=transactionManager

transactionManager是Spring Boot自动配置的JpaTransactionManager默认Bean名称，若你自定义了JPA事务管理器的名称，替换为对应名称即可。

验证方式 #

完成配置后，可通过以下方式确认JPA恢复正常：

• 在ItemWriter中执行JPA持久化操作，检查数据是否正确写入数据库
• 查看日志，确认事务管理器类型为org.springframework.orm.jpa.JpaTransactionManager
• 测试批处理回滚场景，验证JPA操作是否随批处理事务一起回滚

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