Spring Boot 2.X迁移至3.0.5+Spring Batch5.0.1遇JobRepository创建失败

一、核心问题定位 #

启动失败的根源是jobRepository Bean创建失败，结合你的迁移代码和调度服务实现，主要存在两处关键问题：

• DefaultBatchConfigurer 迁移到 DefaultBatchConfiguration 时的配置遗漏
• 调度服务代码存在语法与逻辑错误

二、DefaultBatchConfiguration 适配修复 #

你原代码重写setDataSource空实现的目的，应该是让Spring Batch使用内存型JobRepository（避免依赖数据库）。在Spring Batch 5.x中，DefaultBatchConfiguration的配置逻辑发生变化，需要通过重写createJobRepository方法实现相同效果：

@Configuration
@Slf4j
public class DefaultBatchConfig extends DefaultBatchConfiguration {

    @Override
    protected JobRepository createJobRepository() throws Exception {
        // 配置内存型JobRepository，无需数据源
        MapJobRepositoryFactoryBean factoryBean = new MapJobRepositoryFactoryBean();
        factoryBean.setTransactionManager(new ResourcelessTransactionManager());
        return factoryBean.getObject();
    }
}

如果你的场景需要数据库存储JobRepository，只需确保Spring容器中存在可用的DataSource Bean，DefaultBatchConfiguration会自动复用该数据源，无需额外重写（如需自定义配置可重写对应方法）。

三、调度服务代码错误修复 #

你的SchedulerServiceImpl存在两处明显问题：

1. ExecutorService的Lambda实例化方式完全错误，不符合API规范
2. JobExecutor的调用逻辑存在漏洞

修复后的代码如下：

@Service
@Slf4j
public class SchedulerServiceImpl implements SchedulerService {

    @Autowired
    private Map<String, JobExecutor> jobs;

    @Override
    @Async(value = "asyncPool")
    public void executeJob(JobParam job) {
        JobExecutor jobExecutor = jobs.get(job.getName());
        if (jobExecutor == null) {
            log.error("未找到名为{}的JobExecutor实例", job.getName());
            return;
        }
        // 直接调用JobExecutor执行任务
        jobExecutor.execute(job);
    }
}

若需基于指定线程池执行任务，可调整为：

@Service
@Slf4j
public class SchedulerServiceImpl implements SchedulerService {

    @Autowired
    private Map<String, JobExecutor> jobs;

    @Autowired
    @Qualifier("asyncPool")
    private Executor asyncThreadPool;

    @Override
    @Async(value = "asyncPool")
    public void executeJob(JobParam job) {
        JobExecutor jobExecutor = jobs.get(job.getName());
        if (jobExecutor == null) {
            log.error("未找到名为{}的JobExecutor实例", job.getName());
            return;
        }
        // 使用指定线程池异步执行
        asyncThreadPool.execute(() -> jobExecutor.execute(job));
    }
}

四、额外注意事项 #

• Spring Batch 5.x要求Java 17+，请确认运行环境版本符合要求
• 检查JobExecutor的实现类是否标注了@Component或相关注解，确保能被Spring扫描并注入到Map<String, JobExecutor>中
• 若使用数据库存储JobRepository，需确保数据库表结构已升级至Spring Batch 5.x版本（可通过spring.batch.jdbc.initialize-schema=always自动初始化）

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