Quartz之Job與JobDetail深入解析
Quartz可以用來(lái)做什么?
Quartz是一個(gè)任務(wù)調(diào)度框架。比如你遇到這樣的問題
想每月25號(hào),信用卡自動(dòng)還款
想每年4月1日自己給當(dāng)年暗戀女神發(fā)一封匿名賀卡
想每隔1小時(shí),備份一下自己的愛情動(dòng)作片 學(xué)習(xí)筆記到云盤
這些問題總結(jié)起來(lái)就是:在某一個(gè)有規(guī)律的時(shí)間點(diǎn)干某件事。并且時(shí)間的觸發(fā)的條件可以非常復(fù)雜(比如每月最后一個(gè)工作日的17:50),復(fù)雜到需要一個(gè)專門的框架來(lái)干這個(gè)事。 Quartz就是來(lái)干這樣的事,你給它一個(gè)觸發(fā)條件的定義,它負(fù)責(zé)到了時(shí)間點(diǎn),觸發(fā)相應(yīng)的Job起來(lái)干活。
廢話不多說,代碼杠杠的。。。
public static void main(String[] args) {
try { //創(chuàng)建scheduler
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
//定義一個(gè)Trigger
Trigger trigger =TriggerBuilder.newTrigger().withIdentity("trigger1", "group1") //定義name/group
.startNow()//一旦加入scheduler,立即生效
.withSchedule(SimpleScheduleBuilder.simpleSchedule() //使用SimpleTrigger
.withIntervalInSeconds(1) //每隔一秒執(zhí)行一次
.repeatForever()) //一直執(zhí)行
.build();
//定義一個(gè)JobDetail
JobDetail job =JobBuilder.newJob(HelloQuartz.class) //定義Job類為HelloQuartz類,這是真正的執(zhí)行邏輯所在
.withIdentity("job1", "group1") //定義name/group
.usingJobData("name", "quartz") //定義屬性
.build();
//加入這個(gè)調(diào)度
scheduler.scheduleJob(job, trigger);
//啟動(dòng)之
scheduler.start();
//運(yùn)行一段時(shí)間后關(guān)閉
Thread.sleep(10000);
scheduler.shutdown(true);
} catch (Exception e) {
e.printStackTrace();
}
}
HelloQuartz類
public class HelloQuartz implements Job {
public void execute(JobExecutionContext context) throws JobExecutionException {
JobDetail detail = context.getJobDetail();
String name = detail.getJobDataMap().getString("name");
System.out.println("say hello to " + name + " at " + new Date());
}
}
jar包:

這個(gè)例子很好的覆蓋了Quartz最重要的3個(gè)基本要素:
Scheduler:調(diào)度器。所有的調(diào)度都是由它控制。
Trigger: 定義觸發(fā)的條件。例子中,它的類型是SimpleTrigger,每隔1秒中執(zhí)行一次(什么是SimpleTrigger下面會(huì)有詳述)。
JobDetail & Job: JobDetail 定義的是任務(wù)數(shù)據(jù),而真正的執(zhí)行邏輯是在Job中,例子中是HelloQuartz。 為什么設(shè)計(jì)成JobDetail + Job,不直接使用Job?這是因?yàn)槿蝿?wù)是有可能并發(fā)執(zhí)行,如果Scheduler直接使用Job,就會(huì)存在對(duì)同一個(gè)Job實(shí)例并發(fā)訪問的問題。而JobDetail & Job 方式,sheduler每次執(zhí)行,都會(huì)根據(jù)JobDetail創(chuàng)建一個(gè)新的Job實(shí)例,這樣就可以規(guī)避并發(fā)訪問的問題。
Scheduler
Scheduler就是Quartz的大腦,所有任務(wù)都是由它來(lái)設(shè)施。
Schduelr包含一個(gè)兩個(gè)重要組件: JobStore和ThreadPool。
JobStore是會(huì)來(lái)存儲(chǔ)運(yùn)行時(shí)信息的,包括Trigger,Schduler,JobDetail,業(yè)務(wù)鎖等。它有多種實(shí)現(xiàn)RAMJob(內(nèi)存實(shí)現(xiàn)),JobStoreTX(JDBC,事務(wù)由Quartz管理),JobStoreCMT(JDBC,使用容器事務(wù)),ClusteredJobStore(集群實(shí)現(xiàn))、TerracottaJobStore(什么是Terractta)。
ThreadPool就是線程池,Quartz有自己的線程池實(shí)現(xiàn)。所有任務(wù)的都會(huì)由線程池執(zhí)行。
SchedulerFactory
SchdulerFactory,顧名思義就是來(lái)用創(chuàng)建Schduler了,有兩個(gè)實(shí)現(xiàn):DirectSchedulerFactory和 StdSchdulerFactory。前者可以用來(lái)在代碼里定制你自己的Schduler參數(shù)。后者是直接讀取classpath下的quartz.properties(不存在就都使用默認(rèn)值)配置來(lái)實(shí)例化Schduler。通常來(lái)講,我們使用StdSchdulerFactory也就足夠了。
SchdulerFactory本身是支持創(chuàng)建RMI stub的,可以用來(lái)管理遠(yuǎn)程的Scheduler,功能與本地一樣,可以遠(yuǎn)程提交個(gè)Job什么的。
1.job

