Quartz是一個作業調度框架，它可以與J2EE和J2SE應用相結合，也可以單獨使用。它能夠創建多個甚至數萬個jobs這樣複雜的程式，jobs可以做成標準的java組件或EJBS。Quartz很容易上手，創建一個任務僅需實現Job介面，該介面只有一個方法void execute(JobExecuti... ...
1 什麼是Quartz
Quartz是一個作業調度框架，它可以與J2EE和J2SE應用相結合，也可以單獨使用。它能夠創建多個甚至數萬個jobs這樣複雜的程式，jobs可以做成標準的java組件或EJBS。Quartz很容易上手，創建一個任務僅需實現Job介面，該介面只有一個方法void execute(JobExecutionContext context) throws JobExecutionException;在java實現類添加作業邏輯，當配置好Job實現類並設置調度時間表後，Quartz將會監控任務的剩餘時間，當調度程式確定需要通知需要執行該任務的時候，Quartz將會調用Job實現類的execute方法執行任務。
2 系統設計
Quartz框架的原理主要是通過將Job註冊到調度器，再通過觸發器策略執行Job，系統設計如下：
3 核心元素介紹
Quartz框架的核心是調度器scheduler，核心的組件包括Job（任務）、JobDetail（任務描述）、Trigger（觸發器）。調度器負責管理Quartz應用運行時環境。調度器不是靠自己做所有的工作，而是依賴框架內一些非常重要的部件。Quartz不僅僅是線程和線程管理。為確保可伸縮性，Quartz採用了基於多線程的架構。啟動時，框架初始化一套worker線程，這套線程被調度器用來執行預定的作業。這就是Quartz怎樣能併發運行多個作業的原理。Quartz依賴一套松耦合的線程池管理部件來管理線程環境。
3.1 Job
Job是一個介面，只有一個方法void execute(JobExecutionContext context) throws JobExecutionException。作業類需要實現介面中的execute方法，JobExecutionContext提供了調度的上下文信息，每一次執行Job都會重新創建一個Job對象實例。如下：
public interface Job {
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*
* Interface.
*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
/**
* <p>
* Called by the <code>{@link Scheduler}</code> when a <code>{@link Trigger}</code>
* fires that is associated with the <code>Job</code>.
* </p>
*
* <p>
* The implementation may wish to set a
* {@link JobExecutionContext#setResult(Object) result} object on the
* {@link JobExecutionContext} before this method exits. The result itself
* is meaningless to Quartz, but may be informative to
* <code>{@link JobListener}s</code> or
* <code>{@link TriggerListener}s</code> that are watching the job's
* execution.
* </p>
*
* @throws JobExecutionException
* if there is an exception while executing the job.
*/
void execute(JobExecutionContext context)
throws JobExecutionException;
}
public class ClosePayJob implements Job{
public void execute(JobExecutionContext context) throws JobExecutionException{
//業務邏輯
}
}
3.2 JobDetail
Quartz框架在每次執行Job時，都會重新創建一個Job對象實例，所以它需要Job類的信息以及其他相關信息，以便能夠在運行時通過newInstance()的反射機制實例化Job。因此需要通過一個類來描述Job的實現類及其它相關的靜態信息，比如Job名字、描述、關聯監聽器等信息。JobDetail介面包含了能夠創建Job類的信息載體，用來保存任務的詳細信息。如下代碼定義
public interface JobDetail extends Serializable, Cloneable {
public JobKey getKey();
/**
* <p>
* Return the description given to the <code>Job</code> instance by its
* creator (if any).
* </p>
*
* @return null if no description was set.
*/
public String getDescription();
/**
* <p>
* Get the instance of <code>Job</code> that will be executed.
* </p>
*/
public Class<? extends Job> getJobClass();
/**
* <p>
* Get the <code>JobDataMap</code> that is associated with the <code>Job</code>.
* </p>
*/
public JobDataMap getJobDataMap();
/**
* <p>
* Whether or not the <code>Job</code> should remain stored after it is
* orphaned (no <code>{@link Trigger}s</code> point to it).
* </p>
*
* <p>
* If not explicitly set, the default value is <code>false</code>.
* </p>
*
* @return <code>true</code> if the Job should remain persisted after
* being orphaned.
*/
public boolean isDurable();
/**
* @see PersistJobDataAfterExecution
* @return whether the associated Job class carries the {@link PersistJobDataAfterExecution} annotation.
*/
public boolean isPersistJobDataAfterExecution();
/**
* @see DisallowConcurrentExecution
* @return whether the associated Job class carries the {@link DisallowConcurrentExecution} annotation.
*/
public boolean isConcurrentExectionDisallowed();
/**
* <p>
* Instructs the <code>Scheduler</code> whether or not the <code>Job</code>
* should be re-executed if a 'recovery' or 'fail-over' situation is
* encountered.
* </p>
*
* <p>
* If not explicitly set, the default value is <code>false</code>.
* </p>
*
* @see JobExecutionContext#isRecovering()
*/
public boolean requestsRecovery();
public Object clone();
/**
* Get a {@link JobBuilder} that is configured to produce a
* <code>JobDetail</code> identical to this one.
*/
public JobBuilder getJobBuilder();
}
3.3 Trigger
觸發器（org.quartz.Trigger）抽象類的幾個主要屬性和JobDetail差不多，這裡就不說明瞭，主要註意的是misfireInstruction這個屬性，misfireInstruction這個屬性的是觸發器錯失執行（misfire）後的一個錯失觸發機制標識。當線程池中沒有可用的線程執行任務時，就會錯過觸發時間，Trigger抽象類中預設錯失觸發機制是常量0（聰明的策略）。派生類有它們自己的錯失觸發機制。最常用的兩種是SimpleTrigger和CronTrigger。
3.3.1 SimpleTrigger
指定從某一個時間開始，以一定的時間間隔（單位是毫秒）執行的任務。
它適合的任務類似於：9:00 開始，每隔1小時，執行一次。
它的屬性有：
- repeatInterval 重覆間隔
- repeatCount 重覆次數。實際執行次數是 repeatCount+1。因為在startTime的時候一定會執行一次。** 下麵有關repeatCount 屬性的都是同理
3.3.2 CronTrigger
適合於更複雜的任務，它支持類型於Linux Cron的語法（並且更強大）。基本上它覆蓋了其他Trigger的絕大部分能力—— 當然，也更難理解。
它適合的任務類似於：每天0:00,9:00,18:00各執行一次。
它的屬性只有：Cron表達式。
4 總結
本次文章只是對Quartz的架構和基本元素做了簡單的介紹，後面我們會深入分析Quartz的核心類。
作者：京東物流 賈永強
來源：京東雲開發者社區 自猿其說Tech 轉載請註明來源
