小男孩‘自慰网亚洲一区二区,亚洲一级在线播放毛片,亚洲中文字幕av每天更新,黄aⅴ永久免费无码,91成人午夜在线精品,色网站免费在线观看,亚洲欧洲wwwww在线观看

分享

Quartz的基本使用之入門(2.3.0版本)

 wwq圖書世界 2019-08-21

一、Quartz可以用來做什么

Quartz是一個(gè)強(qiáng)大任務(wù)調(diào)度框架,我工作時(shí)候會(huì)在這些情況下使用到quartz框架,當(dāng)然還有很多的應(yīng)用場景,在這里只列舉2個(gè)實(shí)際用到的

  • 餐廳系統(tǒng)會(huì)在每周四晚上的22點(diǎn)自動(dòng)審核并生成報(bào)表
  • 人事系統(tǒng)會(huì)在每天早晨8點(diǎn)給有待辦的人員自動(dòng)發(fā)送Email提醒

二、使用Quartz之前的準(zhǔn)備

1.建立一個(gè)Maven項(xiàng)目

2.引入quartz的依賴  

  使用quartz,我們僅僅需要在maven的pom文件中添加依賴即可。我使用的是現(xiàn)在最新的一個(gè)版本2.3.0,大家可以在maven的倉庫獲取到最新的版本依賴,地址:http:///artifact/org.quartz-scheduler/quartz

   但然也可以使用這個(gè)2.3.0的依賴,下面的例子都是使用此依賴并實(shí)現(xiàn)了效果。

<!-- https:///artifact/org.quartz-scheduler/quartz -->
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.3.0</version>
</dependency>

三、編寫第一個(gè)Quartz任務(wù)案例 - 每隔2秒鐘打印一次HelloQuartz

先實(shí)現(xiàn)一下這個(gè)基本的Quartz的任務(wù)再來介紹一下Quartz的3個(gè)重要組成,JobDetail,Trigger,Scheduler

1.創(chuàng)建一個(gè)類 HelloJob.java,這個(gè)類是編寫我們的具體要實(shí)現(xiàn)任務(wù)(打印Hello Quartz)

復(fù)制代碼
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

import java.text.SimpleDateFormat;
import java.util.Date;

public
class HelloJob implements Job{   public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { //打印當(dāng)前的執(zhí)行時(shí)間 例如 2017-11-23 00:00:00 Date date = new Date(); SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); System.out.println("現(xiàn)在的時(shí)間是:"+ sf.format(date)); //具體的業(yè)務(wù)邏輯 System.out.println("Hello Quartz"); } }
復(fù)制代碼

2.創(chuàng)建一個(gè)類HelloScheduler.java,這個(gè)是具體觸發(fā)我們的任務(wù)

復(fù)制代碼
public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //創(chuàng)建一個(gè)jobDetail的實(shí)例,將該實(shí)例與HelloJob Class綁定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob").build();
        //創(chuàng)建一個(gè)Trigger觸發(fā)器的實(shí)例,定義該job立即執(zhí)行,并且每2秒執(zhí)行一次,一直執(zhí)行
        SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        //創(chuàng)建schedule實(shí)例
        StdSchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        scheduler.start();
        scheduler.scheduleJob(jobDetail,trigger);

    }
}
復(fù)制代碼

3.執(zhí)行main方法,Run 'HelloScheduler.main()',可以看見如下效果,表明任務(wù)執(zhí)行成功了

4.一句話看懂quartz

   1、創(chuàng)建調(diào)度工廠();      //工廠模式

   2、根據(jù)工廠取得調(diào)度器實(shí)例();    //工廠模式
   3、Builder模式構(gòu)建子組件<Job,Trigger>    // builder模式, 如JobBuilder、TriggerBuilder、DateBuilder
   4、通過調(diào)度器組裝子組件   調(diào)度器.組裝<子組件1,子組件2...>    //工廠模式
   5、調(diào)度器.start();   //工廠模式

 四、第二個(gè)案例 -  每日的9點(diǎn)40分觸發(fā)任務(wù)打印HelloQuartz

 與上一個(gè)的簡單案例的區(qū)別在于,SimpleTrigger/CronTrigger. 簡單的定時(shí)任務(wù),可以采用SimpleTrigger,復(fù)雜的任務(wù)一般采用CronTrigger.cronTrigger不僅可以設(shè)定單的觸發(fā)時(shí)間表,更可以設(shè)定非常復(fù)雜的觸發(fā)時(shí)間表。 CronTrigger 是基于 Unix類似于 cron 表達(dá)式,如果對(duì)cron表達(dá)式比較熟悉,那么學(xué)習(xí)起來經(jīng)非常簡單. 即使對(duì)cron表達(dá)式不熟悉,花一會(huì)兒的功夫也可以學(xué)會(huì)。(在工作中我們直接使用網(wǎng)上的在線生成表達(dá)式即可又快又準(zhǔn)確)生成地址:http://cron./

