您好,登錄后才能下訂單哦!
Job與JobDetail在Quartz中的區(qū)別有哪些?相信很多沒有經(jīng)驗的人對此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個問題。
Quartz可以用來做什么?
Quartz是一個任務(wù)調(diào)度框架。比如你遇到這樣的問題
想每月25號,信用卡自動還款
想每年4月1日自己給當年暗戀女神發(fā)一封匿名賀卡
想每隔1小時,備份一下自己的愛情動作片 學(xué)習(xí)筆記到云盤
這些問題總結(jié)起來就是:在某一個有規(guī)律的時間點干某件事。并且時間的觸發(fā)的條件可以非常復(fù)雜(比如每月最后一個工作日的17:50),復(fù)雜到需要一個專門的框架來干這個事。 Quartz就是來干這樣的事,你給它一個觸發(fā)條件的定義,它負責(zé)到了時間點,觸發(fā)相應(yīng)的Job起來干活。
廢話不多說,代碼杠杠的。。。
public static void main(String[] args) { try { //創(chuàng)建scheduler Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); //定義一個Trigger Trigger trigger =TriggerBuilder.newTrigger().withIdentity("trigger1", "group1") //定義name/group .startNow()//一旦加入scheduler,立即生效 .withSchedule(SimpleScheduleBuilder.simpleSchedule() //使用SimpleTrigger .withIntervalInSeconds(1) //每隔一秒執(zhí)行一次 .repeatForever()) //一直執(zhí)行 .build(); //定義一個JobDetail JobDetail job =JobBuilder.newJob(HelloQuartz.class) //定義Job類為HelloQuartz類,這是真正的執(zhí)行邏輯所在 .withIdentity("job1", "group1") //定義name/group .usingJobData("name", "quartz") //定義屬性 .build(); //加入這個調(diào)度 scheduler.scheduleJob(job, trigger); //啟動之 scheduler.start(); //運行一段時間后關(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包:
這個例子很好的覆蓋了Quartz最重要的3個基本要素:
Scheduler:調(diào)度器。所有的調(diào)度都是由它控制。
Trigger: 定義觸發(fā)的條件。例子中,它的類型是SimpleTrigger,每隔1秒中執(zhí)行一次(什么是SimpleTrigger下面會有詳述)。
JobDetail & Job: JobDetail 定義的是任務(wù)數(shù)據(jù),而真正的執(zhí)行邏輯是在Job中,例子中是HelloQuartz。 為什么設(shè)計成JobDetail + Job,不直接使用Job?這是因為任務(wù)是有可能并發(fā)執(zhí)行,如果Scheduler直接使用Job,就會存在對同一個Job實例并發(fā)訪問的問題。而JobDetail & Job 方式,sheduler每次執(zhí)行,都會根據(jù)JobDetail創(chuàng)建一個新的Job實例,這樣就可以規(guī)避并發(fā)訪問的問題。
Scheduler
Scheduler就是Quartz的大腦,所有任務(wù)都是由它來設(shè)施。
Schduelr包含一個兩個重要組件: JobStore和ThreadPool。
JobStore是會來存儲運行時信息的,包括Trigger,Schduler,JobDetail,業(yè)務(wù)鎖等。它有多種實現(xiàn)RAMJob(內(nèi)存實現(xiàn)),JobStoreTX(JDBC,事務(wù)由Quartz管理),JobStoreCMT(JDBC,使用容器事務(wù)),ClusteredJobStore(集群實現(xiàn))、TerracottaJobStore(什么是Terractta)。
ThreadPool就是線程池,Quartz有自己的線程池實現(xiàn)。所有任務(wù)的都會由線程池執(zhí)行。
SchedulerFactory
SchdulerFactory,顧名思義就是來用創(chuàng)建Schduler了,有兩個實現(xiàn):DirectSchedulerFactory和 StdSchdulerFactory。前者可以用來在代碼里定制你自己的Schduler參數(shù)。后者是直接讀取classpath下的quartz.properties(不存在就都使用默認值)配置來實例化Schduler。通常來講,我們使用StdSchdulerFactory也就足夠了。
SchdulerFactory本身是支持創(chuàng)建RMI stub的,可以用來管理遠程的Scheduler,功能與本地一樣,可以遠程提交個Job什么的。
1.job
實現(xiàn)類JobDetail
JobDetail job = JobBuilder.newJob(RemindJob.class) .withIdentity("job1", "group1").build();//創(chuàng)建一個任務(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年每月的第三個星期五上午10:30觸發(fā) 0 30 10 ? * 6#3 2013 * 2016年每月的第一個星期四下午16:17觸發(fā) 0 17 16 ? * 5#1 2016 * 每天15點到16點每5分鐘運行一次,此外,每天17點到18點每5分鐘運行一次 */ /*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)建一個調(diào)度者 scheduler.scheduleJob(job,trigger);//注冊并進行調(diào)度 scheduler.start();//啟動調(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一個JobDetail實例,因為我們在創(chuàng)建JobDetail時,將要執(zhí)行的job的類名傳給了JobDetail,所以scheduler就知道了要執(zhí)行何種類型的job;每次當scheduler執(zhí)行job時,在調(diào)用其execute(…)方法之前會創(chuàng)建該類的一個新的實例;執(zhí)行完畢,對該實例的引用就被丟棄了,實例會被垃圾回收;這種執(zhí)行策略帶來的一個后果是,job必須有一個無參的構(gòu)造函數(shù)(當使用默認的JobFactory時);另一個后果是,在job類中,不應(yīng)該定義有狀態(tài)的數(shù)據(jù)屬性,因為在job的多次執(zhí)行中,這些屬性的值不會保留。
那么如何給job實例增加屬性或配置呢?如何在job的多次執(zhí)行中,跟蹤job的狀態(tài)呢?答案就是:JobDataMap,JobDetail對象的一部分。
JobDataMap
JobDataMap中可以包含不限量的(序列化的)數(shù)據(jù)對象,在job實例執(zhí)行的時候,可以使用其中的數(shù)據(jù);JobDataMap是Java Map接口的一個實現(xiàn),額外增加了一些便于存取基本類型的數(shù)據(jù)的方法。
將job加入到scheduler之前,在構(gòu)建JobDetail時,可以將數(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"); }
如果你使用的是持久化的存儲機制(本教程的JobStore部分會講到),在決定JobDataMap中存放什么數(shù)據(jù)的時候需要小心,因為JobDataMap中存儲的對象都會被序列化,因此很可能會導(dǎo)致類的版本不一致的問題;Java的標準類型都很安全,如果你已經(jīng)有了一個類的序列化后的實例,某個時候,別人修改了該類的定義,此時你需要確保對類的修改沒有破壞兼容性;更多細節(jié),參考現(xiàn)實中的序列化問題。另外,你也可以配置JDBC-JobStore和JobDataMap,使得map中僅允許存儲基本類型和String類型的數(shù)據(jù),這樣可以避免后續(xù)的序列化問題。
如果你在job類中,為JobDataMap中存儲的數(shù)據(jù)的key增加set方法(如在上面示例中,增加setJobSays(String val)方法),那么Quartz的默認JobFactory實現(xiàn)在job被實例化的時候會自動調(diào)用這些set方法,這樣你就不需要在execute()方法中顯式地從map中取數(shù)據(jù)了。
在Job執(zhí)行時,JobExecutionContext中的JobDataMap為我們提供了很多的便利。它是JobDetail中的JobDataMap和Trigger中的JobDataMap的并集,但是如果存在相同的數(shù)據(jù),則后者會覆蓋前者的值。
下面的示例,在job執(zhí)行時,從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);
看完上述內(nèi)容,你們掌握Job與JobDetail在Quartz中的區(qū)別有哪些的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。