定時(shí)任務(wù)，無論是互聯(lián)網(wǎng)行業(yè)還是傳統(tǒng)軟件行業(yè)都是不可少的。今天介紹的Quartz就是一款非常優(yōu)秀的企業(yè)任務(wù)調(diào)度框架。

Quartz簡(jiǎn)介

Quartz是OpenSymphony開源組織在Job scheduling領(lǐng)域的又一開源項(xiàng)目，它可以和J2EE或J2SE程序結(jié)合使用也可以單獨(dú)使用。小到獨(dú)立的應(yīng)用，大到電子商業(yè)系統(tǒng)，Quartz都能夠創(chuàng)建執(zhí)行成百上千甚至上萬的任務(wù)。簡(jiǎn)而言之就是Quartz是基于Java實(shí)現(xiàn)的任務(wù)調(diào)度框架，可以執(zhí)行你想執(zhí)行的任何任務(wù)。

Quartz體系結(jié)構(gòu)

Job
Job就是你想要實(shí)現(xiàn)的任務(wù)類，每一個(gè)Job必須實(shí)現(xiàn)org.quartz.job接口，且只需實(shí)現(xiàn)接口定義的execute方法。

JobDetail
JobDetail為Job實(shí)例提供了許多設(shè)置屬性以及JobDataMap成員變量屬性，它用來存儲(chǔ)特定Job實(shí)例的狀態(tài)信息。常見屬性name、group、jobClass、jobDataMap等

Trigger
觸發(fā)器，Trigger就是你執(zhí)行任務(wù)的觸發(fā)器，定時(shí)去觸發(fā)你想要執(zhí)行的任務(wù)。Trigger主要分為SimpleTrigger和CronTrigger兩種。

Scheduler
調(diào)度器，將任務(wù)Job和觸發(fā)器Trigger整合起來，負(fù)責(zé)根據(jù)Trigger設(shè)定的時(shí)間執(zhí)行Job。

Quartz體系結(jié)構(gòu)圖

入門例子

需求：每隔5秒鐘控制臺(tái)輸出一下當(dāng)前時(shí)間，并傳遞數(shù)據(jù)給任務(wù)類。

/**
 * 定義要執(zhí)行的任務(wù)類
 *  1.必須實(shí)現(xiàn)Job接口
 *  2.實(shí)現(xiàn)接口中的execute方法, 在該方法中編寫任務(wù)執(zhí)行的業(yè)務(wù)邏輯
 *  3.每次執(zhí)行Job時(shí), 都會(huì)在調(diào)用execute方法前創(chuàng)建一個(gè)新的Job實(shí)例, 調(diào)用完成后, Job實(shí)例就會(huì)被釋放
 */
public class MyJob implements Job {

    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //1.獲取當(dāng)前時(shí)間
        LocalTime localTime = LocalTime.now();
        System.out.println("當(dāng)前時(shí)間: "+localTime);
        //2.獲取trigger傳遞的數(shù)據(jù)
        String name = jobExecutionContext.getTrigger().getJobDataMap().getString("name");
        System.out.println("觸發(fā)器傳遞數(shù)據(jù)："+name);
        //3.獲取jobDetail傳遞的數(shù)據(jù)
        int count = jobExecutionContext.getJobDetail().getJobDataMap().getInt("count");
        System.out.println("JobDetail傳遞數(shù)據(jù)："+count);
    }

}

public static void main(String[] args) throws Exception{
    //1.定義任務(wù)調(diào)度器Scheduler并啟動(dòng)
    Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
    scheduler.start();

    /**
     * 定義定時(shí)任務(wù)的實(shí)例JobDetail
     *    1.通過JobBuilder創(chuàng)建
     *    2.JobDetail為Job提供了很多設(shè)置屬性, 用來存儲(chǔ)Job實(shí)例的狀態(tài)信息
     */
    JobDetail jobDetail = JobBuilder.newJob(MyJob.class)
                                    //設(shè)置任務(wù)名稱和任務(wù)組名
                                    .withIdentity("myjob", "job-group")
                                    //設(shè)置JobDataMap, 可以在MyJob任務(wù)類中獲取到
                                    .usingJobData("count", 10)
                                    .build();

    //3.定義觸發(fā)器Trigger
    Trigger trigger = TriggerBuilder.newTrigger()
                                     //設(shè)置觸發(fā)器名稱和觸發(fā)器組名
                                    .withIdentity("trigger", "trigger-group")
                                    //設(shè)置JobDataMap, 可以在MyJob任務(wù)類中獲取到
                                    .usingJobData("name", "zhangsan")
                                     //每5秒觸發(fā)一次
                                    .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever())
                                    .build();

    //4.通過調(diào)度器關(guān)聯(lián)任務(wù)和觸發(fā)器
    scheduler.scheduleJob(jobDetail, trigger);
}

輸出：
當(dāng)前時(shí)間: 16:56:27.579
觸發(fā)器傳遞數(shù)據(jù)：zhangsan
JobDetail傳遞數(shù)據(jù)：10
當(dāng)前時(shí)間: 16:56:32.509
觸發(fā)器傳遞數(shù)據(jù)：zhangsan
JobDetail傳遞數(shù)據(jù)：10
....