先上代碼,然后介紹一下cron表達(dá)式生成規(guī)則。

1.編寫任務(wù)類 HelloJob.java,具體情況編寫具體內(nèi)容,如生成報(bào)表,發(fā)送郵件。。

復(fù)制代碼
public class HelloJob implements Job{
 public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //打印當(dāng)前的執(zhí)行時(shí)間 例如 2017-11-22 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("現(xiàn)在的時(shí)間是:"+ sf.format(date));
        //具體的業(yè)務(wù)邏輯
        System.out.println("開始生成任務(wù)報(bào)表 或 開始發(fā)送郵件");
    }
}
復(fù)制代碼

 2.編寫任務(wù)觸發(fā)類  CronScheduler.java

復(fù)制代碼
public class CronScheduler {
     public static void main(String[] args) throws SchedulerException, InterruptedException {
        //jobDetail
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("cronJob").build();
        //cronTrigger
        //每日的9點(diǎn)40觸發(fā)任務(wù)
        CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("cronTrigger").withSchedule(CronScheduleBuilder.cronSchedule("0 40 9 * * ? ")).build();
        //1.每日10點(diǎn)15分觸發(fā)      0 15 10 ?* *
        //2.每天下午的2點(diǎn)到2點(diǎn)59分(正點(diǎn)開始,隔5分觸發(fā))       0 0/5 14 * * ?
        //3.從周一到周五每天的上午10點(diǎn)15觸發(fā)      0 15 10 ? MON-FRI
        //4.每月的第三周的星期五上午10點(diǎn)15觸發(fā)     0 15 10 ? * 6#3
        //5.2016到2017年每月最后一周的星期五的10點(diǎn)15分觸發(fā)   0 15 10 ? * 6L 2016-2017
        //Scheduler實(shí)例
        StdSchedulerFactory stdSchedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = stdSchedulerFactory.getScheduler();
        scheduler.start();
        scheduler.scheduleJob(jobDetail,cronTrigger);
    }
}
復(fù)制代碼

3.觸發(fā)的效果

 五、cron表達(dá)式編寫規(guī)則

 1. Quartz Cron 表達(dá)式支持7個(gè)域 ,分別是秒/分/時(shí)/日/月/周/年.期中年是非必須項(xiàng).如下圖

名稱是否必須允許值特殊字符
0-59 , - * /
0-59 , - * /
時(shí) 0-23 , - * /
1-31 , - * ? / L W C
1-12 或 JAN-DEC , - * /
1-7 或 SUN-SAT , - * ? / L C #
空 或 1970-2099 , - * /

注意在cron表達(dá)式中不區(qū)分大小寫.

星號(hào)(*):可用在所有字段中,表示對(duì)應(yīng)時(shí)間域的每一個(gè)時(shí)刻,例如, 在分鐘字段時(shí),表示“每分鐘”;

問號(hào)(?):該字符只在日期和星期字段中使用,它通常指定為“無意義的值”,相當(dāng)于點(diǎn)位符;

減號(hào)(-):表達(dá)一個(gè)范圍,如在小時(shí)字段中使用“10-12”,則表示從10到12點(diǎn),即10,11,12;

逗號(hào)(,):表達(dá)一個(gè)列表值,如在星期字段中使用“MON,WED,FRI”,則表示星期一,星期三和星期五;

斜杠(/):x/y表達(dá)一個(gè)等步長序列,x為起始值,y為增量步長值。如在分鐘字段中使用0/15,則表示為0,15,30和45秒,而5/15在分鐘字段中表示5,20,35,50,你也可以使用*/y,它等同于0/y;

L:該字符只在日期和星期字段中使用,代表“Last”的意思,但它在兩個(gè)字段中意思不同。L在日期字段中,表示這個(gè)月份的最后一天,如一月的31號(hào),非閏年二月的28號(hào);如果L用在星期中,則表示星期六,等同于7。但是,如果L出現(xiàn)在星期字段里,而且在前面有一個(gè)數(shù)值X,則表示“這個(gè)月的最后X天”,例如,6L表示該月的最后星期五;

