原文： https://howtodoinjava.com/spring-batch/quartz-h2-jdbcjobstore-example/

学习使用 Quartz 调度程序和 Quartz 用于记录作业和触发信息的持久性数据库存储记录来执行多个 Spring Batch 作业。 我在启用 Web 控制台的情况下使用H2数据库来查看数据库表中的数据。 您可以根据需要选择数据库。

项目结构

目标

在本教程中，我们将创建一个 Spring 应用程序并执行以下任务。

  1. 创建 2 个 Spring Batch 作业。 每个作业都有多个步骤。
  2. 创建 Quartz 作业和触发器，它们将运行在步骤 1 中创建的 SpringBatch。
  3. Quartz 作业和触发器将存储在文件系统中的持久性 H2 数据库中。
  4. 通过 H2 控制台验证存储在 DB 中的触发信息。
  5. 使用LoggingTriggerHistoryPlugin在日志中记录完整的触发器历史记录。

项目结构

Spring Batch Quartz H2 Jdbcjobstore 示例 - 图1

项目结构

Maven 依赖

我们需要具有以下依赖才能运行此项目。

pom.xml

  1. <project xmlns="http://maven.apache.org/POM/4.0.0"
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd;
  4.     <modelVersion>4.0.0</modelVersion>
  6.     <groupId>com.howtodoinjava</groupId>
  7.     <artifactId>App</artifactId>
  8.     <version>0.0.1-SNAPSHOT</version>
  9.     <packaging>jar</packaging>
  11.     <name>App</name>
  12.     <url>http://maven.apache.org</url>
  14.     <parent>
  15.         <groupId>org.springframework.boot</groupId>
  16.         <artifactId>spring-boot-starter-parent</artifactId>
  17.         <version>2.0.3.RELEASE</version>
  18.     </parent>
  20.     <properties>
  21.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  22.     </properties>
  24.     <dependencies>
  25.         <dependency>
  26.             <groupId>org.springframework.boot</groupId>
  27.             <artifactId>spring-boot-starter-web</artifactId>
  28.         </dependency>
  29.         <dependency>
  30.             <groupId>org.springframework.boot</groupId>
  31.             <artifactId>spring-boot-starter-batch</artifactId>
  32.         </dependency>
  33.         <dependency>
  34.             <groupId>org.springframework.boot</groupId>
  35.             <artifactId>spring-boot-starter-quartz</artifactId>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.springframework</groupId>
  39.             <artifactId>spring-context-support</artifactId>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>com.h2database</groupId>
  43.             <artifactId>h2</artifactId>
  44.             <scope>runtime</scope>
  45.         </dependency>
  46.         <dependency>
  47.             <groupId>com.mchange</groupId>
  48.             <artifactId>c3p0</artifactId>
  49.             <version>0.9.5.2</version>
  50.         </dependency>
  51.     </dependencies>
  53.     <build>
  54.         <plugins>
  55.             <plugin>
  56.                 <groupId>org.springframework.boot</groupId>
  57.                 <artifactId>spring-boot-maven-plugin</artifactId>
  58.             </plugin>
  59.         </plugins>
  60.     </build>
  62.     <repositories>
  63.         <repository>
  64.             <id>repository.spring.release</id>
  65.             <name>Spring GA Repository</name>
  66.             <url>http://repo.spring.io/release</url>
  67.         </repository>
  68.     </repositories>
  69. </project>

配置 Spring Batch 作业和任务

创建一些Tasklets和批处理作业以执行。

MyTaskOne.java and MyTaskTwo.java

  1. import org.springframework.batch.core.StepContribution;
  2. import org.springframework.batch.core.scope.context.ChunkContext;
  3. import org.springframework.batch.core.step.tasklet.Tasklet;
  4. import org.springframework.batch.repeat.RepeatStatus;
  6. public class MyTaskOne implements Tasklet {
  8.     public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
  9.         System.out.println("MyTaskOne start..");
  11.         // ... your code
  13.         System.out.println("MyTaskOne done..");
  14.         return RepeatStatus.FINISHED;
  15.     }    
  16. }
  18. public class MyTaskTwo implements Tasklet {
  20.     public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
  21.         System.out.println("MyTaskTwo start..");
  23.         // ... your code
  25.         System.out.println("MyTaskTwo done..");
  26.         return RepeatStatus.FINISHED;
  27.     }    
  28. }

BatchConfig.java

  1. import org.springframework.batch.core.Job;
  2. import org.springframework.batch.core.Step;
  3. import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
  4. import org.springframework.batch.core.configuration.annotation.JobBuilderFactory;
  5. import org.springframework.batch.core.configuration.annotation.StepBuilderFactory;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  10. import com.howtodoinjava.demo.tasks.MyTaskOne;
  11. import com.howtodoinjava.demo.tasks.MyTaskTwo;
  13. @Configuration
  14. @EnableBatchProcessing
  15. public class BatchConfig {
  17.     @Autowired
  18.     private JobBuilderFactory jobs;
  20.     @Autowired
  21.     private StepBuilderFactory steps;
  23.     @Bean
  24.     public Step stepOne(){
  25.         return steps.get("stepOne")
  26.                 .tasklet(new MyTaskOne())
  27.                 .build();
  28.     }
  30.     @Bean
  31.     public Step stepTwo(){
  32.         return steps.get("stepTwo")
  33.                 .tasklet(new MyTaskTwo())
  34.                 .build();
  35.     }   
  37.     @Bean(name="demoJobOne")
  38.     public Job demoJobOne(){
  39.         return jobs.get("demoJobOne")
  40.                 .start(stepOne())
  41.                 .next(stepTwo())
  42.                 .build();
  43.     }
  45.     @Bean(name="demoJobTwo")
  46.     public Job demoJobTwo(){
  47.         return jobs.get("demoJobTwo")
  48.                 .flow(stepOne())
  49.                 .build()
  50.                 .build();
  51.     }
  52. }

