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

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

Quartz中提供了三種 Listener，監聽 Scheduler的，監聽 Trigger的，監聽 Job的。

只需要創建類實現相應的接口，并在 Scheduler上注冊 Listener，便可實現對核心對象的監聽。

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);// 創建并注冊一個全局的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);// 創建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);// 創建并注冊一個全局的Trigger Listenerscheduler.getListenerManager().addTriggerListener(new MyTriggerListener("myListener1"), EverythingMatcher.allTriggers());// 創建并注冊一個局部的Trigger Listenerscheduler.getListenerManager().addTriggerListener(new MyTriggerListener("myListener2"), KeyMatcher.keyEquals(TriggerKey.triggerKey("trigger1", "gourp1")));// 創建并注冊一個特定組的Trigger ListenerGroupMatcher<TriggerKey> matcher = GroupMatcher.triggerGroupEquals("gourp1");scheduler.getListenerManager().addTriggerListener(new MyTriggerListener("myListener3"), matcher);scheduler.start();}}

JobListener

四個方法：

方法作用或執行實際

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

工具類：ListenerManager，用于添加、獲取、移除監聽器

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

TriggerListener

方法作用或執行實際

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

?

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。