摘要：觸發(fā)器也可以給予名稱和放置在組中，以方便地將它們調(diào)度內(nèi)組織。作業(yè)可以被添加到所述調(diào)度器一次，而是具有多個(gè)觸發(fā)器注冊(cè)。調(diào)度類鏈接工作和觸發(fā)器到一起，并執(zhí)行它。

Quartz是一個(gè)開源的作業(yè)調(diào)度框架，可以讓計(jì)劃的程序任務(wù)一個(gè)預(yù)定義的日期和時(shí)間運(yùn)行。Quartz可以用來(lái)創(chuàng)建簡(jiǎn)單或復(fù)雜的日程安排執(zhí)行幾十，幾百，甚至是十萬(wàn)的作業(yè)數(shù)。
官方鏈接，戳這里

Quartz 是一種功能豐富的，開放源碼的作業(yè)調(diào)度庫(kù)，可以在幾乎任何Java應(yīng)用程序集成 - 從最小的獨(dú)立的應(yīng)用程序到規(guī)模最大電子商務(wù)系統(tǒng)。Quartz可以用來(lái)創(chuàng)建簡(jiǎn)單或復(fù)雜的日程安排執(zhí)行幾十，幾百，甚至是十萬(wàn)的作業(yè)數(shù) - 作業(yè)被定義為標(biāo)準(zhǔn)的Java組件，可以執(zhí)行幾乎任何東西，可以編程讓它們執(zhí)行。 Quartz調(diào)度包括許多企業(yè)級(jí)功能，如JTA事務(wù)和集群支持。

Quartz 是可自由使用，使用Apache 2.0 license授權(quán)方式。

如果應(yīng)用程序需要在給定時(shí)間執(zhí)行任務(wù)，或者如果系統(tǒng)有連續(xù)維護(hù)作業(yè)，那么Quartz是理想的解決方案。

作業(yè)被安排在一個(gè)給定的觸發(fā)時(shí)運(yùn)行。觸發(fā)器可以使用以下指令的接近任何組合來(lái)創(chuàng)建：

在一天中的某個(gè)時(shí)間（到毫秒）

在一周的某幾天

在每月的某一天

在一年中的某些日期

不在注冊(cè)的日歷中列出的特定日期（如商業(yè)節(jié)假日除外）

重復(fù)特定次數(shù)

重復(fù)進(jìn)行，直到一個(gè)特定的時(shí)間/日期

無(wú)限重復(fù)

重復(fù)的延遲時(shí)間間隔

作業(yè)是由其創(chuàng)建者賦予的名字，也可以組織成命名組。觸發(fā)器也可以給予名稱和放置在組中，以方便地將它們調(diào)度內(nèi)組織。作業(yè)可以被添加到所述調(diào)度器一次，而是具有多個(gè)觸發(fā)器注冊(cè)。在企業(yè)Java環(huán)境中，作業(yè)可以執(zhí)行自己的工作作為分布式（XA）事務(wù)的一部分。

故障切換

負(fù)載均衡

Quartz的內(nèi)置的群集功能，通過JDBCJobStore依靠數(shù)據(jù)庫(kù)持久

Terracotta擴(kuò)展Quartz提供集群功能，而不需要一個(gè)支持?jǐn)?shù)據(jù)庫(kù)

quartz-2.2.1.jar

quartz-jobs-2.2.1.jar

調(diào)度器。所有的調(diào)度都是由它控制。調(diào)度類鏈接“工作”和“觸發(fā)器”到一起，并執(zhí)行它。

scheduler 實(shí)例化后，可以啟動(dòng)(start)、暫停(stand-by)、停止(shutdown)。注意：scheduler 被停止后，除非重新實(shí)例化，否則不能重新啟動(dòng)；只有當(dāng) scheduler 啟動(dòng)后，即使處于暫停狀態(tài)也不行，trigger 才會(huì)被觸發(fā)（job才會(huì)被執(zhí)行）

Scheduler的生命期，從SchedulerFactory創(chuàng)建它時(shí)開始，到Scheduler調(diào)用shutdown()方法時(shí)結(jié)束；Scheduler被創(chuàng)建后，可以增加、刪除和列舉Job和Trigger，以及執(zhí)行其它與調(diào)度相關(guān)的操作（如暫停Trigger）。但是，Scheduler只有在調(diào)用start()方法后，才會(huì)真正地觸發(fā)trigger（即執(zhí)行job）

