天天看點

Quartz定時架構完成持久化操作——Spring Boot簡介

簡介

用quartz管理任務計劃很友善,但是當使用資料庫作為存儲媒體的時候,必須要先建立表,不然就會報錯。以下是要使用MySQL時的建表語句。

#  
# In your Quartz properties file, you'll need to set   
# org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
#  
#  
# By: Ron Cordell - roncordell  
#  I didn't see this anywhere, so I thought I'd post it here. This is the script from Quartz to create the tables in a MySQL database, modified to use INNODB instead of MYISAM.  
  
DROP TABLE IF EXISTS QRTZ_JOB_LISTENERS;  
DROP TABLE IF EXISTS QRTZ_TRIGGER_LISTENERS;  
DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS;  
DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS;  
DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE;  
DROP TABLE IF EXISTS QRTZ_LOCKS;  
DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS;  
DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS;  
DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS;  
DROP TABLE IF EXISTS QRTZ_TRIGGERS;  
DROP TABLE IF EXISTS QRTZ_JOB_DETAILS;  
DROP TABLE IF EXISTS QRTZ_CALENDARS;  
CREATE TABLE QRTZ_JOB_DETAILS(  
JOB_NAME VARCHAR(200) NOT NULL,  
JOB_GROUP VARCHAR(200) NOT NULL,  
DESCRIPTION VARCHAR(250) NULL,  
JOB_CLASS_NAME VARCHAR(250) NOT NULL,  
IS_DURABLE VARCHAR(1) NOT NULL,  
IS_VOLATILE VARCHAR(1) NOT NULL,  
IS_STATEFUL VARCHAR(1) NOT NULL,  
REQUESTS_RECOVERY VARCHAR(1) NOT NULL,  
JOB_DATA BLOB NULL,  
PRIMARY KEY (JOB_NAME,JOB_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_JOB_LISTENERS (  
JOB_NAME VARCHAR(200) NOT NULL,  
JOB_GROUP VARCHAR(200) NOT NULL,  
JOB_LISTENER VARCHAR(200) NOT NULL,  
PRIMARY KEY (JOB_NAME,JOB_GROUP,JOB_LISTENER),  
INDEX (JOB_NAME, JOB_GROUP),  
FOREIGN KEY (JOB_NAME,JOB_GROUP)  
REFERENCES QRTZ_JOB_DETAILS(JOB_NAME,JOB_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_TRIGGERS (  
TRIGGER_NAME VARCHAR(200) NOT NULL,  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
JOB_NAME VARCHAR(200) NOT NULL,  
JOB_GROUP VARCHAR(200) NOT NULL,  
IS_VOLATILE VARCHAR(1) NOT NULL,  
DESCRIPTION VARCHAR(250) NULL,  
NEXT_FIRE_TIME BIGINT(13) NULL,  
PREV_FIRE_TIME BIGINT(13) NULL,  
PRIORITY INTEGER NULL,  
TRIGGER_STATE VARCHAR(16) NOT NULL,  
TRIGGER_TYPE VARCHAR(8) NOT NULL,  
START_TIME BIGINT(13) NOT NULL,  
END_TIME BIGINT(13) NULL,  
CALENDAR_NAME VARCHAR(200) NULL,  
MISFIRE_INSTR SMALLINT(2) NULL,  
JOB_DATA BLOB NULL,  
PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),  
INDEX (JOB_NAME, JOB_GROUP),  
FOREIGN KEY (JOB_NAME,JOB_GROUP)  
REFERENCES QRTZ_JOB_DETAILS(JOB_NAME,JOB_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_SIMPLE_TRIGGERS (  
TRIGGER_NAME VARCHAR(200) NOT NULL,  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
REPEAT_COUNT BIGINT(7) NOT NULL,  
REPEAT_INTERVAL BIGINT(12) NOT NULL,  
TIMES_TRIGGERED BIGINT(10) NOT NULL,  
PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),  
INDEX (TRIGGER_NAME, TRIGGER_GROUP),  
FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)  
REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_CRON_TRIGGERS (  
TRIGGER_NAME VARCHAR(200) NOT NULL,  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
CRON_EXPRESSION VARCHAR(120) NOT NULL,  
TIME_ZONE_ID VARCHAR(80),  
PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),  
INDEX (TRIGGER_NAME, TRIGGER_GROUP),  
FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)  
REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_BLOB_TRIGGERS (  
TRIGGER_NAME VARCHAR(200) NOT NULL,  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
BLOB_DATA BLOB NULL,  
PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP),  
INDEX (TRIGGER_NAME, TRIGGER_GROUP),  
FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)  
REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_TRIGGER_LISTENERS (  
TRIGGER_NAME VARCHAR(200) NOT NULL,  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
TRIGGER_LISTENER VARCHAR(200) NOT NULL,  
PRIMARY KEY (TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_LISTENER),  
INDEX (TRIGGER_NAME, TRIGGER_GROUP),  
FOREIGN KEY (TRIGGER_NAME,TRIGGER_GROUP)  
REFERENCES QRTZ_TRIGGERS(TRIGGER_NAME,TRIGGER_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_CALENDARS (  
CALENDAR_NAME VARCHAR(200) NOT NULL,  
CALENDAR BLOB NOT NULL,  
PRIMARY KEY (CALENDAR_NAME))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS (  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
PRIMARY KEY (TRIGGER_GROUP))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_FIRED_TRIGGERS (  
ENTRY_ID VARCHAR(95) NOT NULL,  
TRIGGER_NAME VARCHAR(200) NOT NULL,  
TRIGGER_GROUP VARCHAR(200) NOT NULL,  
IS_VOLATILE VARCHAR(1) NOT NULL,  
INSTANCE_NAME VARCHAR(200) NOT NULL,  
FIRED_TIME BIGINT(13) NOT NULL,  
PRIORITY INTEGER NOT NULL,  
STATE VARCHAR(16) NOT NULL,  
JOB_NAME VARCHAR(200) NULL,  
JOB_GROUP VARCHAR(200) NULL,  
IS_STATEFUL VARCHAR(1) NULL,  
REQUESTS_RECOVERY VARCHAR(1) NULL,  
PRIMARY KEY (ENTRY_ID))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_SCHEDULER_STATE (  
INSTANCE_NAME VARCHAR(200) NOT NULL,  
LAST_CHECKIN_TIME BIGINT(13) NOT NULL,  
CHECKIN_INTERVAL BIGINT(13) NOT NULL,  
PRIMARY KEY (INSTANCE_NAME))  
ENGINE=InnoDB;  
  
CREATE TABLE QRTZ_LOCKS (  
LOCK_NAME VARCHAR(40) NOT NULL,  
PRIMARY KEY (LOCK_NAME))  
ENGINE=InnoDB;  
  
INSERT INTO QRTZ_LOCKS values('TRIGGER_ACCESS');  
INSERT INTO QRTZ_LOCKS values('JOB_ACCESS');  
INSERT INTO QRTZ_LOCKS values('CALENDAR_ACCESS');  
INSERT INTO QRTZ_LOCKS values('STATE_ACCESS');  
INSERT INTO QRTZ_LOCKS values('MISFIRE_ACCESS');  
commit;   
           
  • 表建立完成後重新整理,生成的表如下圖!!
    Quartz定時架構完成持久化操作——Spring Boot簡介
  • 然後再往下這個表格,是圖中十一個表的作用!!
表名 簡介
qrtz_blob_triggers Trigger 作為 Blob 類型存儲(用于 Quartz 使用者用 JDBC 建立他們自己定制的 Trigger 類型,JobStore 并不知道如何存儲執行個體的時候)
qrtz_calendars 以 Blob 類型存儲 Quartz 的 Calendar 資訊
qrtz_cron_triggers 存儲 Cron Trigger,包括 Cron 表達式和時區資訊
qrtz_fired_triggers 存儲與已觸發的 Trigger 相關的狀态資訊,以及相聯 Job 的執行資訊
qrtz_job_details 存儲每一個已配置的 Job 的詳細資訊
qrtz_locks 存儲程式的非觀鎖的資訊(假如使用了悲觀鎖)
qrtz_paused_trigger_grps 存儲已暫停的 Trigger 組的資訊
qrtz_scheduler_state 存儲少量的有關 Scheduler 的狀态資訊,和别的 Scheduler 執行個體(假如是用于一個叢集中)
qrtz_simple_triggers 存儲簡單的 Trigger,包括重複次數,間隔,以及已觸的次數
qrtz_simprop_triggers 存儲CalendarIntervalTrigger和DailyTimeIntervalTrigger兩種類型的觸發器
qrtz_triggers 存儲已配置的 Trigger 的資訊
  • 有了這十一個表之後,定時任務不會自動配置到表裡面,也就是說無法完成定時任務的持久化操作,是以需要引入quartz.properties檔案,屬性如下!!
#============================================================================  
# Configure JobStore    
# Using Spring datasource in quartzJobsConfig.xml  
# Spring uses LocalDataSourceJobStore extension of JobStoreCMT  
#============================================================================ 
#============================================================================  
# Configure Main Scheduler Properties    
# Needed to manage cluster instances  
#============================================================================  
org.quartz.scheduler.instanceName=xwjTest
org.quartz.scheduler.instanceId=AUTO


org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
#more trigger acquired
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false


   
# Change this to match your DB vendor  
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.MSSQLDelegate
org.quartz.jobStore.selectWithLockSQL=SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME \= ? 
org.quartz.jobStore.useProperties=false
org.quartz.jobStore.tablePrefix = qrtz_
org.quartz.jobStore.misfireThreshold = 60000
org.quartz.jobStore.dataSource=myDS  
#org.quartz.jobStore.txIsolationLevelReadCommitted = true 

org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000
  
#============================================================================  
# Configure ThreadPool    
#============================================================================  
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 25
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

#Configure DataSources
#代碼複制過來以後隻需要改變資料庫連接配接池的配置資訊即可完成資料庫的持久化操作
org.quartz.dataSource.myDS.driver=com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL=jdbc:mysql://localhost:3306/test?
org.quartz.dataSource.myDS.user=root
org.quartz.dataSource.myDS.password=hello   
           
  • 上述配置檔案中的屬性,可随意改變的隻有三個值

    org.quartz.scheduler.instanceName是定時架構的名字。

    org.quartz.jobStore.tablePrefix = qrtz_是資料庫中Quartz定時架構的表字首。

    然後修改一下資料庫連接配接池就可以直接運作項目,運作完成後再去檢視資料庫就有了要添加的定時任務!!!配置完成第一次啟動會添加到庫中,第二次啟動可能會報錯,因為第一次啟動的時候已經完成了持久化操作,是以如果沒有調用過删除的方法,就會報錯,這個時候調用一下删除job的方法就可以啦!!!

    整合QUartz架構的java代碼參考

    SpringBoot整合Quartz架構Java實用代碼

    -

    最後看都看了,碼字不易,留個贊再走吧!!!

繼續閱讀