原文： https://howtodoinjava.com/spring-batch/job-scheduler-example/

在企业应用程序中，您将需要将 cron 表达式传递给 Spring TaskScheduler，在固定的时间表上定期执行 Spring Batch 作业。 在此示例中，我们将使用 spring 的内置调度功能执行示例 Spring Batch 作业。

配置批处理作业调度程序

要配置，批处理作业调度分两个步骤完成：

  1. 启用带有@EnableScheduling注解的调度。
  2. 创建带有@Scheduled注解的方法，并使用 cron 作业提供重复详细信息。 在此方法内添加作业执行逻辑。

Cron scheduling on spring batch job

  1. package com.howtodoinjava.demo;
  3. import org.springframework.batch.core.Job;
  4. import org.springframework.batch.core.JobParameters;
  5. import org.springframework.batch.core.JobParametersBuilder;
  6. import org.springframework.batch.core.launch.JobLauncher;
  7. import org.springframework.beans.factory.annotation.Autowired;
  8. import org.springframework.boot.SpringApplication;
  9. import org.springframework.boot.autoconfigure.SpringBootApplication;
  10. import org.springframework.scheduling.annotation.EnableScheduling;
  11. import org.springframework.scheduling.annotation.Scheduled;
  13. @SpringBootApplication
  14. @EnableScheduling
  15. public class App
  16. {
  17.     @Autowired
  18.     JobLauncher jobLauncher;
  20.     @Autowired
  21.     Job job;
  23.     public static void main(String[] args) 
  24.     {
  25.         SpringApplication.run(App.class, args);
  26.     }
  28.     @Scheduled(cron = "0 */1 * * * ?")
  29.     public void perform() throws Exception 
  30.     {
  31.         JobParameters params = new JobParametersBuilder()
  32.                 .addString("JobID", String.valueOf(System.currentTimeMillis()))
  33.                 .toJobParameters();
  34.         jobLauncher.run(job, params);
  35.     }
  36. }

批处理作业将在应用程序启动后每隔一分钟运行一次。

要引用作业和任务源代码，请阅读 Spring batch Java 配置示例。

示例

现在，如果您运行该应用程序并验证日志，您将看到该作业每分钟都在运行。

Console

  1. 2018-07-04 15:57:00.073  INFO 7320 --- [pool-1-thread-1] o.s.b.c.l.support.SimpleJobLauncher      
  2. : Job: [SimpleJob: [name=demoJob]] launched with the following parameters: [{JobID=1530700020003}]
  4. 2018-07-04 15:57:00.097  INFO 7320 --- [pool-1-thread-1] o.s.batch.core.job.SimpleStepHandler     
  5. : Executing step: [stepOne]
  7. MyTaskOne start..
  8. MyTaskOne done..
  10. 2018-07-04 15:57:00.118  INFO 7320 --- [pool-1-thread-1] o.s.batch.core.job.SimpleStepHandler     
  11. : Executing step: [stepTwo]
  13. MyTaskTwo start..
  14. MyTaskTwo done..
  16. 2018-07-04 15:57:00.125  INFO 7320 --- [pool-1-thread-1] o.s.b.c.l.support.SimpleJobLauncher      
  17. : Job: [SimpleJob: [name=demoJob]] completed with the following parameters: [{JobID=1530700020003}] 
  18. and the following status: [COMPLETED]
  20. 2018-07-04 15:58:00.007  INFO 7320 --- [pool-1-thread-1] o.s.b.c.l.support.SimpleJobLauncher      
  21. : Job: [SimpleJob: [name=demoJob]] launched with the following parameters: [{JobID=1530700080002}]
  23. 2018-07-04 15:58:00.011  INFO 7320 --- [pool-1-thread-1] o.s.batch.core.job.SimpleStepHandler     
  24. : Executing step: [stepOne]
  26. MyTaskOne start..
  27. MyTaskOne done..
  29. 2018-07-04 15:58:00.021  INFO 7320 --- [pool-1-thread-1] o.s.batch.core.job.SimpleStepHandler     
  30. : Executing step: [stepTwo]
  32. MyTaskTwo start..
  33. MyTaskTwo done..
  35. 2018-07-04 15:58:00.029  INFO 7320 --- [pool-1-thread-1] o.s.b.c.l.support.SimpleJobLauncher      
  36. : Job: [SimpleJob: [name=demoJob]] completed with the following parameters: [{JobID=1530700080002}] 
  37. and the following status: [COMPLETED]

将我的问题放在评论部分。

学习愉快！