W:該字符只能出現(xiàn)在日期字段里,是對(duì)前導(dǎo)日期的修飾,表示離該日期最近的工作日。例如15W表示離該月15號(hào)最近的工作日,如果該月15號(hào)是星期六,則匹配14號(hào)星期五;如果15日是星期日,則匹配16號(hào)星期一;如果15號(hào)是星期二,那結(jié)果就是15號(hào)星期二。但必須注意關(guān)聯(lián)的匹配日期不能夠跨月,如你指定1W,如果1號(hào)是星期六,結(jié)果匹配的是3號(hào)星期一,而非上個(gè)月最后的那天。W字符串只能指定單一日期,而不能指定日期范圍;

LW組合:在日期字段可以組合使用LW,它的意思是當(dāng)月的最后一個(gè)工作日;

井號(hào)(#):該字符只能在星期字段中使用,表示當(dāng)月某個(gè)工作日。如6#3表示當(dāng)月的第三個(gè)星期五(6表示星期五,#3表示當(dāng)前的第三個(gè)),而4#5表示當(dāng)月的第五個(gè)星期三,假設(shè)當(dāng)月沒有第五個(gè)星期三,忽略不觸發(fā);

C:該字符只在日期和星期字段中使用,代表“Calendar”的意思。它的意思是計(jì)劃所關(guān)聯(lián)的日期,如果日期沒有被關(guān)聯(lián),則相當(dāng)于日歷中所有日期。例如5C在日期字段中就相當(dāng)于日歷5日以后的第一天。1C在星期字段中相當(dāng)于星期日后的第一天。

Cron表達(dá)式對(duì)特殊字符的大小寫不敏感,對(duì)代表星期的縮寫英文大小寫也不敏感。

2.官方的一些案例

表示式說明
0 0 12 * * ? 每天12點(diǎn)運(yùn)行
0 15 10 ? * * 每天10:15運(yùn)行
0 15 10 * * ? 每天10:15運(yùn)行
0 15 10 * * ? * 每天10:15運(yùn)行
0 15 10 * * ? 2008 在2008年的每天10:15運(yùn)行
0 * 14 * * ? 每天14點(diǎn)到15點(diǎn)之間每分鐘運(yùn)行一次,開始于14:00,結(jié)束于14:59。
0 0/5 14 * * ? 每天14點(diǎn)到15點(diǎn)每5分鐘運(yùn)行一次,開始于14:00,結(jié)束于14:55。
0 0/5 14,18 * * ? 每天14點(diǎn)到15點(diǎn)每5分鐘運(yùn)行一次,此外每天18點(diǎn)到19點(diǎn)每5鐘也運(yùn)行一次。
0 0-5 14 * * ? 每天14:00點(diǎn)到14:05,每分鐘運(yùn)行一次。
0 10,44 14 ? 3 WED 3月每周三的14:10分到14:44,每分鐘運(yùn)行一次。
0 15 10 ? * MON-FRI 每周一,二,三,四,五的10:15分運(yùn)行。
0 15 10 15 * ? 每月15日10:15分運(yùn)行。
0 15 10 L * ? 每月最后一天10:15分運(yùn)行。
0 15 10 ? * 6L 每月最后一個(gè)星期五10:15分運(yùn)行。
0 15 10 ? * 6L 2007-2009 在2007,2008,2009年每個(gè)月的最后一個(gè)星期五的10:15分運(yùn)行。
0 15 10 ? * 6#3 每月第三個(gè)星期五的10:15分運(yùn)行。

以上就可以實(shí)現(xiàn)大部分的業(yè)務(wù)的需求了,以下是對(duì)Quartz的API的一些了解

----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

六、Quartz的三個(gè)基本要素

  Quartz對(duì)任務(wù)調(diào)度的領(lǐng)域問題進(jìn)行了高度的抽象,提出了調(diào)度器、任務(wù)和觸發(fā)器這3個(gè)核心的概念,并在org.quartz通過接口和類對(duì)重要的這些核心概念進(jìn)行描述:

  ●Job:是一個(gè)接口,只有一個(gè)方法void execute(JobExecutionContext context),開發(fā)者實(shí)現(xiàn)該接口定義運(yùn)行任務(wù),JobExecutionContext類提供了調(diào)度上下文的各種信息。Job運(yùn)行時(shí)的信息保存在JobDataMap實(shí)例中;

  ●JobDetail:Quartz在每次執(zhí)行Job時(shí),都重新創(chuàng)建一個(gè)Job實(shí)例,所以它不直接接受一個(gè)Job的實(shí)例,相反它接收一個(gè)Job實(shí)現(xiàn)類,以便運(yùn)行時(shí)通過newInstance()的反射機(jī)制實(shí)例化Job。因此需要通過一個(gè)類來描述Job的實(shí)現(xiàn)類及其它相關(guān)的靜態(tài)信息,如Job名字、描述、關(guān)聯(lián)監(jiān)聽器等信息,JobDetail承擔(dān)了這一角色。

  通過該類的構(gòu)造函數(shù)可以更具體地了解它的功用:JobDetail(java.lang.String name, java.lang.String group, java.lang.Class jobClass),該構(gòu)造函數(shù)要求指定Job的實(shí)現(xiàn)類,以及任務(wù)在Scheduler中的組名和Job名稱;

  ●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í)行等;

  ●Calendar:org.quartz.Calendar和java.util.Calendar不同,它是一些日歷特定時(shí)間點(diǎ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)排除。針對(duì)不同時(shí)間段類型,Quartz在org.quartz.impl.calendar包下提供了若干個(gè)Calendar的實(shí)現(xiàn)類,如AnnualCalendar、MonthlyCalendar、WeeklyCalendar分別針對(duì)每年、每月和每周進(jìn)行定義;

  ●Scheduler:代表一個(gè)Quartz的獨(dú)立運(yùn)行容器,Trigger和JobDetail可以注冊到Scheduler中,兩者在Scheduler中擁有各自的組及名稱,組及名稱是Scheduler查找定位容器中某一對(duì)象的依據(jù),Trigger的組及名稱必須唯一,JobDetail的組和名稱也必須唯一(但可以和Trigger的組和名稱相同,因?yàn)樗鼈兪遣煌愋偷模?。Scheduler定義了多個(gè)接口方法,允許外部通過組及名稱訪問和控制容器中Trigger和JobDetail。

  Scheduler可以將Trigger綁定到某一JobDetail中,這樣當(dāng)Trigger觸發(fā)時(shí),對(duì)應(yīng)的Job就被執(zhí)行。一個(gè)Job可以對(duì)應(yīng)多個(gè)Trigger,但一個(gè)Trigger只能對(duì)應(yīng)一個(gè)Job。可以通過SchedulerFactory創(chuàng)建一個(gè)Scheduler實(shí)例。Scheduler擁有一個(gè)SchedulerContext,它類似于ServletContext,保存著Scheduler上下文信息,Job和Trigger都可以訪問SchedulerContext內(nèi)的信息。SchedulerContext內(nèi)部通過一個(gè)Map,以鍵值對(duì)的方式維護(hù)這些上下文數(shù)據(jù),SchedulerContext為保存和獲取數(shù)據(jù)提供了多個(gè)put()和getXxx()的方法??梢酝ㄟ^Scheduler# getContext()獲取對(duì)應(yīng)的SchedulerContext實(shí)例;

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

  Job有一個(gè)StatefulJob子接口,代表有狀態(tài)的任務(wù),該接口是一個(gè)沒有方法的標(biāo)簽接口,其目的是讓Quartz知道任務(wù)的類型,以便采用不同的執(zhí)行方案。無狀態(tài)任務(wù)在執(zhí)行時(shí)擁有自己的JobDataMap拷貝,對(duì)JobDataMap的更改不會(huì)影響下次的執(zhí)行。而有狀態(tài)任務(wù)共享共享同一個(gè)JobDataMap實(shí)例,每次任務(wù)執(zhí)行對(duì)JobDataMap所做的更改會(huì)保存下來,后面的執(zhí)行可以看到這個(gè)更改,也即每次執(zhí)行任務(wù)后都會(huì)對(duì)后面的執(zhí)行發(fā)生影響。

  正因?yàn)檫@個(gè)原因,無狀態(tài)的Job可以并發(fā)執(zhí)行,而有狀態(tài)的StatefulJob不能并發(fā)執(zhí)行,這意味著如果前次的StatefulJob還沒有執(zhí)行完畢,下一次的任務(wù)將阻塞等待,直到前次任務(wù)執(zhí)行完畢。有狀態(tài)任務(wù)比無狀態(tài)任務(wù)需要考慮更多的因素,程序往往擁有更高的復(fù)雜度,因此除非必要,應(yīng)該盡量使用無狀態(tài)的Job。

  如果Quartz使用了數(shù)據(jù)庫持久化任務(wù)調(diào)度信息,無狀態(tài)的JobDataMap僅會(huì)在Scheduler注冊任務(wù)時(shí)保持一次,而有狀態(tài)任務(wù)對(duì)應(yīng)的JobDataMap在每次執(zhí)行任務(wù)后都會(huì)進(jìn)行保存。

  Trigger自身也可以擁有一個(gè)JobDataMap,其關(guān)聯(lián)的Job可以通過JobExecutionContext#getTrigger().getJobDataMap()獲取Trigger中的JobDataMap。不管是有狀態(tài)還是無狀態(tài)的任務(wù),在任務(wù)執(zhí)行期間對(duì)Trigger的JobDataMap所做的更改都不會(huì)進(jìn)行持久,也即不會(huì)對(duì)下次的執(zhí)行產(chǎn)生影響。

  Quartz擁有完善的事件和監(jiān)聽體系,大部分組件都擁有事件,如任務(wù)執(zhí)行前事件、任務(wù)執(zhí)行后事件、觸發(fā)器觸發(fā)前事件、觸發(fā)后事件、調(diào)度器開始事件、關(guān)閉事件等等,可以注冊相應(yīng)的監(jiān)聽器處理感興趣的事件。

