隨筆分類(103)

Quartz 是一個強(qiáng)大的企業(yè)級 Schedule 工具，也是目前最好的開源 Schedule 工具，最近因為項目的需要，簡單的用到了 Quartz 的一些功能，對項目中使用 Quartz 的一些問題做簡單的記錄。

在 Quartz 的應(yīng)用中，我們用到了以下的一些東西，ScheduleFactory, Scheduler, Job, JobDetail, Trigger，簡單說明一下他們的用途。

SchedulerFactory 是 Scheduler 的工廠，我們可以從中獲得受工廠管理的 Scheduler 對象。

SchedulerFactory scheduleFactory = new StdSchedulerFactory();
Scheduler scheduler = scheduleFactory.getScheduler();

Scheduler 是一個計劃集，其中可以包含多個 JobDetail 和 Trigger 組成的計劃任務(wù)。
我們可以從 SchedulerFactory 中取得 Scheduler。

接口Job是每個業(yè)務(wù)上需要執(zhí)行的任務(wù)需要實現(xiàn)的接口，該接口只有一個方法：

public interface Job {
    public void execute(JobExecutionContext context)
        throws JobExecutionException;
}

我們可以在里面定義我們的 Job 執(zhí)行邏輯，比如清除過期數(shù)據(jù)，更新緩存等。

JobDetail描述了一個任務(wù)具體的信息，比如名稱，組名等等。
JobDetail jobDetail = new JobDetail("SayHelloWorldJob", Scheduler.DEFAULT_GROUP, SayHelloWorldJob.class);
在上面的構(gòu)造方法中，第一個是任務(wù)的名稱，第二個是組名，第三個就是實際當(dāng)任務(wù)需要執(zhí)行的回調(diào)類。

Trigger顧名思義就是觸發(fā)器，Quartz有個很好的想法就是分離了任務(wù)和任務(wù)執(zhí)行的條件。Trigger就是控制任務(wù)執(zhí)行條件的類，當(dāng)Trigger認(rèn)為執(zhí)行條件滿足的時刻，Trigger會通知相關(guān)的Job去執(zhí)行。分離的好處是：
1.你可以為某個Job關(guān)聯(lián)多個Trigger，其中任何一個條件滿足都可以觸發(fā)job執(zhí)行，這樣可以完成一些組合的高級觸發(fā)條件
2.當(dāng)Trigger失效后（比如：一個永遠(yuǎn)都不能滿足的條件），你不必去聲明一個新的job，代替的是你可以為job關(guān)聯(lián)一個新的Trigger讓job可以繼續(xù)執(zhí)行。

目前的Quartz實現(xiàn)中，存在兩種Trigger,SimpleTrigger和CronTrigger,SimpleTrigger用來完成一些比如固定時間執(zhí)行的任務(wù)，比如：從現(xiàn)在開始1分鐘后等等；而CronTrigger(沒錯，和unix的cron進(jìn)程的含意一樣)用來執(zhí)行calendar-like的任務(wù)，比如：每周五下午3：00，每月最后一天等等。

在我們項目中，都是一些固定時間的 Job，所以只用到了 SimpleTrigger。
Trigger trigger = new SimpleTrigger("SayHelloWorldJobTrigger",Scheduler.DEFAULT_GROUP,new Date(),null,0,0L);
這個構(gòu)造方法中，第一個是Trigger的名稱，第二個是Trigger的組名，第三個是任務(wù)開始時間，第四個是結(jié)束時間，第五個是重復(fù)次數(shù)（使用SimpleTrigger.REPEAT_INDEFINITELY常量表示無限次），最后一個是重復(fù)周期（單位是毫秒），那么這樣就創(chuàng)建了一個立刻并只執(zhí)行一次的任務(wù)。

但我們定義好了 JobDetail，Job，和 Trigger 后，就可以開始 Schedule 一個 Job 了。

scheduler.scheduleJob(jobDetail, trigger);

這條語句就是把job和Trigger關(guān)聯(lián)，這樣當(dāng)Trigger認(rèn)為應(yīng)該觸發(fā)的時候就會調(diào)用（實際上是Scheduler調(diào)用）job.execute方法了。

scheduler.start();
千萬別忘了加上上面的語句，這條語句通知Quartz使安排的計劃生效。

關(guān)于execute方法的參數(shù)JobExecutionContext
JobExecutionContext就和很多Context結(jié)尾的類功能一樣，提供的運(yùn)行時刻的上下文環(huán)境，JobExecutionContext中有Scheduler,JobDetail,Trigger等很多對象的引用，從而當(dāng)你在execute方法內(nèi)部須需要這些對象的時刻提供的便利。

在項目中，我們把需要執(zhí)行的 Job 相對應(yīng)的一些信息放在 JobExecutionContext 中，在 Job 執(zhí)行的時候可以調(diào)用。

jobDetail.getJobDataMap().put(userid, id);

在 Job 中，我們可以拿到相關(guān)的 Context 信息：

jobExecutionContext.getJobDetail().getJobDataMap().getInt(userid);

JobDetail和Trigger的name和group
Scheduler實例對應(yīng)了很多job和trigger的實例，為了方便的區(qū)分，Quartz使用name和group這兩個特性，正如你想向的一樣，同一個group下不能有兩個相同name的JobDetail，Trigger同理，同一個Scheduler下不能有兩個相同group的JobDetail,Trigger同理，JobDetail和Trigger的完全限定名為：group + name

為了讓服務(wù)器重啟以后，我們的 Scheduler 信息仍然不丟失，我們通常采用數(shù)據(jù)庫持久化 Scheduler 的信息。
DBScript 在 Quartz 的下載包中的：quartz-1.6.0\docs\dbTables 下，選擇自己使用的 DB 相應(yīng)的 Script 導(dǎo)入數(shù)據(jù)庫就可以了。
在應(yīng)用中，我們需要配置一個 quartz.properties 才能正常使用 DB。我們可以在 quartz-1.6.0\examples\example10 中找到該文件的樣例，稍作一些修改，就可以放到自己項目源碼的根目錄下使用了。

設(shè)置 org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX 即可啟用基于 JDBC 的 Quartz 信息持久化。

根據(jù)項目情況設(shè)置以下配置信息：
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties = false
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.tablePrefix = QRTZ_
org.quartz.jobStore.isClustered = false

org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/myapplication
org.quartz.dataSource.myDS.user = root
org.quartz.dataSource.myDS.password =
org.quartz.dataSource.myDS.maxConnections = 5

但是光設(shè)置了 Database 不夠，我們還需要在 Application 啟動的時候自動啟動 Scheduler 才行，我們只需要簡單的寫一個 Servlet 的 Listener 并在 web.xml 中聲明該 Listener ，在 Servlet 容易啟動的時候，Scheduler 就開始自動執(zhí)行。

public class ScheduleStartListener implements ServletContextListener {
    public void contextInitialized(ServletContextEvent servletContextEvent) {
        try {
           scheduleFactory.getScheduler().start();
        } catch (SchedulerException e) {
           // write log
        }
    }

    public void contextDestroyed(ServletContextEvent servletContextEvent) {
        try {
           scheduleFactory.getScheduler().shutdown();
        } catch (SchedulerException e) {
           // write log
        }
    }
}

在 web.xml 里面加入以下配置：
<listener>
    <listener-class>org.agilejava.scheduler.ScheduleStartListener</listener-class>
</listener>

以上簡單的記錄了在項目中關(guān)于 Quartz 的一些應(yīng)用，如果有什么新的使用心得，會在后面繼續(xù)加入的。