【Quartz】將定時任務持久化到數據庫

時間 2019-11-09

原文原文鏈接

　　以前的文章所作的demo是將定時任務的信息保存在內存中的，見如下配置java

org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

　　若是，咱們須要在系統意外（或非意外）從新啓動後，仍保留定時任務信息，能夠使用數據庫存儲定時任務信息。mysql

org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX

　　存儲在MySQL中：sql

　　因爲須要鏈接MySQL數據庫，須要加上數據庫的JDBC驅動，這裏以pom形式下載，也能夠直接引入包數據庫

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>5.1.35</version>
</dependency>

　　而後須要在數據庫中建一些Quartz的表，MySQL的建、刪表腳本以下。若是你使用的是其餘數據庫，能夠下載Quartz的distribution，在\docs\dbTables下。ide

  1 #
  2 # Quartz seems to work best with the driver mm.mysql-2.0.7-bin.jar
  3 #
  4 # PLEASE consider using mysql with innodb tables to avoid locking issues
  5 #
  6 # In your Quartz properties file, you'll need to set 
  7 # org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
  8 #
  9 
 10 DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;
 11 DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;
 12 DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;
 13 DROP TABLE IF EXISTS QRTZ_LOCKS;
 14 DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;
 15 DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS;
 16 DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;
 17 DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;
 18 DROP TABLE IF EXISTS QRTZ_TRIGGERS;
 19 DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;
 20 DROP TABLE IF EXISTS QRTZ_CALENDARS;
 21 
 22 
 23 CREATE TABLE QRTZ_JOB_DETAILS
 24   (
 25     SCHED_NAME VARCHAR(120) NOT NULL,
 26     JOB_NAME  VARCHAR(200) NOT NULL,
 27     JOB_GROUP VARCHAR(200) NOT NULL,
 28     DESCRIPTION VARCHAR(250) NULL,
 29     JOB_CLASS_NAME   VARCHAR(250) NOT NULL,
 30     IS_DURABLE VARCHAR(1) NOT NULL,
 31     IS_NONCONCURRENT VARCHAR(1) NOT NULL,
 32     IS_UPDATE_DATA VARCHAR(1) NOT NULL,
 33     REQUESTS_RECOVERY VARCHAR(1) NOT NULL,
 34     JOB_DATA BLOB NULL,
 35     PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
 36 );
 37 
 38 CREATE TABLE QRTZ_TRIGGERS
 39   (
 40     SCHED_NAME VARCHAR(120) NOT NULL,
 41     TRIGGER_NAME VARCHAR(200) NOT NULL,
 42     TRIGGER_GROUP VARCHAR(200) NOT NULL,
 43     JOB_NAME  VARCHAR(200) NOT NULL,
 44     JOB_GROUP VARCHAR(200) NOT NULL,
 45     DESCRIPTION VARCHAR(250) NULL,
 46     NEXT_FIRE_TIME BIGINT(13) NULL,
 47     PREV_FIRE_TIME BIGINT(13) NULL,
 48     PRIORITY INTEGER NULL,
 49     TRIGGER_STATE VARCHAR(16) NOT NULL,
 50     TRIGGER_TYPE VARCHAR(8) NOT NULL,
 51     START_TIME BIGINT(13) NOT NULL,
 52     END_TIME BIGINT(13) NULL,
 53     CALENDAR_NAME VARCHAR(200) NULL,
 54     MISFIRE_INSTR SMALLINT(2) NULL,
 55     JOB_DATA BLOB NULL,
 56     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
 57     FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)
 58         REFERENCES QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP)
 59 );
 60 
 61 CREATE TABLE QRTZ_SIMPLE_TRIGGERS
 62   (
 63     SCHED_NAME VARCHAR(120) NOT NULL,
 64     TRIGGER_NAME VARCHAR(200) NOT NULL,
 65     TRIGGER_GROUP VARCHAR(200) NOT NULL,
 66     REPEAT_COUNT BIGINT(7) NOT NULL,
 67     REPEAT_INTERVAL BIGINT(12) NOT NULL,
 68     TIMES_TRIGGERED BIGINT(10) NOT NULL,
 69     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
 70     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
 71         REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
 72 );
 73 
 74 CREATE TABLE QRTZ_CRON_TRIGGERS
 75   (
 76     SCHED_NAME VARCHAR(120) NOT NULL,
 77     TRIGGER_NAME VARCHAR(200) NOT NULL,
 78     TRIGGER_GROUP VARCHAR(200) NOT NULL,
 79     CRON_EXPRESSION VARCHAR(200) NOT NULL,
 80     TIME_ZONE_ID VARCHAR(80),
 81     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
 82     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
 83         REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
 84 );
 85 
 86 CREATE TABLE QRTZ_SIMPROP_TRIGGERS
 87   (          
 88     SCHED_NAME VARCHAR(120) NOT NULL,
 89     TRIGGER_NAME VARCHAR(200) NOT NULL,
 90     TRIGGER_GROUP VARCHAR(200) NOT NULL,
 91     STR_PROP_1 VARCHAR(512) NULL,
 92     STR_PROP_2 VARCHAR(512) NULL,
 93     STR_PROP_3 VARCHAR(512) NULL,
 94     INT_PROP_1 INT NULL,
 95     INT_PROP_2 INT NULL,
 96     LONG_PROP_1 BIGINT NULL,
 97     LONG_PROP_2 BIGINT NULL,
 98     DEC_PROP_1 NUMERIC(13,4) NULL,
 99     DEC_PROP_2 NUMERIC(13,4) NULL,
100     BOOL_PROP_1 VARCHAR(1) NULL,
101     BOOL_PROP_2 VARCHAR(1) NULL,
102     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
103     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) 
104     REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
105 );
106 
107 CREATE TABLE QRTZ_BLOB_TRIGGERS
108   (
109     SCHED_NAME VARCHAR(120) NOT NULL,
110     TRIGGER_NAME VARCHAR(200) NOT NULL,
111     TRIGGER_GROUP VARCHAR(200) NOT NULL,
112     BLOB_DATA BLOB NULL,
113     PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP),
114     FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
115         REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
116 );
117 
118 CREATE TABLE QRTZ_CALENDARS
119   (
120     SCHED_NAME VARCHAR(120) NOT NULL,
121     CALENDAR_NAME  VARCHAR(200) NOT NULL,
122     CALENDAR BLOB NOT NULL,
123     PRIMARY KEY (SCHED_NAME,CALENDAR_NAME)
124 );
125 
126 CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS
127   (
128     SCHED_NAME VARCHAR(120) NOT NULL,
129     TRIGGER_GROUP  VARCHAR(200) NOT NULL, 
130     PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP)
131 );
132 
133 CREATE TABLE QRTZ_FIRED_TRIGGERS
134   (
135     SCHED_NAME VARCHAR(120) NOT NULL,
136     ENTRY_ID VARCHAR(95) NOT NULL,
137     TRIGGER_NAME VARCHAR(200) NOT NULL,
138     TRIGGER_GROUP VARCHAR(200) NOT NULL,
139     INSTANCE_NAME VARCHAR(200) NOT NULL,
140     FIRED_TIME BIGINT(13) NOT NULL,
141     SCHED_TIME BIGINT(13) NOT NULL,
142     PRIORITY INTEGER NOT NULL,
143     STATE VARCHAR(16) NOT NULL,
144     JOB_NAME VARCHAR(200) NULL,
145     JOB_GROUP VARCHAR(200) NULL,
146     IS_NONCONCURRENT VARCHAR(1) NULL,
147     REQUESTS_RECOVERY VARCHAR(1) NULL,
148     PRIMARY KEY (SCHED_NAME,ENTRY_ID)
149 );
150 
151 CREATE TABLE QRTZ_SCHEDULER_STATE
152   (
153     SCHED_NAME VARCHAR(120) NOT NULL,
154     INSTANCE_NAME VARCHAR(200) NOT NULL,
155     LAST_CHECKIN_TIME BIGINT(13) NOT NULL,
156     CHECKIN_INTERVAL BIGINT(13) NOT NULL,
157     PRIMARY KEY (SCHED_NAME,INSTANCE_NAME)
158 );
159 
160 CREATE TABLE QRTZ_LOCKS
161   (
162     SCHED_NAME VARCHAR(120) NOT NULL,
163     LOCK_NAME  VARCHAR(40) NOT NULL, 
164     PRIMARY KEY (SCHED_NAME,LOCK_NAME)
165 );
166 
167 
168 commit;

View Code

　　這個腳本除了給出建、刪表語句，也給出了org.quartz.jobStore.driverDelegateClass配置，此項配置到quartz.properties中spa

　　注：你可能也注意到了，這些表都是以QRTZ_爲前綴的，這是默認的前綴。若是你須要用到其餘前綴（個性化需求，或須要配置多個quartz實例），能夠在如下項配置（在quartz.properties中）code

org.quartz.jobStore.tablePrefix = QRTZ_

　　最主要的修改是quartz.propertiesblog

 1 org.quartz.scheduler.instanceName = MyScheduler
 2 org.quartz.threadPool.threadCount = 3
 3 org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
 4 org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
 5 org.quartz.jobStore.tablePrefix = QRTZ_
 6 org.quartz.jobStore.dataSource = myDS
 7 
 8 org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
 9 org.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/ll?characterEncoding=utf-8
10 org.quartz.dataSource.myDS.user = root
11 org.quartz.dataSource.myDS.password = 123456
12 org.quartz.dataSource.myDS.maxConnections = 5