application.properties

  1. #Disable batch job's auto start 
  2. spring.batch.job.enabled=false

配置 Quartz 作业和触发器

现在创建 Quartz 作业，它将运行 SpringBatch。

CustomQuartzJob.java

  1. import org.quartz.DisallowConcurrentExecution;
  2. import org.quartz.JobExecutionContext;
  3. import org.quartz.JobExecutionException;
  4. import org.quartz.PersistJobDataAfterExecution;
  5. import org.springframework.batch.core.Job;
  6. import org.springframework.batch.core.JobParameters;
  7. import org.springframework.batch.core.JobParametersBuilder;
  8. import org.springframework.batch.core.configuration.JobLocator;
  9. import org.springframework.batch.core.launch.JobLauncher;
  10. import org.springframework.context.ApplicationContext;
  11. import org.springframework.scheduling.quartz.QuartzJobBean;
  13. @PersistJobDataAfterExecution
  14. @DisallowConcurrentExecution
  15. public class CustomQuartzJob extends QuartzJobBean {
  17.     private String jobName;
  18.     private JobLauncher jobLauncher;
  19.     private JobLocator jobLocator;
  21.     public String getJobName() {
  22.         return jobName;
  23.     }
  25.     public void setJobName(String jobName) {
  26.         this.jobName = jobName;
  27.     }
  29.     @Override
  30.     protected void executeInternal(JobExecutionContext context) throws JobExecutionException 
  31.     {
  32.         try 
  33.         {
  34.             ApplicationContext applicationContext = (ApplicationContext) context.getScheduler().getContext().get("applicationContext");
  35.             jobLocator = (JobLocator) applicationContext.getBean(JobLocator.class);
  36.             jobLauncher = (JobLauncher) applicationContext.getBean(JobLauncher.class);
  37.             Job job = jobLocator.getJob(jobName);
  38.             JobParameters params = new JobParametersBuilder()
  39.                     .addString("JobID", String.valueOf(System.currentTimeMillis()))
  40.                     .toJobParameters();
  42.             jobLauncher.run(job, params);
  43.         } 
  44.         catch (Exception e) 
  45.         {
  46.             e.printStackTrace();
  47.         }
  48.     }
  49. }

QuartzConfig.java

  1. import java.io.IOException;
  2. import java.util.Properties;
  4. import org.quartz.JobBuilder;
  5. import org.quartz.JobDataMap;
  6. import org.quartz.JobDetail;
  7. import org.quartz.SchedulerException;
  8. import org.quartz.SimpleScheduleBuilder;
  9. import org.quartz.Trigger;
  10. import org.quartz.TriggerBuilder;
  11. import org.springframework.batch.core.configuration.JobRegistry;
  12. import org.springframework.batch.core.configuration.support.JobRegistryBeanPostProcessor;
  13. import org.springframework.beans.factory.config.PropertiesFactoryBean;
  14. import org.springframework.context.annotation.Bean;
  15. import org.springframework.context.annotation.Configuration;
  16. import org.springframework.core.io.ClassPathResource;
  17. import org.springframework.scheduling.quartz.SchedulerFactoryBean;
  19. import com.howtodoinjava.demo.jobs.CustomQuartzJob;
  21. @Configuration
  22. public class QuartzConfig
  23. {    
  24.     @Bean
  25.     public JobRegistryBeanPostProcessor jobRegistryBeanPostProcessor(JobRegistry jobRegistry) {
  26.         JobRegistryBeanPostProcessor jobRegistryBeanPostProcessor = new JobRegistryBeanPostProcessor();
  27.         jobRegistryBeanPostProcessor.setJobRegistry(jobRegistry);
  28.         return jobRegistryBeanPostProcessor;
  29.     }
  31.     @Bean
  32.     public JobDetail jobOneDetail() {
  33.         //Set Job data map
  34.         JobDataMap jobDataMap = new JobDataMap();
  35.         jobDataMap.put("jobName", "demoJobOne");
  37.         return JobBuilder.newJob(CustomQuartzJob.class)
  38.                 .withIdentity("demoJobOne",null)
  39.                 .setJobData(jobDataMap)
  40.                 .storeDurably()
  41.                 .build();
  42.     }
  44.     @Bean
  45.     public JobDetail jobTwoDetail() {
  46.         //Set Job data map
  47.         JobDataMap jobDataMap = new JobDataMap();
  48.         jobDataMap.put("jobName", "demoJobTwo");
  50.         return JobBuilder.newJob(CustomQuartzJob.class)
  51.                 .withIdentity("demoJobTwo",null)
  52.                 .setJobData(jobDataMap)
  53.                 .storeDurably()
  54.                 .build();
  55.     }
  57.     @Bean
  58.     public Trigger jobOneTrigger() 
  59.     {
  60.         SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder
  61.                 .simpleSchedule()
  62.                 .withIntervalInSeconds(10)
  63.                 .repeatForever();
  65.         return TriggerBuilder
  66.                 .newTrigger()
  67.                 .forJob(jobOneDetail())
  68.                 .withIdentity("jobOneTrigger",null)
  69.                 .withSchedule(scheduleBuilder)
  70.                 .build();
  71.     }
  73.     @Bean
  74.     public Trigger jobTwoTrigger() 
  75.     {
  76.         SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder
  77.                 .simpleSchedule()
  78.                 .withIntervalInSeconds(20)
  79.                 .repeatForever();
  81.         return TriggerBuilder
  82.                 .newTrigger()
  83.                 .forJob(jobTwoDetail())
  84.                 .withIdentity("jobTwoTrigger",null)
  85.                 .withSchedule(scheduleBuilder)
  86.                 .build();
  87.     }
  89.     @Bean
  90.     public SchedulerFactoryBean schedulerFactoryBean() throws IOException, SchedulerException 
  91.     {
  92.         SchedulerFactoryBean scheduler = new SchedulerFactoryBean();
  93.         scheduler.setTriggers(jobOneTrigger(), jobTwoTrigger());
  94.         scheduler.setQuartzProperties(quartzProperties());
  95.         scheduler.setJobDetails(jobOneDetail(), jobTwoDetail());
  96.         scheduler.setApplicationContextSchedulerContextKey("applicationContext");
  97.         return scheduler;
  98.     }
  100.     public Properties quartzProperties() throws IOException 
  101.     {
  102.         PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
  103.         propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
  104.         propertiesFactoryBean.afterPropertiesSet();
  105.         return propertiesFactoryBean.getObject();
  106.     }
  107. }