七、Quartz的3大API之一  -  Job 

1.JobDetail & Job和JobDataMap

  JobDetail是任務(wù)的定義,而Job是任務(wù)的執(zhí)行邏輯。在JobDetail里會(huì)引用一個(gè)Job Class定義。

  每一個(gè)JobDetail都會(huì)有一個(gè)JobDataMap。JobDataMap本質(zhì)就是一個(gè)Map的擴(kuò)展類,只是提供了一些更便捷的方法,比如getString()之類的。

還是老樣子,編寫兩個(gè)類來看效果。

2.編寫觸發(fā)類  CronScheduler.java

復(fù)制代碼
public class HelloScheduler {
    public static void main(String[] args) throws SchedulerException {
        //1.創(chuàng)建一個(gè)jobDetail的實(shí)例,將該實(shí)例與HelloJob Class綁定
        JobDetail jobDetail = JobBuilder
                .newJob(HelloJob.class) //定義Job類為HelloJob類,真正的執(zhí)行邏輯所在
                .withIdentity("myJob", "group1") //定義name 和 group
                .usingJobData("message","hello myJob1") //加入屬性到j(luò)obDataMap
                .usingJobData("FloatJobValue",8.88f) //加入屬性到j(luò)obDataMap
                .build();

        //2.創(chuàng)建一個(gè)Trigger觸發(fā)器的實(shí)例,定義該job立即執(zhí)行,并且每2秒執(zhí)行一次,一直執(zhí)行
        SimpleTrigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("myTrigger", "group1")
                .startNow()
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever())
                .build();
        //3.創(chuàng)建schedule實(shí)例
        StdSchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        scheduler.start(); //啟動(dòng)
        scheduler.scheduleJob(jobDetail,trigger); // jobDetail和trigger加入調(diào)度

    }
}
復(fù)制代碼

