我們有這么一種需求，在每個任務(wù)運行結(jié)束之后發(fā)送通知給運維管理員。那是不是要在每個任務(wù)的最后添加一行代碼呢？這種方式對原來的代碼造成了入侵，不利于維護(hù)。如果代碼不是寫在任務(wù)代碼的最后一行，怎么知道任務(wù)執(zhí)行完了呢？或者說，怎么監(jiān)測到任務(wù)的生命周期呢？

觀察者模式：定義對象間一種一對多的依賴關(guān)系，使得每當(dāng)一個對象改變狀態(tài)，則所有依賴它的對象都會得到通知并自動更新。

Quartz中提供了三種 Listener，監(jiān)聽 Scheduler的，監(jiān)聽 Trigger的，監(jiān)聽 Job的。

只需要創(chuàng)建類實現(xiàn)相應(yīng)的接口，并在 Scheduler上注冊 Listener，便可實現(xiàn)對核心對象的監(jiān)聽。

public class MyJobListenerTest {public static void main(String[] args) throws SchedulerException {// JobDetailJobDetail jobDetail = JobBuilder.newJob(MyJob1.class).withIdentity("job1", "group1").build();// TriggerTrigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever()).build();// SchedulerFactorySchedulerFactory factory = new StdSchedulerFactory();// SchedulerScheduler scheduler = factory.getScheduler();scheduler.scheduleJob(jobDetail, trigger);// 創(chuàng)建并注冊一個全局的Job Listenerscheduler.getListenerManager().addJobListener(new MyJobListener(), EverythingMatcher.allJobs());scheduler.start();}} public class MySchedulerListenerTest {public static void main(String[] args) throws SchedulerException {// JobDetailJobDetail jobDetail = JobBuilder.newJob(MyJob1.class).withIdentity("job1", "group1").build();// TriggerTrigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever()).build();// SchedulerFactorySchedulerFactory factory = new StdSchedulerFactory();// SchedulerScheduler scheduler = factory.getScheduler();scheduler.scheduleJob(jobDetail, trigger);// 創(chuàng)建Scheduler Listenerscheduler.getListenerManager().addSchedulerListener(new MySchedulerListener());scheduler.start();}} public class MyTriggerListenerTest {public static void main(String[] args) throws SchedulerException {// JobDetailJobDetail jobDetail = JobBuilder.newJob(MyJob1.class).withIdentity("job1", "group1").build();// TriggerTrigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").startNow().withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).repeatForever()).build();// SchedulerFactorySchedulerFactory factory = new StdSchedulerFactory();// SchedulerScheduler scheduler = factory.getScheduler();scheduler.scheduleJob(jobDetail, trigger);// 創(chuàng)建并注冊一個全局的Trigger Listenerscheduler.getListenerManager().addTriggerListener(new MyTriggerListener("myListener1"), EverythingMatcher.allTriggers());// 創(chuàng)建并注冊一個局部的Trigger Listenerscheduler.getListenerManager().addTriggerListener(new MyTriggerListener("myListener2"), KeyMatcher.keyEquals(TriggerKey.triggerKey("trigger1", "gourp1")));// 創(chuàng)建并注冊一個特定組的Trigger ListenerGroupMatcher<TriggerKey> matcher = GroupMatcher.triggerGroupEquals("gourp1");scheduler.getListenerManager().addTriggerListener(new MyTriggerListener("myListener3"), matcher);scheduler.start();}}

JobListener

四個方法：

方法作用或執(zhí)行實際

getName()	返回JobListener 的名稱
jobToBeExecuted()	Scheduler 在JobDetail 將要被執(zhí)行時調(diào)用這個方法
jobExecutionVetoed()	Scheduler 在JobDetail 即將被執(zhí)行，但又被TriggerListener 否決了時調(diào)用這個 方法
jobWasExecuted()	Scheduler 在JobDetail 被執(zhí)行之后調(diào)用這個方法

工具類：ListenerManager，用于添加、獲取、移除監(jiān)聽器

工具類：Matcher，主要是基于 groupName和 keyName進(jìn)行匹配。?

TriggerListener

方法作用或執(zhí)行實際

getName()	返回監(jiān)聽器的名稱
triggerFired()	Trigger 被觸發(fā)，Job 上的execute() 方法將要被執(zhí)行時，Scheduler 就調(diào)用這個 方法
vetoJobExecution()	在Trigger 觸發(fā)后， Job 將要被執(zhí)行時由Scheduler 調(diào)用這個方法。 TriggerListener 給了一個選擇去否決Job 的執(zhí)行。假如這個方法返回true，這 個Job 將不會為此次Trigger 觸發(fā)而得到執(zhí)行
triggerMisfired()	Trigger 錯過觸發(fā)時調(diào)用
triggerComplete()	Trigger 被觸發(fā)并且完成了Job 的執(zhí)行時，Scheduler 調(diào)用這個方法

?

總結(jié)

以上是生活随笔為你收集整理的Quartz框架中的Listener的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。