如何在SchedulingConfigurer中添加多个Spring Batch调度作业

你遇到的报错是因为Spring依赖注入阶段产生了冲突：你使用@Autowired private Job job按类型注入Job实例，当你新增第二个Spring Batch作业后，Spring容器中会存在2个Job类型的Bean，框架无法判断要注入哪一个，因此抛出该错误。

推荐使用「批量注入所有Job实例」的方式适配动态调度场景，修改步骤如下：

• 移除原有的单个Job注入逻辑，改为注入容器中所有Job类型的Bean，Spring会自动将Bean名称作为Key、Job实例作为Value存入Map中
• 调整executeJob方法，根据传入的作业名从Map中获取匹配的Job实例再执行
• 为每个作业单独调用addTriggerTask添加触发规则，注意匹配对应的CRON配置key和作业名
• 定义Job Bean时需指定与调度逻辑匹配的Bean名称

修改后的完整代码示例：

@Configuration
@EnableScheduling
public class DynamicScheduler implements SchedulingConfigurer {

    private static Logger LOGGER = LoggerFactory.getLogger(DynamicScheduler.class);

    @Autowired
    ConfigRepo repo;

    @Autowired
    JobLauncher jobLauncher;

    // 注入容器中所有Job类型的Bean，key为Bean名称，value为Job实例
    @Autowired
    private Map<String, Job> allJobs;


    @Override
    public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        // 添加第一个作业调度规则
        taskRegistrar.addTriggerTask(() -> executeJob("job1"), t -> {
            CronTrigger crontrigger = new CronTrigger(repo.findById("cronExpressionJob1").get().getConfigValue());
            return crontrigger.nextExecutionTime(t);
        });
        // 添加第二个作业调度规则
        taskRegistrar.addTriggerTask(() -> executeJob("job2"), t -> {
            CronTrigger crontrigger = new CronTrigger(repo.findById("cronExpressionJob2").get().getConfigValue());
            return crontrigger.nextExecutionTime(t);
        });
        // 更多作业可以按照该格式继续添加
    }

    public void executeJob(String jobName) {        
        try {
            // 从Map中获取对应名称的Job实例
            Job targetJob = allJobs.get(jobName);
            if (targetJob == null) {
                LOGGER.error("未找到名称为{}的作业实例", jobName);
                return;
            }
            JobParameters jobParameters = new JobParametersBuilder()
                    .addString("startTime", String.valueOf(System.currentTimeMillis())).toJobParameters();
            jobLauncher.run(targetJob, jobParameters);
        } catch (Exception e) {
            LOGGER.error("作业{}执行失败", jobName, e);
        }
    }
}

对应的作业Bean定义示例：

@Configuration
public class JobConfig {
    // 指定Bean名称为job1，和调度逻辑中的作业名匹配
    @Bean("job1")
    public Job job1(JobRepository jobRepository, Step step1) {
        return new JobBuilder("job1", jobRepository)
                .start(step1)
                .build();
    }

    // 指定Bean名称为job2，和调度逻辑中的作业名匹配
    @Bean("job2")
    public Job job2(JobRepository jobRepository, Step step2) {
        return new JobBuilder("job2", jobRepository)
                .start(step2)
                .build();
    }
}

• 如果作业数量不固定，可以把作业名称、CRON配置key都存在数据库中，动态遍历添加触发任务，不需要硬编码每个作业的调度规则
• 原代码中JobParameters的key使用jobName会导致不同作业的参数key不同，统一用固定key比如startTime更规范，只要保证每次运行参数唯一即可

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