3.編寫具體任務(wù)類HelloJob.java,并打印值

復(fù)制代碼
public class HelloJob implements Job{
  public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //打印當(dāng)前的執(zhí)行時(shí)間 例如 2017-11-22 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("現(xiàn)在的時(shí)間是:"+ sf.format(date));
        //具體的業(yè)務(wù)邏輯
        System.out.println("開始生成任務(wù)報(bào)表 或 開始發(fā)送郵件....");
        JobKey key = jobExecutionContext.getJobDetail().getKey();
        System.out.println("jobDetail 的name : "+key.getName());     //打印jobDetail 的name
        System.out.println("jobDetail 的group : "+key.getGroup());    //打印jobDetail 的group
        JobDataMap jobDetailDataMap = jobExecutionContext.getJobDetail().getJobDataMap();
        String message = jobDetailDataMap.getString("message"); //
        float floatJobValue = jobDetailDataMap.getFloat("FloatJobValue");
        System.out.println("jobDataMap定義的message的值 : "+message );  //打印jobDataMap定義的message的值 
        System.out.println("jobDataMap定義的floatJobValue的值 : "+floatJobValue );   //jobDataMap定義的floatJobValue的值
    }
}
復(fù)制代碼

4.實(shí)現(xiàn)的效果

5.通過get、Set方式獲取dataMap中的值 (修改一下HelloJob.java)即可

復(fù)制代碼
public class HelloJob implements Job{

    //這里是第二種獲取jobDataMap中的值的方法
    private String message;
    private Float floatJobValue;
    private Double doubleTriggerValue;

    public String getMessage() {
        return message;
    }

    public void setMessage(String message) {
        this.message = message;
    }

    public Float getFloatJobValue() {
        return floatJobValue;
    }

