Spring Boot3.x迁移：Spring Batch5自定义Jackson序列化器时如何启动Job？

当使用@EnableBatchProcessing（或继承DefaultBatchConfiguration）时，Spring Boot的Job自动启动机制会被禁用，以下是几种手动控制Job启动的可行方案：

方案一：使用JobLauncherCommandLineRunner触发Job #

这是最贴近Spring Boot原生自动启动逻辑的方式，支持通过配置或命令行参数指定要启动的Job。

在你的配置类中注册JobLauncherCommandLineRunner Bean：

@Configuration
@EnableBatchProcessing(executionContextSerializerRef = "myJacksonSerializer")
public class BatchConfig {

    // 自定义Jackson序列化器Bean
    @Bean
    public ExecutionContextSerializer myJacksonSerializer() {
        return new Jackson2ExecutionContextSerializer(new ObjectMapper());
    }

    // 注册JobLauncherCommandLineRunner，指定默认启动的Job
    @Bean
    public JobLauncherCommandLineRunner jobLauncherCommandLineRunner(JobLauncher jobLauncher, Job myJob) {
        JobLauncherCommandLineRunner runner = new JobLauncherCommandLineRunner(jobLauncher, myJob);
        // 可选：设置默认启动的Job名称，若不设置则需通过命令行参数指定
        runner.setJobNames("myJob");
        return runner;
    }

    // 定义你的Job、Step等Bean
    @Bean
    public Job myJob(JobRepository jobRepository, Step myStep) {
        return new JobBuilder("myJob", jobRepository)
                .start(myStep)
                .build();
    }

    // ... 其他Step等配置
}

如果需要灵活指定启动的Job，可以不设置setJobNames，而是在应用启动时通过命令行参数传递：

java -jar your-app.jar --spring.batch.job.names=myJob,anotherJob

方案二：通过ApplicationRunner/CommandLineRunner手动启动 #

如果需要更灵活的启动逻辑（比如加前置判断条件），可以实现ApplicationRunner或CommandLineRunner接口，在run方法中调用JobLauncher触发Job：

@Component
public class JobStarter implements ApplicationRunner {

    private final JobLauncher jobLauncher;
    private final Job myJob;

    public JobStarter(JobLauncher jobLauncher, Job myJob) {
        this.jobLauncher = jobLauncher;
        this.myJob = myJob;
    }

    @Override
    public void run(ApplicationArguments args) throws Exception {
        // 可添加自定义判断逻辑，比如根据配置决定是否启动
        if (shouldStartJob()) {
            JobParameters jobParameters = new JobParametersBuilder()
                    .addString("runId", String.valueOf(System.currentTimeMillis()))
                    .toJobParameters();
            jobLauncher.run(myJob, jobParameters);
        }
    }

    private boolean shouldStartJob() {
        // 自定义判断逻辑，比如读取配置文件中的开关
        return true;
    }
}

方案三：通过API接口触发Job #

如果需要外部触发（比如通过HTTP接口），可以编写一个Controller注入JobLauncher和Job，提供启动接口：

@RestController
@RequestMapping("/batch")
public class BatchController {

    private final JobLauncher jobLauncher;
    private final Job myJob;

    public BatchController(JobLauncher jobLauncher, Job myJob) {
        this.jobLauncher = jobLauncher;
        this.myJob = myJob;
    }

    @PostMapping("/start")
    public ResponseEntity<String> startJob() throws Exception {
        JobParameters jobParameters = new JobParametersBuilder()
                .addString("triggerTime", LocalDateTime.now().toString())
                .toJobParameters();
        jobLauncher.run(myJob, jobParameters);
        return ResponseEntity.ok("Job started successfully");
    }
}

注意事项 #

• 使用@EnableBatchProcessing时，Spring Boot的BatchAutoConfiguration会被自动排除，因此spring.batch.job.enabled等自动配置属性不再生效，必须通过上述手动方式控制启动。
• 每次启动Job时，建议生成唯一的JobParameters（比如时间戳），避免Spring Batch认为是重复执行而跳过。

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