quartz.properties

  1. #scheduler name will be "MyScheduler"
  2. org.quartz.scheduler.instanceName=TestScheduler
  3. org.quartz.scheduler.instanceId=AUTO
  5. #maximum of 3 jobs can be run simultaneously
  6. org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPool
  7. org.quartz.threadPool.threadCount=50
  9. #Log trigger history
  10. org.quartz.plugin.triggerHistory.class=org.quartz.plugins.history.LoggingTriggerHistoryPlugin
  11. org.quartz.plugin.triggerHistory.triggerFiredMessage=Trigger [{1}.{0}] fired job [{6}.{5}] scheduled at: {2, date, dd-MM-yyyy HH:mm:ss.SSS}, next scheduled at: {3, date, dd-MM-yyyy HH:mm:ss.SSS}
  12. org.quartz.plugin.triggerHistory.triggerCompleteMessage=Trigger [{1}.{0}] completed firing job [{6}.{5}] with resulting trigger instruction code: {9}. Next scheduled at: {3, date, dd-MM-yyyy HH:mm:ss.SSS}
  13. org.quartz.plugin.triggerHistory.triggerMisfiredMessage=Trigger [{1}.{0}] misfired job [{6}.{5}]. Should have fired at: {3, date, dd-MM-yyyy HH:mm:ss.SSS}

配置 H2 数据库

使用quartz.properties文件中的属性将 quartz 配置为使用 H2 数据库。

quartz.properties

  1. #Quartz persistent jobStore config
  2. org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
  3. org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegate
  4. org.quartz.jobStore.tablePrefix=QRTZ_    
  5. org.quartz.jobStore.dataSource=myDS
  6. org.quartz.jobStore.useProperties=false
  7. org.quartz.jobStore.isClustered=false
  9. #Quartz dataSource
  10. org.quartz.dataSource.myDS.driver=org.h2.Driver
  11. org.quartz.dataSource.myDS.URL=jdbc:h2:file:~/h2/testdb;INIT=RUNSCRIPT FROM 'classpath:schema.sql'
  12. org.quartz.dataSource.myDS.user=sa
  13. org.quartz.dataSource.myDS.password =
  14. org.quartz.dataSource.myDS.maxConnections=5
  15. org.quartz.dataSource.myDS.validationQuery=select 1

Quartz 不会自动在数据库中创建必要的表，您需要在应用程序启动时创建它们。 我已经使用了上面的org.quartz.dataSource.myDS.URL属性。 模式查询位于schema.sql文件中。

