一诡曙、關(guān)于 Quartz

Quartz logo

• Quartz 是一個(gè)完全由 Java 編寫的開源作業(yè)調(diào)度框架，為在 Java 應(yīng)用程序中進(jìn)行作業(yè)調(diào)度提供了簡(jiǎn)單卻強(qiáng)大的機(jī)制笆豁。
• Quartz 可以與 J2EE 與 J2SE 應(yīng)用程序相結(jié)合也可以單獨(dú)使用郎汪。
• Quartz 允許程序開發(fā)人員根據(jù)時(shí)間的間隔來調(diào)度作業(yè)定欧。
• Quartz 實(shí)現(xiàn)了作業(yè)和觸發(fā)器的多對(duì)多的關(guān)系，還能把多個(gè)作業(yè)與不同的觸發(fā)器關(guān)聯(lián)怒竿。

二、Quartz 核心概念

核心組件

• Scheduler：調(diào)度容器
• Job：Job接口類扩氢，即被調(diào)度的任務(wù)
• JobDetail ：Job的描述類耕驰，job執(zhí)行時(shí)的依據(jù)此對(duì)象的信息反射實(shí)例化出Job的具體執(zhí)行對(duì)象。
• Trigger：觸發(fā)器录豺，存放Job執(zhí)行的時(shí)間策略朦肘。用于定義任務(wù)調(diào)度時(shí)間規(guī)則。
• JobStore： 存儲(chǔ)作業(yè)和調(diào)度期間的狀態(tài)
• Calendar：指定排除的時(shí)間點(diǎn)（如排除法定節(jié)假日）

job

Job 是一個(gè)接口双饥，只有一個(gè)方法 void execute(JobExecutionContext context)媒抠，開發(fā)者實(shí)現(xiàn)接口來定義任務(wù)。JobExecutionContext 類提供了調(diào)度上下文的各種信息咏花。Job 運(yùn)行時(shí)的信息保存在 JobDataMap 實(shí)例中趴生。例如：

public class HelloJob implements BaseJob {
    private static Logger _log = LoggerFactory.getLogger(HelloJob.class);  
    public HelloJob() { }  
    public void execute(JobExecutionContext context) throws JobExecutionException {
        _log.error("Hello Job執(zhí)行時(shí)間: " + new Date());
    }
}  

JobDetailImpl 類 / JobDetail 接口

JobDetailImpl類實(shí)現(xiàn)了JobDetail接口，用來描述一個(gè) job昏翰，定義了job所有屬性及其 get/set 方法苍匆。下面是 job 內(nèi)部的主要屬性：

Trigger

是一個(gè)類智蝠，描述觸發(fā)Job執(zhí)行的時(shí)間觸發(fā)規(guī)則。主要有 SimpleTrigger 和 CronTrigger 這兩個(gè)子類奈梳。當(dāng)僅需觸發(fā)一次或者以固定時(shí)間間隔周期執(zhí)行杈湾，SimpleTrigger是最適合的選擇；而CronTrigger則可以通過Cron表達(dá)式定義出各種復(fù)雜時(shí)間規(guī)則的調(diào)度方案：如每早晨9:00執(zhí)行攘须，周一漆撞、周三、周五下午5:00執(zhí)行等于宙；

以下是 trigger 的屬性：

Calendar

org.quartz.Calendar和 java.util.Calendar不同征候，它是一些日歷特定時(shí)間點(diǎn)的集合（可以簡(jiǎn)單地將org.quartz.Calendar看作java.util.Calendar的集合——java.util.Calendar代表一個(gè)日歷時(shí)間點(diǎn)杭攻，無特殊說明后面的Calendar即指org.quartz.Calendar）。一個(gè)Trigger可以和多個(gè)Calendar關(guān)聯(lián)疤坝，以便排除或包含某些時(shí)間點(diǎn)兆解。假設(shè)，我們安排每周星期一早上10:00執(zhí)行任務(wù)跑揉，但是如果碰到法定的節(jié)日锅睛，任務(wù)則不執(zhí)行，這時(shí)就需要在Trigger觸發(fā)機(jī)制的基礎(chǔ)上使用Calendar進(jìn)行定點(diǎn)排除历谍。

Scheduler

