(1)什麼是Quartz?
(2)Quartz的特點;
(3)Quartz專用詞彙說明;
(4)Quartz任務排程基本實作原理;
接下來看下具體的内容:
Quartz是一個完全由Java編寫的開源作業排程架構,為在Java應用程式中進行作業排程提供了簡單卻強大的機制。Quartz允許開發人員根據時間間隔來排程作業。它實作了作業和觸發器的多對多的關系,還能把多個作業與不同的觸發器關聯。簡單地建立一個org.quarz.Job接口的Java類。
作為一個優秀的開源排程架構,Quartz 具有以下特點:
① 強大的排程功能,例如支援豐富多樣的排程方法,可以滿足各種正常及特殊需求;
② 靈活的應用方式,例如支援任務和排程的多種組合方式,支援排程資料的多種存儲方式;
③ 分布式和叢集能力,Terracotta 收購後在原來功能基礎上作了進一步提升。
④ Quartz 很容易與 Spring 內建實作靈活可配置的排程功能。
下面是本文中用到的一些專用詞彙,在此聲明:
scheduler:
任務排程器
trigger:
觸發器,用于定義任務排程時間規則
job:
任務,即被排程的任務
misfire:
錯過的,指本來應該被執行但實際沒有被執行的任務排程
Quartz 任務排程的核心元素是 scheduler, trigger 和 job,其中 trigger 和 job 是任務排程的中繼資料,scheduler 是實際執行排程的控制器。
在 Quartz 中,trigger 是用于定義排程時間的元素,即按照什麼時間規則去執行任務。Quartz 中主要提供了四種類型的 trigger:SimpleTrigger,CronTirgger,DateIntervalTrigger,和 NthIncludedDayTrigger。這四種 trigger 可以滿足企業應用中的絕大部分需求。
在 Quartz 中,job 用于表示被排程的任務。主要有兩種類型的 job:無狀态的(stateless)和有狀态的(stateful)。對于同一個 trigger 來說,有狀态的 job 不能被并行執行,隻有上一次觸發的任務被執行完之後,才能觸發下一次執行。Job 主要有兩種屬性:volatility 和 durability,其中 volatility 表示任務是否被持久化到資料庫存儲,而 durability 表示在沒有 trigger 關聯的時候任務是否被保留。兩者都是在值為 true 的時候任務被持久化或保留。一個 job 可以被多個 trigger 關聯,但是一個 trigger 隻能關聯一個 job。
在 Quartz 中, scheduler 由 scheduler 工廠建立:DirectSchedulerFactory 或者 StdSchedulerFactory。 第二種工廠 StdSchedulerFactory 使用較多,因為 DirectSchedulerFactory 使用起來不夠友善,需要作許多詳細的手工編碼設定。 Scheduler 主要有三種:RemoteMBeanScheduler, RemoteScheduler 和 StdScheduler。本文以最常用的 StdScheduler 為例講解。這也是筆者在項目中所使用的 scheduler 類。
這一篇文章,我們緊接着上一篇的文章,講講在Quartz在java project的項目中如何進行使用,在這裡我們使用maven進行建構項目。先看下本章的大綱:
(1)建立工程quartz-java;
(2)配置pom.xml檔案;
(3)編碼說明;
(4)編寫Job類;
(5)編寫啟動類進行代碼測試;
(6)quartz.properties配置檔案說明;
接下裡一起看下具體的内容:
建立一個java project取名為quartz-java。
在pom.xml檔案中添加quartz的依賴:
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.2.3</version>
</dependency>
(一)首先我們需要定義一個任務類,比如為HelloJob ,該類需要繼承Job類,然後添加execute(JobExecutionContext context)方法,在這個方法中就是我們具體的任務執行的地方。
(二)在哪裡定義“在什麼時候執行什麼任務呢?”:那麼我們需要Scheduler,此類的建立方式使用Quartz提供的工廠類StdSchedulerFactory.getDefaultScheduler()進行建立。
(三)如何觸發呢:scheduler.scheduleJob(jobDetail,trigger);進行觸發定時任務,在這裡需要兩個參數。jobDetail可以通過JobBuilder.newJob進行建立,在這裡就需要制定一個Job類了,也就是我們第一步建立的HelloJob;trigger類的話,可以通過TriggerBuilder.newTrigger進行建立。
編寫HelloJob任務類:
package com.kfit.job;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
* 任務類.
* @author Angel --守護天使
* @version v.0.1
* @date 2017年4月21日
*/
public class HelloJob implements Job{
public void execute(JobExecutionContext context) throws JobExecutionException {
// 執行響應的任務.
System.out.println("HelloJob.execute,"+new Date());
}
}
在Main方法中進行編碼測試:
package com.kfit;
import java.util.concurrent.TimeUnit;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import com.kfit.job.HelloJob;
* 直接在Main方法中進行啟動測試.
public class App {
public static void main(String[] args) throws SchedulerException, InterruptedException {
/*
*在 Quartz 中, scheduler 由 scheduler 工廠建立:DirectSchedulerFactory 或者StdSchedulerFactory。第二種工廠 StdSchedulerFactory 使用較多,
*因為 DirectSchedulerFactory 使用起來不夠友善,需要作許多詳細的手工編碼設定。
*/
// 擷取Scheduler執行個體
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
scheduler.start();
System.out.println("scheduler.start");
//具體任務.
JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("job1","group1").build();
//觸發時間點. (每5秒執行1次.)
SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever();
Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1","group1").startNow().withSchedule(simpleScheduleBuilder).build();
// 交由Scheduler安排觸發
scheduler.scheduleJob(jobDetail,trigger);
//睡眠20秒.
TimeUnit.SECONDS.sleep(20);
scheduler.shutdown();//關閉定時任務排程器.
System.out.println("scheduler.shutdown");
執行代碼檢視控制台的列印資訊:
-----------------------------------------------------------
scheduler.start
HelloJob.execute,Fri Apr 21 19:50:01 CST 2017
HelloJob.execute,Fri Apr 21 19:50:06 CST 2017
HelloJob.execute,Fri Apr 21 19:50:11 CST 2017
HelloJob.execute,Fri Apr 21 19:50:16 CST 2017
HelloJob.execute,Fri Apr 21 19:50:21 CST 2017
scheduler.shutdown