    public void setFloatJobValue(Float floatJobValue) {
        this.floatJobValue = floatJobValue;
    }

    public Double getDoubleTriggerValue() {
        return doubleTriggerValue;
    }

    public void setDoubleTriggerValue(Double doubleTriggerValue) {
        this.doubleTriggerValue = doubleTriggerValue;
    }

    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //打印當(dāng)前的執(zhí)行時(shí)間 例如 2017-11-22 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("現(xiàn)在的時(shí)間是:"+ sf.format(date));
        System.out.println("jobDataMap定義的message的值 : "+message );  //打印jobDataMap定義的message的值
        System.out.println("jobDataMap定義的floatJobValue的值 : "+floatJobValue );   //jobDataMap定義的floatJobValue的值
   }
}
復(fù)制代碼

6.效果如下

 八、Quartz的3大API之一  - Tigger

1.startTime和endTime

  有時(shí)候我們希望一個(gè)定時(shí)任務(wù)在一定的時(shí)間內(nèi)是每天執(zhí)行,比如2017年11月24日到2017年12月15日之間執(zhí)行,這時(shí)候我們就要使用startTime和endTime來限定事件范圍了。例子中我們把時(shí)間規(guī)定在幾秒鐘之內(nèi)運(yùn)行,方便查看效果。

1.1編寫Scheduler類SecondScheduler.java

復(fù)制代碼
public class SecondScheduler {
    public static void main(String[] args) throws SchedulerException {
        //創(chuàng)建一個(gè)JobDetail的實(shí)例,將該實(shí)例與HelloJob綁定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("zhlJob").build();
        //開始時(shí)間 3秒鐘之后  (具體時(shí)間按實(shí)際業(yè)務(wù)編寫)
        Date sData = new Date();
        sData.setTime(sData.getTime()+3000); 
        //結(jié)束時(shí)間 6秒鐘之后 (具體時(shí)間按實(shí)際業(yè)務(wù)編寫)
        Date eData = new Date();
        eData.setTime(eData.getTime()+6000);
        //創(chuàng)建一個(gè)Trigger實(shí)例,定義該job3秒之后執(zhí)行,在6秒之后結(jié)束
        SimpleTrigger zhlTrigger = TriggerBuilder.newTrigger().withIdentity("zhlTrigger")
                .startAt(sData) //設(shè)定開始時(shí)間
                .endAt(eData)   //設(shè)定結(jié)束時(shí)間
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()) //每兩秒打印一次
                .build();
        //創(chuàng)建Scheduler實(shí)例
        StdSchedulerFactory stdSchedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = stdSchedulerFactory.getScheduler();
        scheduler.start();
        scheduler.scheduleJob(jobDetail,zhlTrigger);
    }
}
復(fù)制代碼

1.2編寫job類

復(fù)制代碼
public class HelloJob implements Job{public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //打印當(dāng)前的執(zhí)行時(shí)間 例如 2017-11-22 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("現(xiàn)在的時(shí)間是:"+ sf.format(date));
        //具體的業(yè)務(wù)邏輯
        System.out.println("具體執(zhí)行的業(yè)務(wù)...");
        JobKey key = jobExecutionContext.getJobDetail().getKey();
        Trigger trigger = jobExecutionContext.getTrigger();
        System.out.println("開始的時(shí)間: "+sf.format(trigger.getStartTime())); //打印開始時(shí)間
        System.out.println("結(jié)束的事件: "+sf.format(trigger.getEndTime())); //打印結(jié)束時(shí)間
    }
}
復(fù)制代碼

1.3打印效果

2.BaseCalndar

此calendar不是java.util.Calendar,calendar是為了補(bǔ)充Trigger的時(shí)間,可以拍除了或加入一下特定的時(shí)間。Quartz 的 Calender 專門用于屏閉一個(gè)時(shí)間區(qū)間,使 Trigger 在這個(gè)區(qū)間中不被觸發(fā)。   

2.1Quartz 包含了你的應(yīng)用可用的許多的 Calender 類型

  1. AnnualCalendar:排除每一年中指定的一天或者多少天 ,精度是天
  2. CronCalendar:使用表達(dá)式排除某些時(shí)間段不執(zhí)行,精度取決于Cron表達(dá)式,最大精度到秒
  3. DailyCalendar:指定的時(shí)間范圍內(nèi)的每一天不執(zhí)行,指定每天的時(shí)間段,格式是HH:MM[:SS[:mmm]]。也就是最大精度可以到毫秒。
  4. HolidayCalendar:排除節(jié)假日,精度到天
  5. MonthlyCalendar:排除月份中的數(shù)天,可選值為1-31。精度是天
  6. WeeklyCalendar:排除星期中的一天或多天,可選值比如為java.util.Calendar.SUNDAY,精度是天。

