Quartz框架中的Listener

我们有这么一种需求，在每个任务运行结束之后发送通知给运维管理员。那是不是要在每个任务的最后添加一行代码呢？这种方式对原来的代码造成了入侵，不利于维护。如果代码不是写在任务代码的最后一行，怎么知道任务执行完了呢？或者说，怎么监测到任务的生命周期呢？

观察者模式：定义对象间一种一对多的依赖关系，使得每当一个对象改变状态，则所有依赖它的对象都会得到通知并自动更新。

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相关推荐

Quartz框架中的JobStore
问题:最多可以运行多少个任务(磁盘.内存.线程数) Jobstore用来存储任务和触发器相关的信息,例如所有任务的名称.数量.状态等等.Quartz中有两种存储任务的方式,一种在在内存,一种是在数据库 ...
Quartz框架中的Scheduler
调度器,是 Quartz的指挥官,由 StdSchedulerFactory产生.它是单例的.并且是 Quartz中最重要的 API,默认是实现类是 StdScheduler,里面包含了一个Quart ...
Quartz框架中的Trigger
定义任务的触发规律,Trigger,使用 TriggerBuilder来构建. JobDetail跟 Trigger是 1:N的关系. 思考:为什么要解耦? Trigger接口在 Quartz有 4个 ...
Quartz框架之触发器（3）
1 关于Quartz的触发器 Quartz框架中的触发器的主要功能就是指明何时该触发任务的执行, 触发器包含一系列的定义信息,开发人员可根据实际情形自定义对应的触发器. triggerKey 用于分组 ...
SpringBoot与quartz框架实现分布式定时任务
前言 quartz的分布式调度策略是以数据库为边界资源的一种异步策略.各个调度器都遵守一个基于数据库锁的操作规则从而保证了操作的唯一性. 在quartz的集群解决方案里有张表scheduler_loc ...
Quartz 框架快速入门（二）
尽可能的用声明式处理软件配置,其次才考虑编程式的方式.在上一篇<Quartz 框架快速入门(一)>中,如果我们要在 Job 启动之后改变它的执行时间和频度,必须去修改源代码重新编译.这种方 ...
SSH框架中配置log4j的方法
/*2011年8月29日 09:52:54 by Rush*/ SSH框架中使用log4j的方便之处 1. 动态的改变记录级别和策略,即修改log4j.properties,不需要重启Web应用,这需 ...
Quartz框架多个trigger任务执行出现漏执行的问题分析--转
原文地址:http://blog.csdn.net/dailywater/article/details/51470779 一.问题描述使用Quartz配置定时任务,配置了超过10个定时任务,这些 ...
Quartz 框架快速入门（四）
Spring的scheduling.quartz包中对Quartz框架进行了封装,使得开发时不用写任何QuartSpring的代码就可以实现定时任务.Spring通过JobDetailBean,Met ...

Quartz框架中的Listener

Quartz框架中的Listener相关推荐

最新文章

热门文章