Scheduler scheduler = new StdSchedulerFactory().getScheduler();
scheduler.start();
scheduler.scheduleJob(job, trigger);

Scheduler的主要函數(shù)：

start():啟動(dòng)

standby():掛起

shutdown()：關(guān)閉

shutdown(true)表示等待所有正在執(zhí)行的job執(zhí)行完畢后，在關(guān)閉scheduler

shutdown(false)即shutdown()表示直接關(guān)閉scheduler

注意關(guān)閉之后，scheduler不能從新開啟，會(huì)拋出異常

Trigger用于觸發(fā)Job的執(zhí)行。當(dāng)你準(zhǔn)備調(diào)度一個(gè)job時(shí)，你創(chuàng)建一個(gè)Trigger的實(shí)例，然后設(shè)置調(diào)度相關(guān)的屬性。Trigger也有一個(gè)相關(guān)聯(lián)的JobDataMap，用于給Job傳遞一些觸發(fā)相關(guān)的參數(shù)。Quartz自帶了各種不同類型的Trigger，最常用的主要是SimpleTrigger和CronTrigger。

SimpleTrigger – 允許設(shè)置開始時(shí)間，結(jié)束時(shí)間，重復(fù)間隔。主要用于一次性執(zhí)行的Job（只在某個(gè)特定的時(shí)間點(diǎn)執(zhí)行一次），或者Job在特定的時(shí)間點(diǎn)執(zhí)行，重復(fù)執(zhí)行N次，每次執(zhí)行間隔T個(gè)時(shí)間單位。

CronTrigger – 允許UNIX cron表達(dá)式來(lái)指定日期和時(shí)間來(lái)運(yùn)行作業(yè)。在基于日歷的調(diào)度上非常有用，如“每個(gè)星期五的正午”，或者“每月的第十天的上午10:15”等。

SimpleTrigger – 每5秒運(yùn)行

Trigger trigger = TriggerBuilder
    .newTrigger()
    .withIdentity("dummyTriggerName", "group1")
    .withSchedule(
        SimpleScheduleBuilder.simpleSchedule()
        .withIntervalInSeconds(5).repeatForever())
    .build();

CronTrigger – 每5秒運(yùn)行。

Trigger trigger = TriggerBuilder
    .newTrigger()
    .withIdentity("dummyTriggerName", "group1")
    .withSchedule(
        CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
    .build();

JobDetail 定義的是任務(wù)數(shù)據(jù)，而真正的執(zhí)行邏輯是在Job中。

JobDetail對(duì)象是在將job加入scheduler時(shí)，由客戶端程序（你的程序）創(chuàng)建的。它包含job的各種屬性設(shè)置，以及用于存儲(chǔ)job實(shí)例狀態(tài)信息的JobDataMap。

1.下載 jar 包

可以從官方網(wǎng)站或 Maven 中央存儲(chǔ)庫(kù)下載 Quartz 庫(kù)文件；

2.創(chuàng)建一個(gè)作業(yè)

HelloJob.java

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class HelloJob implements Job{

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        // TODO Auto-generated method stub
        System.out.println("Hello Quartz!");
    }
}

3.創(chuàng)建觸發(fā)器，以及通過調(diào)度執(zhí)行作業(yè)