下面以AnnualCalendar舉例,來實(shí)現(xiàn)某一天不執(zhí)行程序。

2.2編寫Scheduler類CalendarSchedule.java

復(fù)制代碼
public class CalendarSchedule {
    public static void main(String[] args) throws SchedulerException {
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        //創(chuàng)建一個(gè)JobDetail的實(shí)例,將該實(shí)例與HelloJob綁定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("zhlJob").build();
        AnnualCalendar holidays = new AnnualCalendar();
        GregorianCalendar nationalDay = new GregorianCalendar(2017, 10, 27);  // 排除今天的時(shí)間2017年11月27日(月份是從0~11的)
        
        holidays.setDayExcluded(nationalDay,true); //排除的日期,如果為false則為包含*/
        //創(chuàng)建Scheduler實(shí)例
        StdSchedulerFactory stdSchedulerFactory = new StdSchedulerFactory();
        Scheduler scheduler = stdSchedulerFactory.getScheduler();
        //向Scheduler注冊日歷
        scheduler.addCalendar("holidays",holidays,false,false);
        Trigger simpleTrigger = TriggerBuilder.newTrigger()
                .withIdentity("zhlTrigger")
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(1).repeatForever()) //每一秒執(zhí)行一次job
                .modifiedByCalendar("holidays")   //將我們設(shè)置好的Calander與trigger綁定
                .build();
        //讓trigger應(yīng)用指定的日歷規(guī)則
        //scheduler.scheduleJob(jobDetail,simpleTrigger);
        System.out.println("現(xiàn)在的時(shí)間 :"+sf.format(new Date()));
        System.out.println("最近的一次執(zhí)行時(shí)間 :"+sf.format(scheduler.scheduleJob(jobDetail,simpleTrigger))); //scheduler與jobDetail、trigger綁定,并打印出最近一次執(zhí)行的事件
        scheduler.start();
    }
}
復(fù)制代碼

2.3編寫job類 ,仍然使用HelloJob就可以

復(fù)制代碼
public class HelloJob implements Job{public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        //打印當(dāng)前的執(zhí)行時(shí)間 例如 2017-11-22 00:00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("現(xiàn)在的時(shí)間是:"+ sf.format(date));
        //具體的業(yè)務(wù)邏輯
        System.out.println("具體執(zhí)行的業(yè)務(wù)...");
        Trigger trigger = jobExecutionContext.getTrigger();
        System.out.println("開始的時(shí)間: "+sf.format(trigger.getStartTime())); //打印開始時(shí)間
        System.out.println("結(jié)束的事件: "+sf.format(trigger.getEndTime())); //打印結(jié)束時(shí)間
}
復(fù)制代碼

2.4執(zhí)行后的效果

可以發(fā)現(xiàn),我將程序設(shè)置為2017年11月27日也就是今天不執(zhí)行,并打印出了程序最近的一次的執(zhí)行時(shí)間,是明天。由此可見,排除時(shí)間成功。

3.Trigger的實(shí)現(xiàn)類

SimpleTrigger和CronTrigger之前已經(jīng)介紹過了,接下來介紹一下CalendarIntervalTrigger 和 DailyTimeIntervalTrigger

 1.CalendarIntervalTrigger

CalendarIntervalTrigger是一個(gè)具體的Trigger,用來觸發(fā)基于定時(shí)重復(fù)的JobDetail。

Trigger將會(huì)每隔N個(gè)calendar在trigger中定義的時(shí)間單元觸發(fā)一次。這個(gè)trigger不適合使用SimpleTrigger完成(例如由于每一個(gè)月的時(shí)間不是固定的描述),也不適用于CronTrigger(例如每5個(gè)月)。

相較于SimpleTrigger有兩個(gè)優(yōu)勢:1、更方便,比如每隔1小時(shí)執(zhí)行,你不用自己去計(jì)算1小時(shí)等于多少毫秒。 2、支持不是固定長度的間隔,比如間隔為月和年。但劣勢是精度只能到秒。

它適合的任務(wù)類似于:9:00 開始執(zhí)行,并且以后每周 9:00 執(zhí)行一次

它的屬性有:

  • interval 執(zhí)行間隔

  • intervalUnit 執(zhí)行間隔的單位(秒,分鐘,小時(shí),天,月,年,星期)

例子:

