SpringBatch中@Async致JPAItemWriter无法持久化数据问题求助

我之前碰到过几乎一模一样的坑！你遇到的核心问题就是Spring Batch默认使用的ResourcelessTransactionManager不支持事务挂起，而@Async会触发跨线程的事务上下文切换，直接导致事务机制紊乱，最终JPA的写入操作根本没在有效事务里执行，自然不会持久化到数据库。

问题根源拆解 #

Spring Batch默认的事务管理器ResourcelessTransactionManager是个“无资源”的管理器，只用来管理Batch自身的作业元数据事务，完全不支持JPA需要的事务挂起、传播等高级特性。当你在REST API里加了@Async后，方法会在新线程执行，Spring会尝试挂起原线程的事务上下文，但这个默认管理器做不到，就会抛出你看到的异常，后续的JPA写入操作也因为没有正确的事务支撑而失效。

具体解决方案 #

1. 给Spring Batch配置JPA兼容的事务管理器

你需要自定义BatchConfigurer，替换默认的事务管理器为JpaTransactionManager（或者DataSourceTransactionManager，取决于你的JPA配置）：

@Configuration
@EnableBatchProcessing
public class CustomBatchConfig implements BatchConfigurer {

    private final EntityManagerFactory entityManagerFactory;
    private final DataSource dataSource;

    // 注入Spring Boot自动配置的EntityManagerFactory和DataSource
    public CustomBatchConfig(EntityManagerFactory entityManagerFactory, DataSource dataSource) {
        this.entityManagerFactory = entityManagerFactory;
        this.dataSource = dataSource;
    }

    // 关键：替换事务管理器为JPA专用的
    @Override
    public PlatformTransactionManager getTransactionManager() {
        return new JpaTransactionManager(entityManagerFactory);
    }

    // 配套配置JobRepository，必须用上面的事务管理器
    @Override
    public JobRepository getJobRepository() throws Exception {
        JobRepositoryFactoryBean factoryBean = new JobRepositoryFactoryBean();
        factoryBean.setDataSource(dataSource);
        factoryBean.setTransactionManager(getTransactionManager());
        factoryBean.setIsolationLevelForCreate("ISOLATION_REPEATABLE_READ");
        factoryBean.afterPropertiesSet();
        return factoryBean.getObject();
    }

    // 实现其他BatchConfigurer方法，保持默认逻辑即可
    @Override
    public JobLauncher getJobLauncher() throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
        jobLauncher.setJobRepository(getJobRepository());
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }

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

2. 移除自定义Writer上的@Transactional

你的SampleWriter不需要自己加@Transactional注解！Spring Batch的Step会在自身的事务边界内调用write方法，你手动加的事务注解会和Batch的事务管理产生冲突，尤其是在@Async的线程环境下，会导致事务嵌套混乱。直接去掉就行：

@Service
public class SampleWriter extends JpaItemWriter<TestEntity> {
    @Autowired
    EntityManager entityManager;

    @Override
    public void write(List<TestEntity> entities) {
        this.doWrite(entityManager, entities);
    }
}

3. 确保@Async的配置正确

别忘了在你的Spring Boot主类或者配置类上加上@EnableAsync，让Spring识别@Async注解并创建异步代理。另外，@Async方法所在的Bean必须是Spring管理的（比如加了@Service/@Component等注解），而且不能在同一个Bean内调用@Async方法（否则代理不生效）。

为什么之前的事务传播配置没用？ #

因为根源不是传播行为的问题，而是底层的事务管理器根本不支持事务挂起这个操作。不管你设置REQUIRES_NEW还是其他传播级别，只要用的是ResourcelessTransactionManager，跨线程的事务切换就会失败，所以调整传播行为自然没用。

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