如何为Spring Batch 5配置定时任务以定期执行Job？

1. 确认核心注解配置 #

启动类除了@EnableScheduling，必须添加@EnableBatchProcessing以开启Spring Batch核心功能，示例代码：

@SpringBootApplication
@EnableScheduling
@EnableBatchProcessing
public class BatchApplication {
    public static void main(String[] args) {
        SpringApplication.run(BatchApplication.class, args);
    }
}

2. 编写定时任务触发Job #

创建定时任务类，注入JobLauncher和你已配置好的hospitalDataJob，在定时方法中调用JobLauncher执行Job。必须生成唯一的JobParameters，否则Spring Batch会判定为重复任务而不执行。

示例代码：

@Component
public class BatchScheduler {

    private final JobLauncher jobLauncher;
    private final Job hospitalDataJob;

    // Spring 4.3+ 支持构造方法自动注入，无需@Autowired
    public BatchScheduler(JobLauncher jobLauncher, Job hospitalDataJob) {
        this.jobLauncher = jobLauncher;
        this.hospitalDataJob = hospitalDataJob;
    }

    // 每日0点触发的cron表达式
    @Scheduled(cron = "0 0 0 * * ?")
    public void runHospitalDataJob() {
        try {
            // 用当前时间戳生成唯一参数，确保每次任务实例不重复
            JobParameters jobParameters = new JobParametersBuilder()
                    .addLong("timestamp", System.currentTimeMillis())
                    .toJobParameters();
            
            // 执行Job
            jobLauncher.run(hospitalDataJob, jobParameters);
        } catch (JobExecutionException e) {
            // 此处添加日志记录或异常告警逻辑
            e.printStackTrace();
        }
    }
}

3. 检查application.yml配置 #

确保Spring Batch元数据存储配置正确，生产环境建议使用持久化数据库（如MySQL），同时禁用项目启动时自动执行Job：

spring:
  batch:
    job:
      enabled: false # 禁止项目启动时自动执行Job，仅通过定时触发
    jdbc:
      initialize-schema: always # 首次启动初始化Batch元数据表，生产环境可改为never
  datasource:
    url: jdbc:mysql://localhost:3306/batch_db?useSSL=false&serverTimezone=UTC
    username: root
    password: your_db_password
    driver-class-name: com.mysql.cj.jdbc.Driver

4. 关键注意事项 #

• JobParameters唯一性：每次执行必须传入不同参数（如时间戳、日期），否则Spring Batch会认为是同一Job实例，拒绝重复执行。
• 异常处理：jobLauncher.run()会抛出JobExecutionException，需捕获并处理（如日志记录、告警）。
• 异步执行配置：默认JobLauncher为同步执行，若需异步运行，可自定义线程池配置：

@Configuration
public class BatchAsyncConfig {

    @Bean
    public JobLauncher asyncJobLauncher(JobRepository jobRepository) throws Exception {
        SimpleJobLauncher jobLauncher = new SimpleJobLauncher();
        jobLauncher.setJobRepository(jobRepository);
        // 配置异步线程池
        jobLauncher.setTaskExecutor(new SimpleAsyncTaskExecutor("batch-task-"));
        jobLauncher.afterPropertiesSet();
        return jobLauncher;
    }
}

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