SimpleTrigger.java

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class SimpleTrigger {

    public static void main(String[] args) throws Exception {

        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("dummyJobName", "group1").build();

         // 定義一個(gè)Trigger
        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("dummyTriggerName", "group1")        // 定義 name/group
                .withSchedule(
                        SimpleScheduleBuilder.simpleSchedule()
                                .withIntervalInSeconds(5).repeatForever())
                .build();
        
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

CronTrigger.java

import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class CronTrigger {

    public static void main(String[] args) throws Exception {
        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("dummyJobName", "group").build();

        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("dummyJobName", "group")
                .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
                .build();

        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

輸出的結(jié)果如下：

每隔五分鐘就會(huì)打印出一條 Hello Quartz!

Hello Quartz!
Hello Quartz!
Hello Quartz!

JobExecutionContext

當(dāng) Schedule 調(diào)用一個(gè) Job，就會(huì)將 JobExecutionContext 傳遞給 Job 的 execute() 方法

Job 能通過 JobExecutionContext 對(duì)象訪問到 Quartz 運(yùn)行時(shí)候的環(huán)境以及 Job本身的明細(xì)數(shù)據(jù)

JobDataMap

在進(jìn)行任務(wù)調(diào)度時(shí) JobDataMap存儲(chǔ)在JobExecutionContext中，非常方便獲取

JobDataMap 可以用來(lái)裝載任何可序列化的數(shù)據(jù)對(duì)象，當(dāng)job 實(shí)例對(duì)象被執(zhí)行時(shí)這些參數(shù)對(duì)象會(huì)傳遞給它

JobDataMap實(shí)現(xiàn)了JDK的Map接口，并且添加了一些非常方便的方法用來(lái)存取數(shù)據(jù)基本類型

key

將Job和Trigger注冊(cè)到Scheduler時(shí)，可以為它們?cè)O(shè)置key，配置其身份屬性。

Job和Trigger的key（JobKey和TriggerKey）可以用于將Job和Trigger放到不同的分組（group）里，然后基于分組進(jìn)行操作。

同一個(gè)分組下的Job或Trigger的名稱必須唯一，即一個(gè)Job或Trigger的key由名稱（name）和分組（group）組成。

第一步：創(chuàng)建一個(gè) Job。

在這個(gè)類中，我們通過 JobExecutionContext 來(lái)獲取 JobDataMap、key以及通過自定義傳入的信息。代碼中有備注，仔細(xì)看下就知道了。

HelloJob.java

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.TriggerKey;

public class HelloJob implements Job{

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // TODO Auto-generated method stub
        System.out.println("Hello Quartz!");
        
        // 獲取 JobDetail 的 key 和 group
        JobKey key = context.getJobDetail().getKey();
        System.out.println("JobDetail key name: "+key.getName());
        System.out.println("JobDetail key Group: "+key.getGroup());
        
        // 從 JobExecutionContext 中獲取一個(gè)實(shí)例,  獲取從 jobDetail 傳入的數(shù)據(jù)
        JobDataMap dataMap = context.getJobDetail().getJobDataMap();
        String JobMsg = dataMap.getString("message");
        Float floatMsg = dataMap.getFloat("floatData");
        System.out.println("JobDetial:"+ JobMsg);
        System.out.println("floatMsg:"+ floatMsg);
        
        //獲取 trigger 的 key 和 group
        TriggerKey triggerKey = context.getTrigger().getKey();
        System.out.println("TriggerKey key name: "+triggerKey.getName());
        System.out.println("TriggerKey key Group: "+triggerKey.getGroup());
        
        // 獲取一個(gè) trigger 的 jobDataMap 實(shí)例
        JobDataMap triggerMap = context.getTrigger().getJobDataMap();
        String triggerMsg = dataMap.getString("message");
        System.out.println("triggerMsg:"+ triggerMsg);
    }
}

第二步：測(cè)試類

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class SimpleTrigger {

    public static void main(String[] args) throws Exception {

        JobDetail job = JobBuilder.newJob(HelloJob.class)
                .withIdentity("dummyJobName", "group1")
                .usingJobData("message", "hello myJob1")    //傳入自定義的數(shù)據(jù)
                .usingJobData("floatData", 1.2F)
                .build();

         // 定義一個(gè)Trigger
        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("dummyTriggerName", "group1")        // 定義 name/group
                .usingJobData("message", "hello myTrigger")
                .withSchedule(
                        SimpleScheduleBuilder.simpleSchedule()
                                .withIntervalInSeconds(5).repeatForever())
                .build();
        
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

輸出結(jié)果

Hello Quartz!
JobDetail key name: dummyJobName
JobDetail key Group: group1
JobDetial:hello myJob1
floatMsg:1.2
TriggerKey key name: dummyTriggerName
TriggerKey key Group: group1
triggerMsg:hello myJob1

w3cschool 上的quartz 教程

官方鏈接