復(fù)制代碼
CalendarIntervalScheduleBuilder
     .calendarIntervalSchedule()
     .withIntervalInDays(1)  //每天執(zhí)行一次
   //.withIntervalInHours(1)
   //.withIntervalInMinutes(1)
   //.withIntervalInMonths(1)
   //.withIntervalInSeconds(1)
   //.withIntervalInWeeks(1)
   //.withIntervalInHours(1)
     .build()
復(fù)制代碼

2.DailyTimeIntervalTrigger

指定每天的某個(gè)時(shí)間段內(nèi),以一定的時(shí)間間隔執(zhí)行任務(wù)。并且它可以支持指定星期。

它適合的任務(wù)類似于:指定每天9:00 至 18:00 ,每隔70秒執(zhí)行一次,并且只要周一至周五執(zhí)行。

它的屬性有:

  • startTimeOfDay 每天開始時(shí)間
  • endTimeOfDay 每天結(jié)束時(shí)間
  • daysOfWeek 需要執(zhí)行的星期
  • interval 執(zhí)行間隔
  • intervalUnit 執(zhí)行間隔的單位(秒,分鐘,小時(shí),天,月,年,星期)
  • repeatCount 重復(fù)次數(shù)

2.1編寫Scheduler類

復(fù)制代碼
 public static void main(String[] args) throws SchedulerException {
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        //1.創(chuàng)建一個(gè)jobDetail的實(shí)例,將該實(shí)例與HelloJob Class綁定
        JobDetail jobDetail = JobBuilder
                .newJob(HelloJob.class)
                .withIdentity("myJob", "group1") //定義name 和 group
                .build();

        //2.創(chuàng)建一個(gè)Trigger觸發(fā)器的實(shí)例
        Trigger simpleTrigger = TriggerBuilder.newTrigger()
                .withIdentity("zhlTrigger")
                .withSchedule(
                        DailyTimeIntervalScheduleBuilder.dailyTimeIntervalSchedule()
                                .startingDailyAt(TimeOfDay.hourAndMinuteOfDay(8, 0)) //每天8:00開始
                                .endingDailyAt(TimeOfDay.hourAndMinuteOfDay(17, 0)) //17:00 結(jié)束
                                .onDaysOfTheWeek(MONDAY,TUESDAY,WEDNESDAY,THURSDAY,FRIDAY) //周一至周五執(zhí)行
                                .withIntervalInHours(1) //每間隔1小時(shí)執(zhí)行一次
                                .withRepeatCount(100) //最多重復(fù)100次(實(shí)際執(zhí)行100+1次)
                )
                .modifiedByCalendar("holidays")   //將我們設(shè)置好的Calander與trigger綁定
                .build();

        //3.創(chuàng)建schedule實(shí)例
        StdSchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        System.out.println("現(xiàn)在的時(shí)間 :"+sf.format(new Date()));
        System.out.println();
        System.out.println("最近的一次執(zhí)行時(shí)間 :"+sf.format(scheduler.scheduleJob(jobDetail,simpleTrigger))); //scheduler與jobDetail、trigger綁定,并打印出最近一次執(zhí)行的事件
        scheduler.start();
    }
復(fù)制代碼

2.2打印的效果

九、總結(jié):

雖然介紹了Quartz一些基本的用法,但是Quartz的強(qiáng)大不止這些,包括集成Spring,與Spring Boot的集成,quartz的listener,quartz的持久化,集群,插件等等,之后會(huì)陸續(xù)的介紹。最后,quartz是一個(gè)基于java的非常成熟的任務(wù)調(diào)度框架,適合于任何常規(guī)的使用,以及個(gè)性化的開發(fā)使用, 其次通過數(shù)據(jù)庫的持久化,可以選擇實(shí)現(xiàn)集群,大大增加了任務(wù)調(diào)度的可靠性,值得每個(gè)程序人借鑒使用。 

    本站是提供個(gè)人知識(shí)管理的網(wǎng)絡(luò)存儲(chǔ)空間,所有內(nèi)容均由用戶發(fā)布,不代表本站觀點(diǎn)。請(qǐng)注意甄別內(nèi)容中的聯(lián)系方式、誘導(dǎo)購買等信息,謹(jǐn)防詐騙。如發(fā)現(xiàn)有害或侵權(quán)內(nèi)容,請(qǐng)點(diǎn)擊一鍵舉報(bào)。
    轉(zhuǎn)藏 分享 獻(xiàn)花(0

    0條評(píng)論

    發(fā)表

    請(qǐng)遵守用戶 評(píng)論公約

    類似文章 更多