1.引言
Quartz是一個(gè)開源的任務(wù)調(diào)度框架?；诙〞r(shí)、定期的策略來執(zhí)行任務(wù)是它的核心功能，比如2018年除夕夜晚上8點(diǎn)發(fā)紅包或者打開【木子道】公眾號(hào)，每隔10分鐘發(fā)1次紅包。Quartz有3個(gè)核心要素：調(diào)度器(Scheduler)、任務(wù)(Job)、觸發(fā)器(Trigger)。Quartz完全使用Java開發(fā)，可以集成到各種規(guī)模的應(yīng)用程序中。它能夠承載成千上萬的任務(wù)調(diào)度，并且支持集群。它支持將數(shù)據(jù)存儲(chǔ)到數(shù)據(jù)庫中以實(shí)現(xiàn)持久化，并支持絕大多數(shù)的數(shù)據(jù)庫。它將任務(wù)與觸發(fā)設(shè)計(jì)為松耦合，即一個(gè)任務(wù)可以對(duì)應(yīng)多個(gè)觸發(fā)器，這樣能夠輕松構(gòu)造出極為復(fù)雜的觸發(fā)策略。
2.Quartz 核心API介紹（版本2.3.0）
Scheduler :與調(diào)度器交互的主要接口。
Job:實(shí)現(xiàn)該接口組件能被調(diào)度程序執(zhí)行的任務(wù)類。
JobDetail:用于定義Job的實(shí)例。
Trigger:觸發(fā)器，定義一個(gè)Job如何被調(diào)度器執(zhí)行。
TriggerBuilder：觸發(fā)器創(chuàng)建器，用于創(chuàng)建觸發(fā)器Trigger實(shí)例。
JobBuilder ：用于聲明一個(gè)任務(wù)實(shí)例，也可以定義關(guān)于該任務(wù)的詳情比如任務(wù)名、組名等，這個(gè)聲明的實(shí)例將會(huì)作為一個(gè)實(shí)際執(zhí)行的任務(wù)。
Scheduler
void start() ; 開始啟動(dòng)Scheduler的線程Trigger。
void shutdown() ;關(guān)閉Scheduler的Trigger，并清理與調(diào)度程序相關(guān)聯(lián)的所有資源。
boolean isShutdown(); Scheduler是否關(guān)閉
Date scheduleJob(JobDetail var1, Trigger var2) ;將該給定添加JobDetail到調(diào)度程序，并將給定Trigger與它關(guān)聯(lián)
void triggerJob(JobKey var1, JobDataMap var2) ;觸發(fā)標(biāo)識(shí)JobDetail（立即執(zhí)行）。
void pauseJob(JobKey var1) ; 暫停任務(wù)
void resumeJob(JobKey var1); 恢復(fù)任務(wù)
boolean deleteJob(JobKey var1); 刪除任務(wù)
......
Scheduler由SchedulerFactory創(chuàng)建，并隨著shutdown方法的調(diào)用而終止。創(chuàng)建后它將可被用來添加、刪除或列出Job和Trigger，或執(zhí)行一些調(diào)度相關(guān)的工作。Scheduler 創(chuàng)建完成后，處于“待命”模式，并且必須先start()調(diào)用其方法才能觸發(fā)任何Jobs只有通過start()方法啟動(dòng)后它才會(huì)真的工作。
Job
void execute(JobExecutionContext var1) throws JobExecutionException;這個(gè)接口由代表要執(zhí)行的“工作”的類來實(shí)現(xiàn)。實(shí)例Job必須有一個(gè)public 無參數(shù)的構(gòu)造函數(shù)。
當(dāng)job的一個(gè)trigger被觸發(fā)后，execute()方法會(huì)被scheduler的一個(gè)工作線程調(diào)用；傳遞給execute()方法的JobExecutionContext對(duì)象中保存著該job運(yùn)行時(shí)的一些信息 ，執(zhí)行job的scheduler的引用，觸發(fā)job的trigger的引用，JobDetail對(duì)象引用，以及一些其它信息。
JobDetail
JobDataMap getJobDataMap(); 獲取實(shí)例成員數(shù)據(jù)
JobBuilder getJobBuilder();獲得JobBuilder對(duì)象
JobDetail對(duì)象是在將job加入scheduler時(shí)，由客戶端程序（你的程序）創(chuàng)建的。它包含job的各種屬性設(shè)置，以及用于存儲(chǔ)job實(shí)例狀態(tài)信息的JobDataMap。
Trigger
TriggerKey getKey(); 獲取觸發(fā)器唯一標(biāo)示，同分組key唯一，key= key + 組名稱，默認(rèn)組名稱DEFAULT。
JobKey getJobKey();獲取任務(wù)唯一標(biāo)示，
JobDataMap getJobDataMap();獲取實(shí)例數(shù)據(jù)。
int getPriority();觸發(fā)優(yōu)先級(jí)，默認(rèn)是5，同時(shí)觸發(fā)才會(huì)比較優(yōu)先級(jí)。
Trigger用于觸發(fā)Job的執(zhí)行。當(dāng)你準(zhǔn)備調(diào)度一個(gè)job時(shí)，你創(chuàng)建一個(gè)Trigger的實(shí)例，然后設(shè)置調(diào)度相關(guān)的屬性。Trigger也有一個(gè)相關(guān)聯(lián)的JobDataMap，用于給Job傳遞一些觸發(fā)相關(guān)的參數(shù)。Quartz自帶了各種不同類型的Trigger，最常用的主要是SimpleTrigger和CronTrigger。
CronTrigger
CronTrigger通常比SimpleTrigger更有用，如果您需要一個(gè)基于類似日歷的概念重復(fù)出現(xiàn)的工作調(diào)度計(jì)劃，而不是SimpleTrigger的精確指定時(shí)間間隔。
使用CronTrigger，您可以在每周一上午九點(diǎn)打開我的微信公眾號(hào)【木子道】，查閱相關(guān)技術(shù)分享文章。還可以每周五晚8點(diǎn)給我回復(fù)。
即使如此，就像SimpleTrigger一樣，CronTrigger有一個(gè)startTime，指定調(diào)度何時(shí)生效，還有一個(gè)（可選）endTime，指定何時(shí)應(yīng)該停止調(diào)度。
Cron表達(dá)式
Cron-Expressions用于配置CronTrigger的實(shí)例。Cron-Expressions是由七個(gè)子表達(dá)式組成的字符串，它們描述了計(jì)劃的各個(gè)細(xì)節(jié)。這些子表達(dá)式用空格分隔，表示：
秒 分鐘 小時(shí) 日 月 星期 年份（可選）
一個(gè)完整的cron-expression的例子是字符串“0 0 0 1 * ？“ - 這意味著”每個(gè)每月1日00:00:00 發(fā)布統(tǒng)計(jì)上個(gè)月數(shù)據(jù)“。
單獨(dú)的子表達(dá)式可以包含范圍和/或列表。例如，可以用“MON-FRI”，“MON，WED，F(xiàn)RI”，甚至“MON-WED，SAT”代替先前（以“WED”）為例的星期幾字段。
通配符（“字符”）可以用來表示該字段的“每個(gè)”可能的值。因此，上例中“月”字段中的字符只是“每月”。因此，“星期幾”字段中的“*”顯然意味著“每周的每一天”。
所有的字段都有一組可以指定的有效值。這些值應(yīng)該相當(dāng)明顯 - 例如秒和分鐘的數(shù)字0到59，以及數(shù)小時(shí)的值0到23。月的日期可以是1-31的任何值，但是您需要小心給定的月份有多少天！可以將月份指定為0到11之間的值，或者使用字符串JAN，F(xiàn)EB，MAR，APR，MAY，JUN，JUL，AUG，SEP，OCT，NOV和DEC?？梢詫⑿瞧趲字付?到7之間的值（1 =星期日），或者使用字符串SUN，MON，TUE，WED，THU，F(xiàn)RI和SAT。
“/”字符可用于指定增量值。例如，如果在“分鐘”字段中輸入“0/15”，則表示“每分鐘15分鐘，從零開始”。如果在“分鐘”字段中使用“3/20”，則意味著“從第三分鐘開始的每20分鐘一小時(shí)” - 或者換句話說，就是在分鐘中指定“3,23,43”領(lǐng)域。請(qǐng)注意“ / 35”并不意味著“每35分鐘” 的微妙含義，即“每分鐘35分鐘，從零開始”，換句話說就是指定“0,35”。
'？' 字符被允許用于日期和星期幾字段。它用來指定“沒有具體的價(jià)值”。當(dāng)你需要在兩個(gè)字段中的一個(gè)字段中指定某些內(nèi)容時(shí)，這是非常有用的，而不是其他的。請(qǐng)參閱下面的示例（和CronTrigger JavaDoc）進(jìn)行說明。
月份和星期幾字段允許使用“L”字符。這個(gè)角色對(duì)于“最后”來說是短暫的，但是在兩個(gè)領(lǐng)域中的每一個(gè)都有不同的含義。例如，月份字段中的值“L”意味著“月份的最后一天”，即非閏年的2月28日的1月31日。如果單獨(dú)使用在星期幾字段中，則僅表示“7”或“SAT”。但是，如果在星期幾字段中使用另一個(gè)值，則表示“本月的最后一個(gè)xxx日”，例如“6L”或“FRIL”都表示“本月的最后一個(gè)星期五”。您還可以指定月份的最后一天的偏移量，例如“L-3”，表示日歷月份的倒數(shù)第三天。當(dāng)使用“L”選項(xiàng)時(shí)，不要指定列表或值的范圍，因?yàn)槟鷷?huì)得到令人困惑/意外的結(jié)果。
“W”用于指定與指定日期最近的星期幾（星期一至星期五）。例如，如果您要指定“15W”作為月份日期字段的值，則其含義是：“最近的星期幾到本月15日”。
“?！庇糜谥付ㄔ撛碌牡趎個(gè)“XXX”工作日。例如，星期幾字段中的“6＃3”或“FRI＃3”的值表示“月的第三個(gè)星期五”。
示例Cron表達(dá)式
CronTrigger示例1 -創(chuàng)建一個(gè)觸發(fā)器的表達(dá)式，每5分鐘查閱【木子道】公眾號(hào)
“0 0/5 * * *？”
CronTrigger示例2 - 一個(gè)表達(dá)式，用于創(chuàng)建在分鐘后10秒（即上午10:00:10，上午10:05:10等）每5分鐘觸發(fā)一次的觸發(fā)器。
“10 0/5 * * *？”
CronTrigger示例3 - 一個(gè)表達(dá)式，用于創(chuàng)建在每周三和周五的10:30，11:30，12:30和13:30發(fā)生的觸發(fā)器。
“0 30 10-13？* WED，F(xiàn)RI“
CronTrigger示例4 - 一個(gè)表達(dá)式，用于創(chuàng)建一個(gè)觸發(fā)器，在每個(gè)月的第5天和第20天的上午8點(diǎn)到上午10點(diǎn)之間每隔半小時(shí)觸發(fā)一次。請(qǐng)注意，觸發(fā)器不會(huì)在上午10點(diǎn)，僅在8點(diǎn)，8點(diǎn)，9點(diǎn)和9點(diǎn)30分
“0 0/30 8-9 5,20 *？”
請(qǐng)注意，一些調(diào)度要求過于復(fù)雜，無法用一個(gè)觸發(fā)器來表示 - 例如“上午9點(diǎn)至上午10點(diǎn)之間每5分鐘一次，下午1點(diǎn)至10點(diǎn)之間每20分鐘一次”。在這種情況下解決方案是簡(jiǎn)單地創(chuàng)建兩個(gè)觸發(fā)器，并注冊(cè)他們兩個(gè)運(yùn)行相同的工作。
JobStore
JobStore負(fù)責(zé)跟蹤所有給調(diào)度器的“工作數(shù)據(jù)”：作業(yè)，觸發(fā)器，日歷等。為您的Quartz調(diào)度器實(shí)例選擇合適的JobStore是非常重要的一步。幸運(yùn)的是，一旦你了解它們之間的差異，選擇應(yīng)該是一個(gè)非常簡(jiǎn)單的選擇。您可以在您提供給SchedulerFactory的屬性文件（或?qū)ο螅┲新暶髂恼{(diào)度程序應(yīng)使用哪個(gè)JobStore（以及它的配置設(shè)置），以便生成調(diào)度程序?qū)嵗?/p>
切勿在代碼中直接使用JobStore實(shí)例。出于某種原因，許多人試圖這樣做。JobStore用于石英本身的幕后使用。你必須告訴Quartz（通過配置）使用哪個(gè)JobStore，但是你只能在你的代碼中使用Scheduler接口。
RAMJobStore
RAMJobStore是最簡(jiǎn)單的JobStore，它也是性能最高的（CPU時(shí)間）。RAMJobStore以明顯的方式得到它的名字：它將所有的數(shù)據(jù)保存在RAM中。這就是為什么它閃電般快速，也是為什么配置如此簡(jiǎn)單。缺點(diǎn)是，當(dāng)你的應(yīng)用程序結(jié)束（或崩潰）時(shí)，所有的調(diào)度信息都將丟失 - 這意味著RAMJobStore無法遵守作業(yè)和觸發(fā)器的“非易失性”設(shè)置。對(duì)于某些應(yīng)用程序來說，這是可以接受的 - 甚至是所需的行為，但是對(duì)于其他應(yīng)用程序來說，這可能是災(zāi)難性的。
JDBCJobStore
JDBCJobStore也被恰當(dāng)?shù)孛?- 它通過JDBC將其所有數(shù)據(jù)保存在數(shù)據(jù)庫中。因此，配置比RAMJobStore要復(fù)雜一些，而且速度也不是那么快。但是，性能退化不是非常糟糕，特別是如果您使用主鍵上的索引構(gòu)建數(shù)據(jù)庫表時(shí)。在相當(dāng)現(xiàn)代的機(jī)器上有一個(gè)體面的局域網(wǎng)（在調(diào)度器和數(shù)據(jù)庫之間），檢索和更新觸發(fā)器的時(shí)間通常小于10毫秒。
JDBCJobStore幾乎可以與任何數(shù)據(jù)庫一起使用，它已經(jīng)被廣泛地用于Oracle，PostgreSQL，MySQL，MS SQLServer，HSQLDB和DB2。要使用JDBCJobStore，必須先為Quartz創(chuàng)建一組數(shù)據(jù)庫表來使用。您可以在Quartz發(fā)行版的“docs / dbTables”目錄中找到創(chuàng)建表的SQL腳本。如果您的數(shù)據(jù)庫類型沒有腳本，只需查看其中一個(gè)腳本，然后以任何必要的方式修改它。有一點(diǎn)需要注意的是，在這些腳本中，所有的表都以前綴“QRTZ_”開頭（例如表“QRTZ_TRIGGERS”和“QRTZ_JOB_DETAIL”）。這個(gè)前綴實(shí)際上可以是任何你想要的，只要你通知JDBCJobStore什么前綴（在你的Quartz屬性中）。使用不同的前綴對(duì)于創(chuàng)建多個(gè)表集合，對(duì)于多個(gè)調(diào)度器實(shí)例，
一旦創(chuàng)建了表，在配置和啟動(dòng)JDBCJobStore之前，還有一個(gè)重要的決定。您需要確定您的應(yīng)用程序需要什么類型的事務(wù)。如果您不需要將調(diào)度命令（如添加和刪除觸發(fā)器）與其他事務(wù)綁定，那么您可以讓Quartz使用JobStoreTX作為JobStore（這是最常見的選擇）來管理事務(wù)。
如果您需要Quartz與其他事務(wù)（即在J2EE應(yīng)用程序服務(wù)器中）一起工作，那么您應(yīng)該使用JobStoreCMT--在這種情況下，Quartz將讓應(yīng)用程序服務(wù)器容器管理事務(wù)。
最后一塊難題是設(shè)置一個(gè)JDBCJobStore可以連接到數(shù)據(jù)庫的DataSource。DataSources是使用幾種不同的方法之一在你的Quartz屬性中定義的。一種方法是讓Quartz創(chuàng)建和管理DataSource本身 - 通過提供數(shù)據(jù)庫的所有連接信息。另一種方法是讓Quartz使用由Quartz運(yùn)行的應(yīng)用程序服務(wù)器管理的DataSource - 通過向JDBCJobStore提供DataSource的JNDI名稱。
TerracottaJobStore
TerracottaJobStore在不使用數(shù)據(jù)庫的情況下提供了擴(kuò)展性和健壯性的手段。這意味著您的數(shù)據(jù)庫可以從Quartz中免費(fèi)下載，并且可以將其所有資源保存到您的應(yīng)用程序的其余部分。
TerracottaJobStore可以運(yùn)行群集或非群集，并且在任何情況下為應(yīng)用程序重新啟動(dòng)之間的持續(xù)工作數(shù)據(jù)提供存儲(chǔ)介質(zhì)，因?yàn)閿?shù)據(jù)存儲(chǔ)在Terracotta服務(wù)器中。它的性能比通過JDBCJobStore使用數(shù)據(jù)庫要好得多（大約好一個(gè)數(shù)量級(jí)），但是比RAMJobStore慢得多。
3.Quartz 的配置與使用
//配置SchedulerFactory
@Bean
public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource) {
SchedulerFactoryBean factory = new SchedulerFactoryBean();
factory.setDataSource(dataSource);
//quartz參數(shù)
Properties prop = new Properties();
prop.put("org.quartz.scheduler.instanceName", "AstaliScheduler");
prop.put("org.quartz.scheduler.instanceId", "AUTO");
//線程池配置
prop.put("org.quartz.threadPool.class", "org.quartz.simpl.SimpleThreadPool");
prop.put("org.quartz.threadPool.threadCount", "20");
prop.put("org.quartz.threadPool.threadPriority", "5");
//JobStore配置
//SQL腳本。http://svn.terracotta.org/svn/quartz/tags/quartz-2.1.3/docs/dbTables/
prop.put("org.quartz.jobStore.class", "org.quartz.impl.jdbcjobstore.JobStoreTX");
//集群配置
prop.put("org.quartz.jobStore.isClustered", "true"); //開啟集群
prop.put("org.quartz.jobStore.clusterCheckinInterval", "15000");
prop.put("org.quartz.jobStore.maxMisfiresToHandleAtATime", "1");
prop.put("org.quartz.jobStore.misfireThreshold", "12000");
prop.put("org.quartz.jobStore.tablePrefix", "QRTZ_"); //表頭
factory.setQuartzProperties(prop);
factory.setSchedulerName("AstaliScheduler");
//延時(shí)啟動(dòng)
factory.setStartupDelay(30);
factory.setApplicationContextSchedulerContextKey("applicationContextKey");
//可選，QuartzScheduler 啟動(dòng)時(shí)更新己存在的Job，
//這樣就不用每次修改targetObject后刪除qrtz_job_details表對(duì)應(yīng)記錄了
factory.setOverwriteExistingJobs(true);
//設(shè)置自動(dòng)啟動(dòng)，默認(rèn)為true
factory.setAutoStartup(true);
return factory;
}
}
//構(gòu)建Job實(shí)例 創(chuàng)建任務(wù)
//ScheduleJob extents QuartzJobBean,QuartzJobBean implements Job
JobDetail jobDetail = JobBuilder.newJob(ScheduleJob.class)
.withIdentity(getJobKey(scheduleJobEntity.getJobId()))
.build();
//構(gòu)建cron
CronScheduleBuilder scheduleBuilde = CronScheduleBuilder
.cronSchedule(scheduleJob.getCronExpression())
.withMisfireHandlingInstructionDoNothing();
//根據(jù)cron，構(gòu)建一個(gè)CronTrigger
CronTrigger trigger = TriggerBuilder.newTrigger()
.withIdentity(getTriggerKey(scheduleJob.getJobId()))
.withSchedule(scheduleBuilder)
.build();
//調(diào)度器的任務(wù)類與觸發(fā)器關(guān)聯(lián)
scheduler.scheduleJob(jobDetail, trigger);
//立即執(zhí)行任務(wù)
JobDataMap dataMap = new JobDataMap();
dataMap.put(ScheduleJobEntity.JOB_PARAM_KEY, new
Gson().toJson(scheduleJob));
scheduler.triggerJob(getJobKey(scheduleJob.getJobId()), dataMap);
//暫定任務(wù)
scheduler.pauseJob(getJobKey(jobId));
//恢復(fù)任務(wù)
scheduler.resumeJob(getJobKey(jobId));
//刪除任務(wù)
scheduler.deleteJob(getJobKey(jobId));
/**
* 獲取觸發(fā)器key
*/
private static TriggerKey getTriggerKey(Long jobId) {
return TriggerKey.triggerKey(JOB_NAME + jobId);
}
/**
* 獲取jobKey
*/
private static JobKey getJobKey(Long jobId) {
return JobKey.jobKey(JOB_NAME + jobId);
}
/**
* 獲取表達(dá)式觸發(fā)器
*/
public static CronTrigger getCronTrigger(Scheduler scheduler, Long jobId) {
try {
return (CronTrigger) scheduler.getTrigger(getTriggerKey(jobId));
} catch (SchedulerException e) {
throw new Exception("getCronTrigger異常，請(qǐng)檢查qrtz開頭的表，是否有臟數(shù)據(jù)", e);
}
}
//上篇文章對(duì)newSingleThreadExecutor有說明
ExecutorService service = Executors.newSingleThreadExecutor();
//執(zhí)行定時(shí)任務(wù)實(shí)現(xiàn)Runnable并重寫run方法
ScheduleRunnable task = new ScheduleRunnable(scheduleJob.getBeanName(),
scheduleJob.getMethodName(),
scheduleJob.getParams());
//提交任務(wù)并有結(jié)果
Future<?> future = service.submit(task);
future.get();
@Override
public void run() {
try {
//利用反射執(zhí)行方法
ReflectionUtils.makeAccessible(method);
if(StringUtils.isNotBlank(params)){
method.invoke(target, params);
}else{
method.invoke(target);
}
}catch (Exception e) {
throw new Exception("執(zhí)行定時(shí)任務(wù)失敗", e);
}
}
建立一個(gè)觸發(fā)器，每隔上午8點(diǎn)到下午5點(diǎn)，每隔一分鐘一次：
trigger = newTrigger()
.withIdentity("trigger3", "group1")
.withSchedule(cronSchedule("0 0/2 8-17 * * ?"))
.forJob("myJob", "group1")
.build();
建立一個(gè)觸發(fā)器，每天在上午10:42開槍：
trigger = newTrigger()
.withIdentity("trigger3", "group1")
.withSchedule(dailyAtHourAndMinute(10, 42))
.forJob(myJobKey)
.build();
效果圖
需要源碼的請(qǐng)關(guān)注公眾號(hào)【木子道】