調(diào)度器现拒，代表一個(gè)Quartz的獨(dú)立運(yùn)行容器，好比一個(gè)『大管家』望侈，這個(gè)大管家應(yīng)該可以接受 Job印蔬， 然后按照各種Trigger去運(yùn)行，Trigger和JobDetail可以注冊(cè)到Scheduler中脱衙，兩者在Scheduler中擁有各自的組及名稱侥猬，組及名稱是Scheduler查找定位容器中某一對(duì)象的依據(jù)例驹，Trigger的組及名稱必須唯一，JobDetail的組和名稱也必須唯一（但可以和Trigger的組和名稱相同退唠，因?yàn)樗鼈兪遣煌愋偷模┚樾狻cheduler定義了多個(gè)接口方法，允許外部通過組及名稱訪問和控制容器中Trigger和JobDetail瞧预。

image

ThreadPool

Scheduler 使用一個(gè)線程池作為任務(wù)運(yùn)行的基礎(chǔ)設(shè)施弧可，任務(wù)通過共享線程池中的線程提高運(yùn)行效率。

進(jìn)行一個(gè)定時(shí)任務(wù)的簡(jiǎn)單實(shí)例

public class JobTest implements BaseJob {
    private static org.slf4j.Logger log = LoggerFactory.getLogger(JobTest.class);

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        log.error("JobTest 執(zhí)行時(shí)間: " + new Date());
    }
}

@Test
public void quartzTest() throws SchedulerException{
    // 1. 創(chuàng)建 SchedulerFactory
    SchedulerFactory factory = new StdSchedulerFactory();
    // 2. 從工廠中獲取調(diào)度器實(shí)例
    Scheduler scheduler = factory.getScheduler();

    // 3. 引進(jìn)作業(yè)程序
    JobDetail jobDetail = JobBuilder.newJob(JobTest.class).withDescription("this is a ram job") //job的描述
            .withIdentity("jobTest", "jobTestGrip") //job 的name和group
            .build();

    long time=  System.currentTimeMillis() + 3*1000L; //3秒后啟動(dòng)任務(wù)
    Date statTime = new Date(time);

    // 4. 創(chuàng)建Trigger
    //使用SimpleScheduleBuilder或者CronScheduleBuilder
    Trigger trigger = TriggerBuilder.newTrigger()
            .withDescription("this is a cronTrigger")
            .withIdentity("jobTrigger", "jobTriggerGroup")
            //.withSchedule(SimpleScheduleBuilder.simpleSchedule())
            .startAt(statTime)  //默認(rèn)當(dāng)前時(shí)間啟動(dòng)
            .withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ?")) //兩秒執(zhí)行一次
            .build();

    // 5. 注冊(cè)任務(wù)和定時(shí)器
    scheduler.scheduleJob(jobDetail, trigger);

    // 6. 啟動(dòng) 調(diào)度器
    scheduler.start();
    _log.info("啟動(dòng)時(shí)間 ： " + new Date());
}

三劣欢、Quartz 設(shè)計(jì)分析

quartz.properties文件

Quartz 有一個(gè)叫做quartz.properties的配置文件棕诵，它允許你修改框架運(yùn)行時(shí)環(huán)境。缺省是使用 Quartz.jar 里面的quartz.properties 文件凿将。你應(yīng)該創(chuàng)建一個(gè) quartz.properties 文件的副本并且把它放入你工程的 classes 目錄中以便類裝載器找到它校套。

// 調(diào)度標(biāo)識(shí)名 集群中每一個(gè)實(shí)例都必須使用相同的名稱 （區(qū)分特定的調(diào)度器實(shí)例） 
org.quartz.scheduler.instanceName：DefaultQuartzScheduler 
// ID設(shè)置為自動(dòng)獲取 每一個(gè)必須不同 （所有調(diào)度器實(shí)例中是唯一的） 
org.quartz.scheduler.instanceId ：AUTO 
// 數(shù)據(jù)保存方式為持久化 
org.quartz.jobStore.class ：org.quartz.impl.jdbcjobstore.JobStoreTX 
// 表的前綴 
org.quartz.jobStore.tablePrefix ： QRTZ_ 
// 設(shè)置為TRUE不會(huì)出現(xiàn)序列化非字符串類到 BLOB 時(shí)產(chǎn)生的類版本問題 
// org.quartz.jobStore.useProperties ： true 
// 加入集群 true 為集群 false不是集群 
org.quartz.jobStore.isClustered ： false 
// 調(diào)度實(shí)例失效的檢查時(shí)間間隔 
org.quartz.jobStore.clusterCheckinInterval：20000 
// 容許的最大作業(yè)延長(zhǎng)時(shí)間 
org.quartz.jobStore.misfireThreshold ：60000 
// ThreadPool 實(shí)現(xiàn)的類名 
org.quartz.threadPool.class：org.quartz.simpl.SimpleThreadPool 
// 線程數(shù)量 
org.quartz.threadPool.threadCount ： 10 
// 線程優(yōu)先級(jí) 
// threadPriority 屬性的最大值是常量 java.lang.Thread.MAX_PRIORITY，等于10牧抵。最小值為常量 java.lang.Thread.MIN_PRIORITY笛匙，為1
org.quartz.threadPool.threadPriority ： 5
// 自創(chuàng)建父線程 
//org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread： true 
// 數(shù)據(jù)庫別名 
org.quartz.jobStore.dataSource ： qzDS 
// 設(shè)置數(shù)據(jù)源 
org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver 
org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartz 
org.quartz.dataSource.qzDS.user:root 
org.quartz.dataSource.qzDS.password:123456 
org.quartz.dataSource.qzDS.maxConnection:10

