什么是job schedule system?
??? job schedule system是負(fù)責(zé)在預(yù)定義的時(shí)間執(zhí)行或者通知某個(gè)應(yīng)用組件的系統(tǒng)。舉個(gè)例子來(lái)說(shuō)，比如在每周一早上9：30發(fā)送email通知客戶(hù)最新的業(yè)務(wù)情況。
java.util.Timer和java.util.TimerTask
??? Timer和TimerTask是可以完成job schedule的兩個(gè)jdk提供的類(lèi)，不過(guò)這不能稱(chēng)為一個(gè)system。Timer和TimerTask是很簡(jiǎn)單的，不直接支持持久化任務(wù)，線程池和類(lèi)似日歷(calendar-like)的計(jì)劃安排，在完成一些高級(jí)功能上開(kāi)發(fā)人員要進(jìn)行大量的擴(kuò)展。
Quartz的簡(jiǎn)單介紹
??? Quartz是opensymphony組織專(zhuān)攻job scheduling領(lǐng)域又一個(gè)開(kāi)源利器，可以到http://www.opensymphony.com/quartz查看詳細(xì)信息。Quartz是輕量級(jí)的組件，開(kāi)發(fā)人員只需要加載單獨(dú)的jar包就可以利用Quartz強(qiáng)大的日程安排功能。當(dāng)然，假如你為Quartz配備了數(shù)據(jù)庫(kù)持久化任務(wù)的特性，Quartz也可以很好的利用這一點(diǎn)，從而在機(jī)器重啟后還能夠記住你原先安排的計(jì)劃。
??? Quartz中我們接觸最多的接口使Scheduler接口，該接口的提供了計(jì)劃安排的功能，比如schedule/unschedule計(jì)劃、start/pause/stop Scheduler.
??? Quartz提供一些常用的Listener(JobListener,TriggerListener,SchedulerListener)用于完全的監(jiān)視計(jì)劃安排和執(zhí)行情況。
開(kāi)始我們的Quartz之旅
想必大家很想看一個(gè)HelloWorld的例子了吧，那么還是以HellowWorld開(kāi)始。
import java.util.Date;
?import org.quartz.Job;
?import org.quartz.JobDetail;
?import org.quartz.JobExecutionContext;
?import org.quartz.JobExecutionException;
?import org.quartz.Scheduler;
?import org.quartz.SchedulerFactory;
?import org.quartz.Trigger;
?import org.quartz.impl.StdSchedulerFactory;
?/**
? * @author snowway
? * @version $Id$
? */
?public class SayHelloWorldJob implements Job{
???? /*
????? * (non-Javadoc)
????? *
????? * @see org.quartz.Job#execute(org.quartz.JobExecutionContext)
????? */
???? public void execute(JobExecutionContext context) throws JobExecutionException{
???????? System.out.println("hello world!");
???? }
???? public static void main(String[] args) throws Exception{
???????? SchedulerFactory factory = new StdSchedulerFactory();
???????? Scheduler scheduler = factory.getScheduler();
???????? JobDetail jobDetail = new JobDetail("SayHelloWorldJob",
???????????????? Scheduler.DEFAULT_GROUP,
???????????????? SayHelloWorldJob.class);
???????? Trigger trigger = new SimpleTrigger("SayHelloWorldJobTrigger",
???????????????? Scheduler.DEFAULT_GROUP,
???????????????? new Date(),
???????????????? null,
???????????????? 0,
???????????????? 0L);
???????? scheduler.scheduleJob(jobDetail, trigger);
???????? scheduler.start();
???? }
?}
為了簡(jiǎn)單起見(jiàn)，我把main方法寫(xiě)在SayHelloWorldJob中了，執(zhí)行SayHelloWorldJob可以看到控制臺(tái)打印hello world.
?Job是什么？
?接口Job是每個(gè)業(yè)務(wù)上需要執(zhí)行的任務(wù)需要實(shí)現(xiàn)的接口，該接口只有一個(gè)方法：
?package org.quartz;
??? public interface Job {
????? public void execute(JobExecutionContext context)
??????? throws JobExecutionException;
??? }
?execute方法也就是當(dāng)時(shí)間到達(dá)后，Quartz回調(diào)的方法，我們使SayHelloWorldJob實(shí)現(xiàn)Job接口以提供打印功能
?
JobDetail是什么？
?JobDetail描述了一個(gè)任務(wù)具體的信息，比如名稱(chēng)，組名等等。
?JobDetail jobDetail = new JobDetail("SayHelloWorldJob",
???????????????? Scheduler.DEFAULT_GROUP,
???????????????? SayHelloWorldJob.class);
?在上面的構(gòu)造方法中，第一個(gè)是任務(wù)的名稱(chēng)，第二個(gè)是組名，第三個(gè)就是實(shí)際當(dāng)任務(wù)需要執(zhí)行的回調(diào)類(lèi)。
?Trigger是什么？
?Trigger顧名思義就是觸發(fā)器，Quartz有個(gè)很好的想法就是分離了任務(wù)和任務(wù)執(zhí)行的條件。Trigger就是控制任務(wù)執(zhí)行條件的類(lèi)，當(dāng)Trigger認(rèn)為執(zhí)行條件滿足的時(shí)刻，Trigger會(huì)通知相關(guān)的Job去執(zhí)行。分離的好處是：
?1.你可以為某個(gè)Job關(guān)聯(lián)多個(gè)Trigger，其中任何一個(gè)條件滿足都可以觸發(fā)job執(zhí)行，這樣可以完成一些組合的高級(jí)觸發(fā)條件
?2.當(dāng)Trigger失效后（比如：一個(gè)永遠(yuǎn)都不能滿足的條件），你不必去聲明一個(gè)新的job，代替的是你可以為job關(guān)聯(lián)一個(gè)新的Trigger讓job可以繼續(xù)執(zhí)行。
?目前的Quartz實(shí)現(xiàn)中，存在兩種Trigger,SimpleTrigger和CronTrigger,SimpleTrigger用來(lái)完成一些比如固定時(shí)間執(zhí)行的任務(wù)，比如：從現(xiàn)在開(kāi)始1分鐘后等等；而CronTrigger(沒(méi)錯(cuò)，和unix的cron進(jìn)程的含意一樣)用來(lái)執(zhí)行calendar-like的任務(wù)，比如：每周五下午3：00，每月最后一天等等。
?Trigger trigger = new SimpleTrigger("SayHelloWorldJobTrigger",
???????????????? Scheduler.DEFAULT_GROUP,
???????????????? new Date(),
???????????????? null,
???????????????? 0,
???????????????? 0L);
?這個(gè)構(gòu)造方法中，第一個(gè)是Trigger的名稱(chēng)，第二個(gè)是Trigger的組名，第三個(gè)是任務(wù)開(kāi)始時(shí)間，第四個(gè)是結(jié)束時(shí)間，第五個(gè)是重復(fù)
?次數(shù)（使用SimpleTrigger.REPEAT_INDEFINITELY常量表示無(wú)限次），最后一個(gè)是重復(fù)周期（單位是毫秒），那么這樣就創(chuàng)建
?了一個(gè)立刻并只執(zhí)行一次的任務(wù)。
?scheduler.scheduleJob(jobDetail, trigger);
?這條語(yǔ)句就是把job和Trigger關(guān)聯(lián)，這樣當(dāng)Trigger認(rèn)為應(yīng)該觸發(fā)的時(shí)候就會(huì)調(diào)用（實(shí)際上是Scheduler調(diào)用）job.execute方法了。
?scheduler.start();
?千萬(wàn)別忘了加上上面的語(yǔ)句，這條語(yǔ)句通知Quartz使安排的計(jì)劃生效。
?關(guān)于execute方法的參數(shù)JobExecutionContext
?JobExecutionContext就和很多Context結(jié)尾的類(lèi)功能一樣，提供的運(yùn)行時(shí)刻的上下文環(huán)境，JobExecutionContext中有
?Scheduler,JobDetail,Trigger等很多對(duì)象的引用，從而當(dāng)你在execute方法內(nèi)部須需要這些對(duì)象的時(shí)刻提供的便利。
?
JobDetail和Trigger的name和group
?Scheduler實(shí)例對(duì)應(yīng)了很多job和trigger的實(shí)例，為了方便的區(qū)分，Quartz使用name和group這兩個(gè)特性，正如你想向的一樣，
?同一個(gè)group下不能有兩個(gè)相同name的JobDetail，Trigger同理
?同一個(gè)Scheduler下不能有兩個(gè)相同group的JobDetail,Trigger同理
?JobDetail和Trigger的完全限定名為：group + name
HelloWorld的例子還不足以說(shuō)明一些問(wèn)題，一些人可能會(huì)這樣問(wèn):假如execute方法中需要一些額外的數(shù)據(jù)怎么辦？比如說(shuō)execute
?中希望發(fā)送一封郵件，但是我需要知道郵件的發(fā)送者、接收者等信息?
?存在兩種解決方案：
?1.JobDataMap類(lèi)：
?? 每個(gè)JobDetail都關(guān)聯(lián)了一個(gè)JobDataMap實(shí)例，JobDataMap是java.util.Map的子類(lèi)，基本上是提供key-value形式的數(shù)據(jù)，并提供了一些便利方法（主要是對(duì)java基本數(shù)據(jù)類(lèi)型的支持，如put(String key,int value)），當(dāng)開(kāi)發(fā)人員創(chuàng)建JobDetail的時(shí)候，可以把附加信息放到JobDataMap中，那么在execute方法中可以根據(jù)key找到需要的值。
?? JobDetail job = new JobDetail....
?? job.getJobDataMap().put("from","snowway@vip.sina.com");
?? ...??
在execute中
?? String from = jobExecutionContext.getJobDetail().getJobDataMap().getString("from");
?? ....
?? 不過(guò)，當(dāng)你使用數(shù)據(jù)庫(kù)存儲(chǔ)JobDetail的時(shí)候（默認(rèn)情況下使用RAM），這里有一個(gè)致命的弱點(diǎn)，你不能把沒(méi)有實(shí)現(xiàn)java.io.Serializable的對(duì)象放入JobDataMap中，因?yàn)镼uartz將使用Blob字段保存（也可以通過(guò)配置文件關(guān)閉）序列化過(guò)的JobDataMap中的對(duì)象。比如你在execute方法中需要一個(gè)java.sql.Connection接口實(shí)例，這種情況也是普遍的，那么通常情況下你不能把Connection放入JobDataMap，即使你只想在execute中使用。（注：讀者可暫時(shí)認(rèn)為上面這段話是正確的，然而可以通過(guò)指示quartz改變這種行為，那屬于高級(jí)話題）
?2.假如你需要一個(gè)java.sql.Connection，用于在execute中完成某些操作，那么你可以把Connection放入Quartz的SchedulerContext中，execute也可以訪問(wèn)，并且Quartz不會(huì)持久化SchedulerContext中的任何東西。
?? scheduler.getContext().put("java.sql.Connection",connection);??
?execute中
?? Connection con = (Connection)jobExecutionContext.getScheduler().getContext().get("java.sql.Connection");
?未完待續(xù)...