专栏首页Throwable's Blog第七章:Trigger监听器和Job监听器

第七章:Trigger监听器和Job监听器

监听器(listener)是你创建的对象,主要作用是接收和处理调度器回调的事件(event)。TriggerListener接收到与触发器(Trigger)相关的事件,JobListener接收与调度任务(Job)相关的事件。

与触发器相关的事件包括:触发器正要触发,触发器错失触发,触发器触发完成(调度任务已被触发开始执行,触发器完成当次触发)。

org.quartz.TriggerListener接口

public interface TriggerListener {

    public String getName();

    public void triggerFired(Trigger trigger, JobExecutionContext context);

    public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context);

    public void triggerMisfired(Trigger trigger);

    public void triggerComplete(Trigger trigger, JobExecutionContext context,
            int triggerInstructionCode);
}

与调度任务相关的事件包括:Job即将执行时的通知以及Job执行完成时的通知。

org.quartz.JobListener接口

public interface JobListener {

    public String getName();

    public void jobToBeExecuted(JobExecutionContext context);

    public void jobExecutionVetoed(JobExecutionContext context);

    public void jobWasExecuted(JobExecutionContext context,
            JobExecutionException jobException);

}

使用自定义的监听器

要创建一个Listener,只需创建一个实现org.quartz.TriggerListener或org.quartz.JobListener接口实现的实例。然后,Listener需要在运行时注册到调度器中。Listener必须指定一个名称(通过实现JobListener接口的getName()方法来传入监听器的名字)。

为了方便起见,自定义监听器也可以继承自JobListenerSupport类或TriggerListenerSupport类,并且只需覆盖你感兴趣的方法。

Listener通过调度器的ListenerManager进行注册,可以通过一个匹配器(Matcher)实例去匹配监听你感兴趣的Job或者Trigger。注意下面的事项:

Listener在运行时才注册到调度器中,并且不与Job或者触发器一起存储在JobStore中。这是因为通常监听器是直接集成到应用程序之中(这里的意思大概是监听器中会有应用程序里面相关的逻辑)。因此每当应用程序启动的时候,所有的监听器需要重新注册到调度器中。

添加匹配的特定Job的JobListener

scheduler.getListenerManager().addJobListener(myJobListener, KeyMatcher.jobKeyEquals(new JobKey("myJobName", "myJobGroup")));

你可能需要为匹配器和关键类使用静态导入,这将使你定义匹配器的逻辑更简洁:

import static org.quartz.JobKey.*;
import static org.quartz.impl.matchers.KeyMatcher.*;
import static org.quartz.impl.matchers.GroupMatcher.*;
import static org.quartz.impl.matchers.AndMatcher.*;
import static org.quartz.impl.matchers.OrMatcher.*;
import static org.quartz.impl.matchers.EverythingMatcher.*;
...etc.

使用静态导入后上面的例子变成这样:

scheduler.getListenerManager().addJobListener(myJobListener, jobGroupEquals("myJobGroup"));

添加对两个特定Group的所有Job感兴趣的JobListener:

scheduler.getListenerManager().addJobListener(myJobListener, or(jobGroupEquals("myJobGroup"), jobGroupEquals("yourGroup")));

添加对所有Job感兴趣的JobListener:

scheduler.getListenerManager().addJobListener(myJobListener, allJobs());

注册TriggerListener的工作原理和JobListener基本相同。

大多数Quartz的使用者并不使用Listener。但是当应用程序有获取任务调度相关的事件通知的需求时,如果使用了Listener可以避免在Job的逻辑里面加入额外的通知逻辑,这一点对于使用者而言是很方便的。

原文链接:tutorial-lesson-07

本文是Throwable的原创文章,转载请提前告知作者并且标明出处。 博客内容遵循 署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0) 协议 本文永久链接是:https://www.throwable.club/2019/03/30/quartz-doc-translation-lesson-7/

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • 第三章:Job和JobDetail的更多细节

    正如你在第二章:Quartz API、调度任务以及触发器看到的,org.quartz.Job很容易实现,在接口中只有一个execute方法。本节主要关注:Job...

    Throwable
  • 第十二章:其他特性

    Quartz提供了一个用于插入附加功能的接口org.quartz.spi.SchedulerPlugin。

    Throwable
  • 第十一章:高级(企业级)特性

    Quartz集群目前与JDBC-Jobstore(JobStoreTX或JobStoreCMT)和(<–译者注:其实我觉得这里应该是"或")Terracotta...

    Throwable
  • 【latex】LaTeX如何输入大小写罗马数字?

    原帖地址:http://blog.sina.com.cn/s/blog_5e16f1770100g5sl.html

    后端技术漫谈
  • Java命令模式(Command)

      将一个请求封装为一个对象,从而可用不同的请求对客户进行参数化;对请求排队或记录日志,以及支持可撤销的操作,将”发出请求的对象”和”接收与执行这些请求的对象”...

    用户4919348
  • 向jboss写入服务器日志

    实际开发中,记录日志是常用的功能,jboss默认情况下已经记录了很多运行日志,如果开发人员要手动在server.log中写入日志,可以参考下面的方法: 1 p...

    菩提树下的杨过
  • 一篇文章学会PageFactory模式

    我们已经学习了Page Object设计模式,优势很明显,能更好的体现java的面向对象思想和封装特性。但同时也存在一些不足之处,那就是随着这种模式使用,随着元...

    软件测试君
  • Easyswoole下Crontab定时器如何实现奇偶数时间分别运行不用的定时任务

    本文为北溟有鱼QAQ原创文章,转载无需和我联系,但请注明来自北溟有鱼QAQ https://www.umdzz.cn ...

    北溟有鱼QAQ
  • 浅谈事务(一) (r5笔记第24天)

    关于事务,在Oracle中似乎是习以为常的,但是在学习MySQL的过程中,发现各种灵活的存储引擎,一个很大的焦点就是对于事务的支持,足以看出事务的实现还是有一定...

    jeanron100
  • 理论|来聊聊最近很火的WGAN

    本周推送的话题是WGAN——WassersteinGAN[2],这篇文章于2017年1月26日出现在arXiv上,并迅速得到了大家的热议,在reddit上有专门...

    用户1908973

扫码关注云+社区

领取腾讯云代金券