Spring Batch 4.x升级至5.x：BatchMetaDataConfiguration替代方案咨询

问题描述 #

在Spring Batch 5中，MapJobRepositoryFactoryBean已被移除，原有的基于内存存储作业元数据的配置（如下代码）无法继续使用，需要找到替代方案实现相同的内存式元数据管理功能：

@Configuration
@EnableBatchProcessing
public class BatchMetaDataConfiguration {

@Bean
public ResourcelessTransactionManager transactionManager() {
return new ResourcelessTransactionManager();
}

@Bean
public MapJobRepositoryFactoryBean mapJobRepositoryFactory
(ResourcelessTransactionManager   txManager)
throws Exception {
MapJobRepositoryFactoryBean factory = new MapJobRepositoryFactoryBean(txManager);
factory.afterPropertiesSet();
return factory;
}

@Bean
public JobRepository jobRepository(MapJobRepositoryFactoryBean factory) throws Exception {
return factory.getObject();
}

@Bean
public JobExplorer jobExplorer(MapJobRepositoryFactoryBean factory) {
return new SimpleJobExplorer(factory.getJobInstanceDao(), factory.getJobExecutionDao(),
factory.getStepExecutionDao(), factory.getExecutionContextDao());
}

@Bean
public SimpleJobLauncher jobLauncher(JobRepository jobRepository) {
SimpleJobLauncher launcher = new SimpleJobLauncher();
launcher.setJobRepository(jobRepository);
return launcher;
}

}

替代方案与实现 #

Spring Batch 5中用MapJobRepository直接替代原有的MapJobRepositoryFactoryBean，同时配套使用MapJobExplorerFactoryBean来创建JobExplorer，以下是完整的替代配置：

@Configuration
@EnableBatchProcessing
public class BatchMetaDataConfiguration {

    // 事务管理器仍使用ResourcelessTransactionManager，适配内存存储场景
    @Bean
    public ResourcelessTransactionManager transactionManager() {
        return new ResourcelessTransactionManager();
    }

    // 直接创建基于内存的JobRepository
    @Bean
    public JobRepository jobRepository(ResourcelessTransactionManager transactionManager) throws Exception {
        MapJobRepository mapJobRepository = new MapJobRepository(transactionManager);
        mapJobRepository.afterPropertiesSet();
        return mapJobRepository;
    }

    // 通过MapJobExplorerFactoryBean创建JobExplorer，关联内存存储的DAO
    @Bean
    public MapJobExplorerFactoryBean mapJobExplorerFactoryBean(JobRepository jobRepository) {
        MapJobRepository mapJobRepository = (MapJobRepository) jobRepository;
        MapJobExplorerFactoryBean factoryBean = new MapJobExplorerFactoryBean();
        factoryBean.setJobInstanceDao(mapJobRepository.getJobInstanceDao());
        factoryBean.setJobExecutionDao(mapJobRepository.getJobExecutionDao());
        factoryBean.setStepExecutionDao(mapJobRepository.getStepExecutionDao());
        factoryBean.setExecutionContextDao(mapJobRepository.getExecutionContextDao());
        return factoryBean;
    }

    @Bean
    public JobExplorer jobExplorer(MapJobExplorerFactoryBean factoryBean) throws Exception {
        return factoryBean.getObject();
    }

    // JobLauncher配置保持原有逻辑，关联新的JobRepository
    @Bean
    public SimpleJobLauncher jobLauncher(JobRepository jobRepository) {
        SimpleJobLauncher launcher = new SimpleJobLauncher();
        launcher.setJobRepository(jobRepository);
        return launcher;
    }
}

关键变化说明 #

• 移除了MapJobRepositoryFactoryBean，直接实例化MapJobRepository并完成初始化
• 使用MapJobExplorerFactoryBean替代手动创建SimpleJobExplorer，简化了内存式JobExplorer的配置流程
• 事务管理器ResourcelessTransactionManager可以继续使用，因为它适配内存存储无需持久化事务的场景
• 所有核心组件（JobRepository、JobExplorer、JobLauncher）的依赖关系保持兼容原有逻辑

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