實(shí)現(xiàn)類JobDetail
JobDetail job = JobBuilder.newJob(RemindJob.class)
.withIdentity("job1", "group1").build();//創(chuàng)建一個(gè)任務(wù)
/**
* 創(chuàng)建觸發(fā)器
* 第一種方式 不太好
*/
SimpleTrigger trigger = TriggerBuilder.newTrigger().withIdentity("myTrigger", "myTriggerGroup").
withSchedule(SimpleScheduleBuilder.simpleSchedule().
withIntervalInSeconds(3).
repeatForever()).
startAt(new Date(System.currentTimeMillis()+1000)).build();
/**
* 創(chuàng)建觸發(fā)器
* 第二種 方式 非常好
* 可以 好用 2013年每月的第三個(gè)星期五上午10:30觸發(fā) 0 30 10 ? * 6#3 2013
* 2016年每月的第一個(gè)星期四下午16:17觸發(fā) 0 17 16 ? * 5#1 2016
* 每天15點(diǎn)到16點(diǎn)每5分鐘運(yùn)行一次,此外,每天17點(diǎn)到18點(diǎn)每5分鐘運(yùn)行一次
*/
/*CronTrigger trigger=TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "myTriggerGroup")
.withSchedule(CronScheduleBuilder.cronSchedule("0 18 16 ? * 5#1 2016")).build();*/
SchedulerFactory sf=new StdSchedulerFactory();//創(chuàng)建調(diào)度者工廠
Scheduler scheduler = sf.getScheduler();//創(chuàng)建一個(gè)調(diào)度者
scheduler.scheduleJob(job,trigger);//注冊(cè)并進(jìn)行調(diào)度
scheduler.start();//啟動(dòng)調(diào)度
//Thread.sleep(millis)
//scheduler.shutdown();//關(guān)閉調(diào)度
RemindJob 類的定義
*/
public class RemindJob implements Job {
private RemindService service=new RemindService();
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
service.printPlan("你好!");
Date date=new Date();
String time = date.toString();
System.out.println(time+"job is starting");
}
可以看到,我們傳給scheduler一個(gè)JobDetail實(shí)例,因?yàn)槲覀冊(cè)趧?chuàng)建JobDetail時(shí),將要執(zhí)行的job的類名傳給了JobDetail,所以scheduler就知道了要執(zhí)行何種類型的job;每次當(dāng)scheduler執(zhí)行job時(shí),在調(diào)用其execute(…)方法之前會(huì)創(chuàng)建該類的一個(gè)新的實(shí)例;執(zhí)行完畢,對(duì)該實(shí)例的引用就被丟棄了,實(shí)例會(huì)被垃圾回收;這種執(zhí)行策略帶來(lái)的一個(gè)后果是,job必須有一個(gè)無(wú)參的構(gòu)造函數(shù)(當(dāng)使用默認(rèn)的JobFactory時(shí));另一個(gè)后果是,在job類中,不應(yīng)該定義有狀態(tài)的數(shù)據(jù)屬性,因?yàn)樵趈ob的多次執(zhí)行中,這些屬性的值不會(huì)保留。
那么如何給job實(shí)例增加屬性或配置呢?如何在job的多次執(zhí)行中,跟蹤job的狀態(tài)呢?答案就是:JobDataMap,JobDetail對(duì)象的一部分。
JobDataMap
JobDataMap中可以包含不限量的(序列化的)數(shù)據(jù)對(duì)象,在job實(shí)例執(zhí)行的時(shí)候,可以使用其中的數(shù)據(jù);JobDataMap是Java Map接口的一個(gè)實(shí)現(xiàn),額外增加了一些便于存取基本類型的數(shù)據(jù)的方法。
將job加入到scheduler之前,在構(gòu)建JobDetail時(shí),可以將數(shù)據(jù)放入JobDataMap,如下示例:
JobDetail job=JobBuilder.newJob(RemindJob.class)
.withIdentity("job1", "group1")
.usingJobData("hello", "we are family")
.build();
在job的執(zhí)行過程中,可以從JobDataMap中取出數(shù)據(jù),如下示例:
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
service.printPlan("你好!");
JobKey key=context.getJobDetail().getKey();
JobDataMap map = context.getJobDetail().getJobDataMap();
String string = map.getString("hello");
System.out.println(key+"==========="+string);
Date date=new Date();
String time = date.toString();
System.out.println(time+"job is starting");
}
如果你使用的是持久化的存儲(chǔ)機(jī)制(本教程的JobStore部分會(huì)講到),在決定JobDataMap中存放什么數(shù)據(jù)的時(shí)候需要小心,因?yàn)镴obDataMap中存儲(chǔ)的對(duì)象都會(huì)被序列化,因此很可能會(huì)導(dǎo)致類的版本不一致的問題;Java的標(biāo)準(zhǔn)類型都很安全,如果你已經(jīng)有了一個(gè)類的序列化后的實(shí)例,某個(gè)時(shí)候,別人修改了該類的定義,此時(shí)你需要確保對(duì)類的修改沒有破壞兼容性;更多細(xì)節(jié),參考現(xiàn)實(shí)中的序列化問題。另外,你也可以配置JDBC-JobStore和JobDataMap,使得map中僅允許存儲(chǔ)基本類型和String類型的數(shù)據(jù),這樣可以避免后續(xù)的序列化問題。
如果你在job類中,為JobDataMap中存儲(chǔ)的數(shù)據(jù)的key增加set方法(如在上面示例中,增加setJobSays(String val)方法),那么Quartz的默認(rèn)JobFactory實(shí)現(xiàn)在job被實(shí)例化的時(shí)候會(huì)自動(dòng)調(diào)用這些set方法,這樣你就不需要在execute()方法中顯式地從map中取數(shù)據(jù)了。
在Job執(zhí)行時(shí),JobExecutionContext中的JobDataMap為我們提供了很多的便利。它是JobDetail中的JobDataMap和Trigger中的JobDataMap的并集,但是如果存在相同的數(shù)據(jù),則后者會(huì)覆蓋前者的值。
下面的示例,在job執(zhí)行時(shí),從JobExecutionContext中獲取合并后的JobDataMap:
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
service.printPlan("你好!");
JobKey key=context.getJobDetail().getKey();
/* JobDataMap map = context.getJobDetail().getJobDataMap();
String string = map.getString("hello");
System.out.println(key+"==========="+string);*/
JobDataMap map = context.getMergedJobDataMap();
String string = map.getString("hello");
System.out.println(key+"--------------------- "+string);
以上這篇Quartz之Job與JobDetail深入解析就是小編分享給大家的全部?jī)?nèi)容了,希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
springboot整合mybatis-plus實(shí)現(xiàn)多表分頁(yè)查詢的示例代碼
這篇文章主要介紹了springboot整合mybatis-plus實(shí)現(xiàn)多表分頁(yè)查詢的示例代碼,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2021-03-03
Java?EasyExcel實(shí)現(xiàn)合并相同內(nèi)容單元格與動(dòng)態(tài)標(biāo)題功能
這篇文章主要為大家詳細(xì)介紹了Java?EasyExcel如何實(shí)現(xiàn)合并相同內(nèi)容單元格與動(dòng)態(tài)標(biāo)題功能,文中的示例代碼講解詳細(xì),有需要的小伙伴可以參考下2023-12-12
idea環(huán)境下Maven無(wú)法正常下載pom中配置的包問題
這篇文章主要介紹了idea環(huán)境下Maven無(wú)法正常下載pom中配置的包的問題,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-06-06
Java中Map接口使用以及有關(guān)集合的面試知識(shí)點(diǎn)匯總
在java面試過程中,Map時(shí)常會(huì)被作為一個(gè)面試點(diǎn)來(lái)問,下面這篇文章主要給大家介紹了關(guān)于Java中Map接口使用以及有關(guān)集合的面試知識(shí)點(diǎn)匯總的相關(guān)資料,文中通過實(shí)例代碼介紹的非常詳細(xì),需要的朋友可以參考下2022-07-07
Java和scala實(shí)現(xiàn) Spark RDD轉(zhuǎn)換成DataFrame的兩種方法小結(jié)
今天小編就為大家分享一篇Java和scala實(shí)現(xiàn) Spark RDD轉(zhuǎn)換成DataFrame的兩種方法小結(jié),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來(lái)看看吧2018-06-06
如何利用Java實(shí)現(xiàn)MySQL的數(shù)據(jù)變化監(jiān)聽
在高并發(fā)和大數(shù)據(jù)環(huán)境下,實(shí)時(shí)獲取?MySQL?數(shù)據(jù)庫(kù)的增量變化對(duì)數(shù)據(jù)同步、數(shù)據(jù)分析、緩存更新等場(chǎng)景至關(guān)重要,下面我們就來(lái)看看如何通過Java實(shí)現(xiàn)MySQL的數(shù)據(jù)變化監(jiān)聽吧2025-02-02