Job

定時(shí)任務(wù)并發(fā)執(zhí)行問題

在任務(wù)類上加@DisallowConcurrentExecution即可解決并發(fā)問題

@DisallowConcurrentExecution
public class MyJob implements Job {
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    }
}

Job狀態(tài)

Job分為有狀態(tài)的Job和無狀態(tài)的Job
有狀態(tài)的Job：多次Job調(diào)用期間可以持有一些狀態(tài)信息，這些信息存儲(chǔ)在JobDataMap中
無狀態(tài)的Job：每次調(diào)用都會(huì)創(chuàng)建一個(gè)新的JobDataMap

# 沒有添加該注解，每次調(diào)用創(chuàng)建一個(gè)新的JobDataMap，不會(huì)累加
# 添加該注解，多次Job調(diào)用可以持有一些狀態(tài)信息
@PersistJobDataAfterExecution
public class HelloJob implements Job {
}

Trigger

Simple觸發(fā)器

簡(jiǎn)單的觸發(fā)器，適合于按照時(shí)間間隔重復(fù)執(zhí)行一項(xiàng)定時(shí)任務(wù)。

常用屬性：開始時(shí)間、結(jié)束時(shí)間、重復(fù)次數(shù)和重復(fù)間隔
重復(fù)次數(shù)：0、正整數(shù)、無限次執(zhí)行
重復(fù)間隔：0(并發(fā)執(zhí)行)、long類型(毫秒級(jí))

Trigger trigger = TriggerBuilder.newTrigger()
                    .withIdentity("trigger-name", "trigger-group")
                    .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                                    .withIntervalInSeconds(5) //時(shí)間間隔：5秒
                                    .withRepeatCount(100)     //重復(fù)執(zhí)行100次
                    )
                    .startAt(DateBuilder.futureDate(10, DateBuilder.IntervalUnit.SECOND)) //10秒后開始執(zhí)行
                    .endAt(DateBuilder.futureDate(50, DateBuilder.IntervalUnit.SECOND))   //50秒后結(jié)束
                    .build();

Cron觸發(fā)器

按日歷方式觸發(fā)任務(wù)。

Cron表達(dá)式：由7個(gè)字表達(dá)式組成的字符串，每個(gè)表達(dá)式都描述了一個(gè)單獨(dú)的日程細(xì)節(jié)，表達(dá)式使用空格分割
1.秒
2.分
3.小時(shí)
4.天(月)
5.月
6.天(周)
7.年

示例
0 0 2,4,20 * * ? 每天上午2點(diǎn)4點(diǎn), 下午20點(diǎn)執(zhí)行
0 0/30 9-20 * * ? 每天早上9點(diǎn)到20點(diǎn)每隔半個(gè)小時(shí)執(zhí)行一次
0 0 12 ？ * WED 每個(gè)周三中午12點(diǎn)
0 0 12 * * ？ 每天中午12點(diǎn)觸發(fā)
0 * 14 * * ？ 每天下午14點(diǎn)到14點(diǎn)59每隔一分鐘執(zhí)行一次

Trigger trigger = TriggerBuilder.newTrigger()
        .withIdentity("trigger1", "group1") //觸發(fā)器名稱，觸發(fā)器組名稱
        //每5秒執(zhí)行一次
        .withSchedule(CronScheduleBuilder.cronSchedule("0/5 * * * * ?"))
        .build();

Trigger的優(yōu)先級(jí)問題

Trigger默認(rèn)優(yōu)先級(jí)為5，只有在多個(gè)Trigger同時(shí)執(zhí)行，并且線程數(shù)小于Trigger數(shù)量時(shí)才會(huì)有用。

    Trigger trigger = TriggerBuilder.newTrigger()
                                    .withIdentity("trigger", "trigger-group")
                                    .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever())
                                    .withPriority(6) //設(shè)置Trigger的優(yōu)先級(jí)為6
                                    .build();

Scheduler調(diào)度器

StdSchedulerFactory

默認(rèn)創(chuàng)建Scheduler的方式，使用一組參數(shù)(java.util.Properties)來創(chuàng)建和初始化Quartz調(diào)度器。
配置參數(shù)我們可以存儲(chǔ)在quartz.properties
調(diào)用getScheduler方法就能創(chuàng)建和初始化調(diào)度器對(duì)象

# 方式1
SchedulerFactory schedulerFactory = new StdSchedulerFactory();
Scheduler scheduler = schedulerFactory.getScheduler();

# 方式2
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

Scheduler

調(diào)度器，將任務(wù)Job和觸發(fā)器Trigger整合起來，負(fù)責(zé)根據(jù)Trigger設(shè)定的時(shí)間執(zhí)行Job。

//將任務(wù)Job和觸發(fā)器Trigger整合起來， 并返回調(diào)度器開始時(shí)間
Date date = scheduler.scheduleJob(jobDetail, trigger);
//開啟任務(wù)調(diào)度
scheduler.start();
//掛起，即暫停操作
scheduler.standby();
//等所以正在執(zhí)行的任務(wù)執(zhí)行完畢，再關(guān)閉
scheduler.shutdown(true); 
//直接關(guān)閉
scheduler.shutdown(false);