schema.sql

  1. DROP TABLE  IF EXISTS QRTZ_CALENDARS;
  2. DROP TABLE  IF EXISTS QRTZ_CRON_TRIGGERS;
  3. DROP TABLE  IF EXISTS QRTZ_FIRED_TRIGGERS;
  4. DROP TABLE  IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
  5. DROP TABLE  IF EXISTS QRTZ_SCHEDULER_STATE;
  6. DROP TABLE  IF EXISTS QRTZ_LOCKS;
  7. DROP TABLE  IF EXISTS QRTZ_JOB_DETAILS;
  8. DROP TABLE  IF EXISTS QRTZ_SIMPLE_TRIGGERS;
  9. DROP TABLE  IF EXISTS qrtz_simprop_triggers;
  10. DROP TABLE  IF EXISTS QRTZ_BLOB_TRIGGERS;
  11. DROP TABLE  IF EXISTS QRTZ_TRIGGERS;
  12. DROP TABLE  IF EXISTS qrtz_simprop_triggers;
  14. CREATE TABLE QRTZ_CALENDARS (
  15.   SCHED_NAME VARCHAR(120) NOT NULL,
  16.   CALENDAR_NAME VARCHAR (200)  NOT NULL ,
  17.   CALENDAR IMAGE NOT NULL
  18. );
  20. CREATE TABLE QRTZ_CRON_TRIGGERS (
  21.   SCHED_NAME VARCHAR(120) NOT NULL,
  22.   TRIGGER_NAME VARCHAR (200)  NOT NULL ,
  23.   TRIGGER_GROUP VARCHAR (200)  NOT NULL ,
  24.   CRON_EXPRESSION VARCHAR (120)  NOT NULL ,
  25.   TIME_ZONE_ID VARCHAR (80) 
  26. );
  28. CREATE TABLE QRTZ_FIRED_TRIGGERS (
  29.   SCHED_NAME VARCHAR(120) NOT NULL,
  30.   ENTRY_ID VARCHAR (95)  NOT NULL ,
  31.   TRIGGER_NAME VARCHAR (200)  NOT NULL ,
  32.   TRIGGER_GROUP VARCHAR (200)  NOT NULL ,
  33.   INSTANCE_NAME VARCHAR (200)  NOT NULL ,
  34.   FIRED_TIME BIGINT NOT NULL ,
  35.   SCHED_TIME BIGINT NOT NULL ,
  36.   PRIORITY INTEGER NOT NULL ,
  37.   STATE VARCHAR (16)  NOT NULL,
  38.   JOB_NAME VARCHAR (200)  NULL ,
  39.   JOB_GROUP VARCHAR (200)  NULL ,
  40.   IS_NONCONCURRENT BOOLEAN  NULL ,
  41.   REQUESTS_RECOVERY BOOLEAN  NULL 
  42. );
  44. CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS (
  45.   SCHED_NAME VARCHAR(120) NOT NULL,
  46.   TRIGGER_GROUP VARCHAR (200)  NOT NULL 
  47. );
  49. CREATE TABLE QRTZ_SCHEDULER_STATE (
  50.   SCHED_NAME VARCHAR(120) NOT NULL,
  51.   INSTANCE_NAME VARCHAR (200)  NOT NULL ,
  52.   LAST_CHECKIN_TIME BIGINT NOT NULL ,
  53.   CHECKIN_INTERVAL BIGINT NOT NULL
  54. );
  56. CREATE TABLE QRTZ_LOCKS (
  57.   SCHED_NAME VARCHAR(120) NOT NULL,
  58.   LOCK_NAME VARCHAR (40)  NOT NULL 
  59. );
  61. CREATE TABLE QRTZ_JOB_DETAILS (
  62.   SCHED_NAME VARCHAR(120) NOT NULL,
  63.   JOB_NAME VARCHAR (200)  NOT NULL ,
  64.   JOB_GROUP VARCHAR (200)  NOT NULL ,
  65.   DESCRIPTION VARCHAR (250) NULL ,
  66.   JOB_CLASS_NAME VARCHAR (250)  NOT NULL ,
  67.   IS_DURABLE BOOLEAN  NOT NULL ,
  68.   IS_NONCONCURRENT BOOLEAN  NOT NULL ,
  69.   IS_UPDATE_DATA BOOLEAN  NOT NULL ,
  70.   REQUESTS_RECOVERY BOOLEAN  NOT NULL ,
  71.   JOB_DATA IMAGE NULL
  72. );
  74. CREATE TABLE QRTZ_SIMPLE_TRIGGERS (
  75.   SCHED_NAME VARCHAR(120) NOT NULL,
  76.   TRIGGER_NAME VARCHAR (200)  NOT NULL ,
  77.   TRIGGER_GROUP VARCHAR (200)  NOT NULL ,
  78.   REPEAT_COUNT BIGINT NOT NULL ,
  79.   REPEAT_INTERVAL BIGINT NOT NULL ,
  80.   TIMES_TRIGGERED BIGINT NOT NULL
  81. );
  83. CREATE TABLE qrtz_simprop_triggers
  84.   (          
  85.     SCHED_NAME VARCHAR(120) NOT NULL,
  86.     TRIGGER_NAME VARCHAR(200) NOT NULL,
  87.     TRIGGER_GROUP VARCHAR(200) NOT NULL,
  88.     STR_PROP_1 VARCHAR(512) NULL,
  89.     STR_PROP_2 VARCHAR(512) NULL,
  90.     STR_PROP_3 VARCHAR(512) NULL,
  91.     INT_PROP_1 INTEGER NULL,
  92.     INT_PROP_2 INTEGER NULL,
  93.     LONG_PROP_1 BIGINT NULL,
  94.     LONG_PROP_2 BIGINT NULL,
  95.     DEC_PROP_1 NUMERIC(13,4) NULL,
  96.     DEC_PROP_2 NUMERIC(13,4) NULL,
  97.     BOOL_PROP_1 BOOLEAN NULL,
  98.     BOOL_PROP_2 BOOLEAN NULL,
  99. );
  101. CREATE TABLE QRTZ_BLOB_TRIGGERS (
  102.   SCHED_NAME VARCHAR(120) NOT NULL,
  103.   TRIGGER_NAME VARCHAR (200)  NOT NULL ,
  104.   TRIGGER_GROUP VARCHAR (200)  NOT NULL ,
  105.   BLOB_DATA IMAGE NULL
  106. );
  108. CREATE TABLE QRTZ_TRIGGERS (
  109.   SCHED_NAME VARCHAR(120) NOT NULL,
  110.   TRIGGER_NAME VARCHAR (200)  NOT NULL ,
  111.   TRIGGER_GROUP VARCHAR (200)  NOT NULL ,
  112.   JOB_NAME VARCHAR (200)  NOT NULL ,
  113.   JOB_GROUP VARCHAR (200)  NOT NULL ,
  114.   DESCRIPTION VARCHAR (250) NULL ,
  115.   NEXT_FIRE_TIME BIGINT NULL ,
  116.   PREV_FIRE_TIME BIGINT NULL ,
  117.   PRIORITY INTEGER NULL ,
  118.   TRIGGER_STATE VARCHAR (16)  NOT NULL ,
  119.   TRIGGER_TYPE VARCHAR (8)  NOT NULL ,
  120.   START_TIME BIGINT NOT NULL ,
  121.   END_TIME BIGINT NULL ,
  122.   CALENDAR_NAME VARCHAR (200)  NULL ,
  123.   MISFIRE_INSTR SMALLINT NULL ,
  124.   JOB_DATA IMAGE NULL
  125. );
  127. ALTER TABLE QRTZ_CALENDARS  ADD
  128.   CONSTRAINT PK_QRTZ_CALENDARS PRIMARY KEY  
  129.   (
  130.     SCHED_NAME,
  131.     CALENDAR_NAME
  132.   );
  134. ALTER TABLE QRTZ_CRON_TRIGGERS  ADD
  135.   CONSTRAINT PK_QRTZ_CRON_TRIGGERS PRIMARY KEY  
  136.   (
  137.     SCHED_NAME,
  138.     TRIGGER_NAME,
  139.     TRIGGER_GROUP
  140.   );
  142. ALTER TABLE QRTZ_FIRED_TRIGGERS  ADD
  143.   CONSTRAINT PK_QRTZ_FIRED_TRIGGERS PRIMARY KEY  
  144.   (
  145.     SCHED_NAME,
  146.     ENTRY_ID
  147.   );
  149. ALTER TABLE QRTZ_PAUSED_TRIGGER_GRPS  ADD
  150.   CONSTRAINT PK_QRTZ_PAUSED_TRIGGER_GRPS PRIMARY KEY  
  151.   (
  152.     SCHED_NAME,
  153.     TRIGGER_GROUP
  154.   );
  156. ALTER TABLE QRTZ_SCHEDULER_STATE  ADD
  157.   CONSTRAINT PK_QRTZ_SCHEDULER_STATE PRIMARY KEY  
  158.   (
  159.     SCHED_NAME,
  160.     INSTANCE_NAME
  161.   );
  163. ALTER TABLE QRTZ_LOCKS  ADD
  164.   CONSTRAINT PK_QRTZ_LOCKS PRIMARY KEY  
  165.   (
  166.     SCHED_NAME,
  167.     LOCK_NAME
  168.   );
  170. ALTER TABLE QRTZ_JOB_DETAILS  ADD
  171.   CONSTRAINT PK_QRTZ_JOB_DETAILS PRIMARY KEY  
  172.   (
  173.     SCHED_NAME,
  174.     JOB_NAME,
  175.     JOB_GROUP
  176.   );
  178. ALTER TABLE QRTZ_SIMPLE_TRIGGERS  ADD
  179.   CONSTRAINT PK_QRTZ_SIMPLE_TRIGGERS PRIMARY KEY  
  180.   (
  181.     SCHED_NAME,
  182.     TRIGGER_NAME,
  183.     TRIGGER_GROUP
  184.   );
  186. ALTER TABLE QRTZ_SIMPROP_TRIGGERS  ADD
  187.   CONSTRAINT PK_QRTZ_SIMPROP_TRIGGERS PRIMARY KEY  
  188.   (
  189.     SCHED_NAME,
  190.     TRIGGER_NAME,
  191.     TRIGGER_GROUP
  192.   );
  194. ALTER TABLE QRTZ_TRIGGERS  ADD
  195.   CONSTRAINT PK_QRTZ_TRIGGERS PRIMARY KEY  
  196.   (
  197.     SCHED_NAME,
  198.     TRIGGER_NAME,
  199.     TRIGGER_GROUP
  200.   );
  202. ALTER TABLE QRTZ_CRON_TRIGGERS ADD
  203.   CONSTRAINT FK_QRTZ_CRON_TRIGGERS_QRTZ_TRIGGERS FOREIGN KEY
  204.   (
  205.     SCHED_NAME,
  206.     TRIGGER_NAME,
  207.     TRIGGER_GROUP
  208.   ) REFERENCES QRTZ_TRIGGERS (
  209.     SCHED_NAME,
  210.     TRIGGER_NAME,
  211.     TRIGGER_GROUP
  212.   ) ON DELETE CASCADE;
  214. ALTER TABLE QRTZ_SIMPLE_TRIGGERS ADD
  215.   CONSTRAINT FK_QRTZ_SIMPLE_TRIGGERS_QRTZ_TRIGGERS FOREIGN KEY
  216.   (
  217.     SCHED_NAME,
  218.     TRIGGER_NAME,
  219.     TRIGGER_GROUP
  220.   ) REFERENCES QRTZ_TRIGGERS (
  221.     SCHED_NAME,
  222.     TRIGGER_NAME,
  223.     TRIGGER_GROUP
  224.   ) ON DELETE CASCADE;
  226. ALTER TABLE QRTZ_SIMPROP_TRIGGERS ADD
  227.   CONSTRAINT FK_QRTZ_SIMPROP_TRIGGERS_QRTZ_TRIGGERS FOREIGN KEY
  228.   (
  229.     SCHED_NAME,
  230.     TRIGGER_NAME,
  231.     TRIGGER_GROUP
  232.   ) REFERENCES QRTZ_TRIGGERS (
  233.     SCHED_NAME,
  234.     TRIGGER_NAME,
  235.     TRIGGER_GROUP
  236.   ) ON DELETE CASCADE;
  238. ALTER TABLE QRTZ_TRIGGERS ADD
  239.   CONSTRAINT FK_QRTZ_TRIGGERS_QRTZ_JOB_DETAILS FOREIGN KEY
  240.   (
  241.     SCHED_NAME,
  242.     JOB_NAME,
  243.     JOB_GROUP
  244.   ) REFERENCES QRTZ_JOB_DETAILS (
  245.     SCHED_NAME,
  246.     JOB_NAME,
  247.     JOB_GROUP
  248.   );
  250. COMMIT;

