如何定义同时支持Spring Batch与Rest Api的TransactionManager

错误原因 #

这个错误核心是事务上下文类型不匹配：

• 定时任务触发Batch时，使用你配置的HibernateTransactionManager，事务上下文持有SessionHolder；
• Rest请求触发时，请求上下文可能已由默认JPA事务管理器初始化，持有EntityManagerHolder；
• 调用jobLauncher.run时，Batch尝试用HibernateTransactionManager获取SessionHolder，但当前上下文是EntityManagerHolder，直接导致类型转换失败。

解决方案一：统一使用JpaTransactionManager（推荐） #

JpaTransactionManager是Spring官方适配JPA的事务管理器，底层兼容Hibernate实现，同时能适配Rest请求的JPA事务上下文和Batch的事务需求。修改你的Batch配置类如下：

@Configuration
@EnableBatchProcessing
@RequiredArgsConstructor
@Slf4j
public class EodBatchConfig extends DefaultBatchConfigurer {
    // 注入EntityManagerFactory替代SessionFactory
    private final EntityManagerFactory entityManagerFactory;

    @Override
    public void setDataSource(DataSource dataSource) {
        // 保持原有忽略DataSource的逻辑
    }

    @Override
    public PlatformTransactionManager getTransactionManager() {
        JpaTransactionManager txManager = new JpaTransactionManager();
        txManager.setEntityManagerFactory(entityManagerFactory);
        return txManager;
    }
    // 其他Batch配置逻辑...
}

修改后，定时任务和Rest请求触发Batch时，事务上下文会统一使用EntityManagerHolder，彻底避免类型转换冲突，同时完全兼容Hibernate的数据库操作。

解决方案二：保留HibernateTransactionManager，隔离事务上下文 #

如果必须保留HibernateTransactionManager，需要确保Batch事务与Rest请求的事务上下文隔离，具体步骤：

1. 给Batch的事务管理器指定名称：

@Configuration
@EnableBatchProcessing
@RequiredArgsConstructor
@Slf4j
public class EodBatchConfig extends DefaultBatchConfigurer {
    private final SessionFactory sessionFactory;

    @Override
    public void setDataSource(DataSource dataSource) {
        // 保持原有逻辑
    }

    // 给事务管理器命名为batchTransactionManager
    @Override
    @Bean(name = "batchTransactionManager")
    public HibernateTransactionManager getTransactionManager() {
        HibernateTransactionManager txManager = new HibernateTransactionManager();
        txManager.setSessionFactory(sessionFactory);
        return txManager;
    }
    // 其他配置...
}

2. 在调用jobLauncher.run的方法上，明确指定使用Batch的事务管理器，并设置事务传播行为为REQUIRES_NEW（强制新建独立事务，避免与Rest请求的事务嵌套）：

@Service
@RequiredArgsConstructor
public class JobService {
    private final JobLauncher jobLauncher;
    private final JobRegistry jobRegistry;

    // 指定使用Batch的事务管理器，且新建独立事务
    @Transactional(transactionManager = "batchTransactionManager", propagation = Propagation.REQUIRES_NEW)
    public BatchStatus rerunJob(String name, LocalDate date) {
        JobParameters jobParameters = new JobParametersBuilder()
                .addLocalDate("date", date)
                .toJobParameters();
        try {
            Job job = jobRegistry.getJob(name);
            JobExecution execution = jobLauncher.run(job, jobParameters);
            return execution.getStatus();
        } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException | JobParametersInvalidException e) {
            log.error("Job execution failed", e);
            throw new RuntimeException("Failed to rerun job", e);
        }
    }
}

3. （可选）如果项目存在其他JPA事务场景，给JPA事务管理器添加@Primary注解，确保默认事务管理器为JPA：

@Configuration
public class TransactionConfig {
    @Autowired
    private EntityManagerFactory entityManagerFactory;

    @Primary
    @Bean(name = "jpaTransactionManager")
    public JpaTransactionManager jpaTransactionManager() {
        return new JpaTransactionManager(entityManagerFactory);
    }
}

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