Quartz 調(diào)度器

Quartz框架的核心是調(diào)度器。調(diào)度器負(fù)責(zé)管理Quartz應(yīng)用運(yùn)行時(shí)環(huán)境犀变。啟動(dòng)時(shí)妹孙，框架初始化一套worker線程，這套線程被調(diào)度器用來執(zhí)行預(yù)定的作業(yè)获枝。這就是 Quartz 怎樣能并發(fā)運(yùn)行多個(gè)作業(yè)的原理记劈。Quartz 依賴一套松耦合的線程池管理部件來管理線程環(huán)境务荆。

兩種作業(yè)存儲(chǔ)方式

1. RAMJobStore

- 通常的內(nèi)存來持久化調(diào)度程序信息。這種作業(yè)存儲(chǔ)類型最容易配置馆衔、構(gòu)造和運(yùn)行。
- 因?yàn)檫@種方式的調(diào)度程序信息是被分配到 JVM 內(nèi)存中嘹裂，所以，當(dāng)應(yīng)用程序停止運(yùn)行時(shí)，所有調(diào)度信息將被丟失旭旭。如果你需要在重新啟動(dòng)之間持久化調(diào)度信息，則將需要第二種類型的作業(yè)存儲(chǔ)葱跋。 

2. JDBC作業(yè)存儲(chǔ)

- 需要JDBC驅(qū)動(dòng)程序和后臺(tái)數(shù)據(jù)庫來持久化調(diào)度程序信息（支持集群）

表關(guān)系和解釋

表關(guān)系

表名稱 | 說明
qrtz_blob_triggers | Trigger作為Blob類型存儲(chǔ)(用于Quartz用戶用JDBC創(chuàng)建他們自己定制的Trigger類型持寄，JobStore 并不知道如何存儲(chǔ)實(shí)例的時(shí)候)
qrtz_calendars | 以Blob類型存儲(chǔ)Quartz的Calendar日歷信息， quartz可配置一個(gè)日歷來指定一個(gè)時(shí)間范圍
qrtz_cron_triggers | 存儲(chǔ)Cron Trigger娱俺，包括Cron表達(dá)式和時(shí)區(qū)信息稍味。
qrtz_fired_triggers |   存儲(chǔ)與已觸發(fā)的Trigger相關(guān)的狀態(tài)信息，以及相聯(lián)Job的執(zhí)行信息
qrtz_job_details | 存儲(chǔ)每一個(gè)已配置的Job的詳細(xì)信息
qrtz_locks |    存儲(chǔ)程序的非觀鎖的信息(假如使用了悲觀鎖)
qrtz_paused_trigger_graps |     存儲(chǔ)已暫停的Trigger組的信息
qrtz_scheduler_state |  存儲(chǔ)少量的有關(guān) Scheduler的狀態(tài)信息荠卷，和別的 Scheduler 實(shí)例(假如是用于一個(gè)集群中)
qrtz_simple_triggers     | 存儲(chǔ)簡(jiǎn)單的 Trigger模庐，包括重復(fù)次數(shù)，間隔油宜，以及已觸的次數(shù)
qrtz_triggers    | 存儲(chǔ)已配置的 Trigger的信息
qrzt_simprop_triggers   

利用 SpringBoot + Quartz 搭建的界面化的 Demo

在網(wǎng)上找到一個(gè)搭好的 Demo掂碱，感謝大神！原文： Spring Boot集成持久化Quartz定時(shí)任務(wù)管理和界面展示

本工程所用到的技術(shù)或工具

Spring Boot
Mybatis
Quartz
PageHelper
VueJS
ElementUI
MySql數(shù)據(jù)庫

先看圖：

效果圖.png

新建任務(wù).png

源碼地址

• 我的github
• 我的碼云
• 原項(xiàng)目github

參考資料

• quartz原理揭秘和源碼解讀
• quartz由淺入深
• Quartz官方文檔
• Spring Boot集成持久化Quartz定時(shí)任務(wù)管理和界面展示