运行演示

配置日志记录并启动应用程序

为了格式化日志语句，我创建了自定义logback.xml。

logback.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <configuration scan="true">
  4.     <appender name="consoleAppender" class="ch.qos.logback.core.ConsoleAppender">
  5.         <encoder>
  6.             <charset>UTF-8</charset>
  7.             <Pattern>%d{yyyy-MM-dd HH:mm:ss} %p %X{TXNID} - %m%n</Pattern>
  8.         </encoder>
  9.     </appender>
  11.     <root level="INFO">
  12.         <appender-ref ref="consoleAppender" />
  13.     </root>
  14. </configuration>

作为 Spring 启动应用程序启动该应用程序。

App.java

  1. package com.howtodoinjava.demo;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  6. @SpringBootApplication
  7. public class App
  8. {
  9.     public static void main(String[] args) 
  10.     {
  11.         SpringApplication.run(App.class, args);
  12.     }
  13. }

验证作业执行

在服务器控制台中验证正在执行的 Spring Batch 作业。

Console

  1.   .   ____          _            __ _ _
  2.  /\\ / ___'_ __ _ _(_)_ __  __ _ \ \ \ \
  3. ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ \ \
  4.  \\/  ___)| |_)| | | | | || (_| |  ) ) ) )
  5.   '  |____| .__|_| |_|_| |_\__, | / / / /
  6.  =========|_|==============|___/=/_/_/_/
  7.  :: Spring Boot ::        (v2.0.3.RELEASE)
  9. 2018-07-06 09:29:07 INFO  - Starting App on MACHINE-ID with PID 13456 (C:\Users\lokesh\workspace\App\target\classes started by lokesh in C:\Users\lokesh\workspace\App)
  10. 2018-07-06 09:29:07 INFO  - No active profile set, falling back to default profiles: default
  11. 2018-07-06 09:29:08 INFO  - Refreshing org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@23529fee: startup date [Fri Jul 06 09:29:08 IST 2018]; root of context hierarchy
  12. 2018-07-06 09:29:10 INFO  - Bean 'quartzConfig' of type [com.howtodoinjava.demo.config.QuartzConfig$EnhancerBySpringCGLIB$78eca775] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  13. 2018-07-06 09:29:10 INFO  - Bean 'org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration' of type [org.springframework.transaction.annotation.ProxyTransactionManagementConfiguration$EnhancerBySpringCGLIB$11c34f14] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  14. 2018-07-06 09:29:10 INFO  - Bean 'org.springframework.boot.autoconfigure.jdbc.DataSourceConfiguration$Hikari' of type [org.springframework.boot.autoconfigure.jdbc.DataSourceConfiguration$Hikari] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  15. 2018-07-06 09:29:10 INFO  - Bean 'org.springframework.boot.context.properties.ConversionServiceDeducer$Factory' of type [org.springframework.boot.context.properties.ConversionServiceDeducer$Factory] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  16. 2018-07-06 09:29:10 INFO  - Bean 'spring.datasource-org.springframework.boot.autoconfigure.jdbc.DataSourceProperties' of type [org.springframework.boot.autoconfigure.jdbc.DataSourceProperties] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  17. 2018-07-06 09:29:10 INFO  - Bean 'dataSource' of type [com.zaxxer.hikari.HikariDataSource] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  18. 2018-07-06 09:29:10 INFO  - HikariPool-1 - Starting...
  19. 2018-07-06 09:29:11 INFO  - HikariPool-1 - Start completed.
  20. 2018-07-06 09:29:11 INFO  - Executing SQL script from URL [file:/C:/Users/lokesh/workspace/App/target/classes/schema.sql]
  21. 2018-07-06 09:29:11 INFO  - Executed SQL script from URL [file:/C:/Users/lokesh/workspace/App/target/classes/schema.sql] in 66 ms.
  22. 2018-07-06 09:29:11 INFO  - Bean 'org.springframework.boot.autoconfigure.jdbc.DataSourceInitializerInvoker' of type [org.springframework.boot.autoconfigure.jdbc.DataSourceInitializerInvoker] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  23. 2018-07-06 09:29:11 INFO  - Bean 'org.springframework.batch.core.configuration.annotation.SimpleBatchConfiguration' of type [org.springframework.batch.core.configuration.annotation.SimpleBatchConfiguration$EnhancerBySpringCGLIB$1186297a] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  24. 2018-07-06 09:29:11 INFO  - Bean 'jobRegistry' of type [com.sun.proxy.$Proxy49] is not eligible for getting processed by all BeanPostProcessors (for example: not eligible for auto-proxying)
  25. 2018-07-06 09:29:12 INFO  - Tomcat initialized with port(s): 8080 (http)
  26. 2018-07-06 09:29:12 INFO  - Initializing ProtocolHandler ["http-nio-8080"]
  27. 2018-07-06 09:29:12 INFO  - Starting service [Tomcat]
  28. 2018-07-06 09:29:12 INFO  - Starting Servlet Engine: Apache Tomcat/8.5.31
  29. 2018-07-06 09:29:12 INFO  - Initializing Spring embedded WebApplicationContext
  30. 2018-07-06 09:29:12 INFO  - Root WebApplicationContext: initialization completed in 4505 ms
  31. 2018-07-06 09:29:12 INFO  - Servlet webServlet mapped to [/console/*]
  32. 2018-07-06 09:29:12 INFO  - Servlet dispatcherServlet mapped to [/]
  33. 2018-07-06 09:29:12 INFO  - Mapping filter: 'characterEncodingFilter' to: [/*]
  34. 2018-07-06 09:29:12 INFO  - Mapping filter: 'hiddenHttpMethodFilter' to: [/*]
  35. 2018-07-06 09:29:12 INFO  - Mapping filter: 'httpPutFormContentFilter' to: [/*]
  36. 2018-07-06 09:29:12 INFO  - Mapping filter: 'requestContextFilter' to: [/*]
  37. 2018-07-06 09:29:13 INFO  - No database type set, using meta data indicating: H2
  38. 2018-07-06 09:29:13 INFO  - No TaskExecutor has been set, defaulting to synchronous executor.
  39. 2018-07-06 09:29:13 INFO  - Executing SQL script from class path resource [org/quartz/impl/jdbcjobstore/tables_h2.sql]
  40. 2018-07-06 09:29:13 INFO  - Executed SQL script from class path resource [org/quartz/impl/jdbcjobstore/tables_h2.sql] in 21 ms.
  41. 2018-07-06 09:29:13 INFO  - Using ConnectionProvider class 'org.quartz.utils.C3p0PoolingConnectionProvider' for data source 'myDS'
  42. 2018-07-06 09:29:13 INFO  - MLog clients using slf4j logging.
  43. 2018-07-06 09:29:13 INFO  - Initializing c3p0-0.9.5.2 [built 08-December-2015 22:06:04 -0800; debug? true; trace: 10]
  44. 2018-07-06 09:29:13 INFO  - Using default implementation for ThreadExecutor
  45. 2018-07-06 09:29:14 INFO  - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
  46. 2018-07-06 09:29:14 INFO  - Quartz Scheduler v.2.3.0 created.
  47. 2018-07-06 09:29:14 INFO  - Using thread monitor-based data access locking (synchronization).
  48. 2018-07-06 09:29:14 INFO  - JobStoreTX initialized.
  49. 2018-07-06 09:29:14 INFO  - Scheduler meta-data: Quartz Scheduler (v2.3.0) 'schedulerFactoryBean' with instanceId 'NON_CLUSTERED'
  50.   Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
  51.   NOT STARTED.
  52.   Currently in standby mode.
  53.   Number of jobs executed: 0
  54.   Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 50 threads.
  55.   Using job-store 'org.quartz.impl.jdbcjobstore.JobStoreTX' - which supports persistence. and is not clustered.
  57. 2018-07-06 09:29:14 INFO  - Quartz scheduler 'schedulerFactoryBean' initialized from an externally provided properties instance.
  58. 2018-07-06 09:29:14 INFO  - Quartz scheduler version: 2.3.0
  59. 2018-07-06 09:29:14 INFO  - JobFactory set to: org.springframework.scheduling.quartz.AdaptableJobFactory@3db64bd4
  60. 2018-07-06 09:29:14 INFO  - Initializing c3p0 pool... com.mchange.v2.c3p0.ComboPooledDataSource [ acquireIncrement -> 3, acquireRetryAttempts -> 30, acquireRetryDelay -> 1000, autoCommitOnClose -> false, automaticTestTable -> null, breakAfterAcquireFailure -> false, checkoutTimeout -> 0, connectionCustomizerClassName -> null, connectionTesterClassName -> com.mchange.v2.c3p0.impl.DefaultConnectionTester, contextClassLoaderSource -> caller, dataSourceName -> 8jgsvm9wug78a3djgl4a|73ab3aac, debugUnreturnedConnectionStackTraces -> false, description -> null, driverClass -> org.h2.Driver, extensions -> {}, factoryClassLocation -> null, forceIgnoreUnresolvedTransactions -> false, forceSynchronousCheckins -> false, forceUseNamedDriverClass -> false, identityToken -> 8jgsvm9wug78a3djgl4a|73ab3aac, idleConnectionTestPeriod -> 50, initialPoolSize -> 3, jdbcUrl -> jdbc:h2:file:~/h2/testdb;INIT=RUNSCRIPT FROM 'classpath:schema.sql', maxAdministrativeTaskTime -> 0, maxConnectionAge -> 0, maxIdleTime -> 0, maxIdleTimeExcessConnections -> 0, maxPoolSize -> 5, maxStatements -> 0, maxStatementsPerConnection -> 120, minPoolSize -> 1, numHelperThreads -> 3, preferredTestQuery -> select 1, privilegeSpawnedThreads -> false, properties -> {user=******, password=******}, propertyCycle -> 0, statementCacheNumDeferredCloseThreads -> 0, testConnectionOnCheckin -> true, testConnectionOnCheckout -> false, unreturnedConnectionTimeout -> 0, userOverrides -> {}, usesTraditionalReflectiveProxies -> false ]
  61. 2018-07-06 09:29:15 INFO  - Mapped URL path [/**/favicon.ico] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
  62. 2018-07-06 09:29:15 INFO  - Looking for @ControllerAdvice: org.springframework.boot.web.servlet.context.AnnotationConfigServletWebServerApplicationContext@23529fee: startup date [Fri Jul 06 09:29:08 IST 2018]; root of context hierarchy
  63. 2018-07-06 09:29:15 INFO  - Mapped "{[/error]}" onto public org.springframework.http.ResponseEntity<java.util.Map<java.lang.String, java.lang.Object>> org.springframework.boot.autoconfigure.web.servlet.error.BasicErrorController.error(javax.servlet.http.HttpServletRequest)
  64. 2018-07-06 09:29:15 INFO  - Mapped "{[/error],produces=}" onto public org.springframework.web.servlet.ModelAndView org.springframework.boot.autoconfigure.web.servlet.error.BasicErrorController.errorHtml(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse)
  65. 2018-07-06 09:29:15 INFO  - Mapped URL path [/webjars/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
  66. 2018-07-06 09:29:15 INFO  - Mapped URL path [/**] onto handler of type [class org.springframework.web.servlet.resource.ResourceHttpRequestHandler]
  67. 2018-07-06 09:29:15 INFO  - Executing SQL script from class path resource [org/springframework/batch/core/schema-h2.sql]
  68. 2018-07-06 09:29:16 INFO  - Executed SQL script from class path resource [org/springframework/batch/core/schema-h2.sql] in 105 ms.
  69. 2018-07-06 09:29:16 INFO  - Registering beans for JMX exposure on startup
  70. 2018-07-06 09:29:16 INFO  - Bean with name 'dataSource' has been autodetected for JMX exposure
  71. 2018-07-06 09:29:16 INFO  - Located MBean 'dataSource': registering with JMX server as MBean [com.zaxxer.hikari:name=dataSource,type=HikariDataSource]
  72. 2018-07-06 09:29:16 INFO  - Starting beans in phase 2147483647
  73. 2018-07-06 09:29:16 INFO  - Starting Quartz Scheduler now
  74. 2018-07-06 09:29:16 INFO  - Freed 0 triggers from 'acquired' / 'blocked' state.
  75. 2018-07-06 09:29:16 INFO  - Recovering 0 jobs that were in-progress at the time of the last shut-down.
  76. 2018-07-06 09:29:16 INFO  - Recovery complete.
  77. 2018-07-06 09:29:16 INFO  - Removed 0 'complete' triggers.
  78. 2018-07-06 09:29:16 INFO  - Removed 0 stale fired job entries.
  79. 2018-07-06 09:29:16 INFO  - Scheduler schedulerFactoryBean_$_NON_CLUSTERED started.
  80. 2018-07-06 09:29:16 INFO  - Starting ProtocolHandler ["http-nio-8080"]
  81. 2018-07-06 09:29:16 INFO  - Using a shared selector for servlet write/read
  82. 2018-07-06 09:29:16 INFO  - Tomcat started on port(s): 8080 (http) with context path ''
  83. 2018-07-06 09:29:16 INFO  - Started App in 9.709 seconds (JVM running for 10.821)
  84. 2018-07-06 09:29:17 INFO  - Trigger [DEFAULT.jobOneTrigger] fired job [DEFAULT.demoJobOne] scheduled at:  06-07-2018 09:29:13.524, next scheduled at:  06-07-2018 09:29:23.524
  85. 2018-07-06 09:29:17 INFO  - Trigger [DEFAULT.jobTwoTrigger] fired job [DEFAULT.demoJobTwo] scheduled at:  06-07-2018 09:29:13.565, next scheduled at:  06-07-2018 09:29:33.565
  86. 2018-07-06 09:29:17 INFO  - Job: [FlowJob: [name=demoJobTwo]] launched with the following parameters: [{JobID=1530849557198}]
  87. 2018-07-06 09:29:17 INFO  - Executing step: [stepOne]
  88. MyTaskOne start..
  89. MyTaskOne done..
  90. 2018-07-06 09:29:17 INFO  - Job: [FlowJob: [name=demoJobTwo]] completed with the following parameters: [{JobID=1530849557198}] and the following status: [COMPLETED]
  91. 2018-07-06 09:29:17 INFO  - Trigger [DEFAULT.jobTwoTrigger] completed firing job [DEFAULT.demoJobTwo] with resulting trigger instruction code: DO NOTHING. Next scheduled at:  06-07-2018 09:29:33.565
  92. 2018-07-06 09:29:17 INFO  - Job: [SimpleJob: [name=demoJobOne]] launched with the following parameters: [{JobID=1530849557093}]
  93. 2018-07-06 09:29:17 INFO  - Executing step: [stepOne]
  94. MyTaskOne start..
  95. MyTaskOne done..
  96. 2018-07-06 09:29:17 INFO  - Executing step: [stepTwo]
  97. MyTaskTwo start..
  98. MyTaskTwo done..
  99. 2018-07-06 09:29:17 INFO  - Job: [SimpleJob: [name=demoJobOne]] completed with the following parameters: [{JobID=1530849557093}] and the following status: [COMPLETED]
  100. 2018-07-06 09:29:17 INFO  - Trigger [DEFAULT.jobOneTrigger] completed firing job [DEFAULT.demoJobOne] with resulting trigger instruction code: DO NOTHING. Next scheduled at:  06-07-2018 09:29:23.524
  101. 2018-07-06 09:29:23 INFO  - Trigger [DEFAULT.jobOneTrigger] fired job [DEFAULT.demoJobOne] scheduled at:  06-07-2018 09:29:23.524, next scheduled at:  06-07-2018 09:29:33.524
  102. 2018-07-06 09:29:23 INFO  - Job: [SimpleJob: [name=demoJobOne]] launched with the following parameters: [{JobID=1530849563538}]
  103. 2018-07-06 09:29:23 INFO  - Executing step: [stepOne]
  104. MyTaskOne start..
  105. MyTaskOne done..
  106. 2018-07-06 09:29:23 INFO  - Executing step: [stepTwo]
  107. MyTaskTwo start..
  108. MyTaskTwo done..
  109. 2018-07-06 09:29:23 INFO  - Job: [SimpleJob: [name=demoJobOne]] completed with the following parameters: [{JobID=1530849563538}] and the following status: [COMPLETED]
  110. 2018-07-06 09:29:23 INFO  - Trigger [DEFAULT.jobOneTrigger] completed firing job [DEFAULT.demoJobOne] with resulting trigger instruction code: DO NOTHING. Next scheduled at:  06-07-2018 09:29:33.524

验证 H2 控制台

使用浏览器 URL 访问 H2 控制台：http://localhost:8080/console/

Spring Batch Quartz H2 Jdbcjobstore 示例 - 图2

H2 控制台

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

学习愉快！