前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >第七章:Trigger监听器和Job监听器

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

作者头像
Throwable
发布2020-06-23 16:25:12
1.1K0
发布2020-06-23 16:25:12
举报
文章被收录于专栏:Throwable's BlogThrowable's Blog

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

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

org.quartz.TriggerListener接口

代码语言:javascript
复制
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接口

代码语言:javascript
复制
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。注意下面的事项:

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

添加匹配的特定Job的JobListener

代码语言:javascript
复制
scheduler.getListenerManager().addJobListener(myJobListener, KeyMatcher.jobKeyEquals(new JobKey("myJobName", "myJobGroup")));

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

代码语言:javascript
复制
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.

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

代码语言:javascript
复制
scheduler.getListenerManager().addJobListener(myJobListener, jobGroupEquals("myJobGroup"));

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

代码语言:javascript
复制
scheduler.getListenerManager().addJobListener(myJobListener, or(jobGroupEquals("myJobGroup"), jobGroupEquals("yourGroup")));

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

代码语言:javascript
复制
scheduler.getListenerManager().addJobListener(myJobListener, allJobs());

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

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

原文链接:tutorial-lesson-07

本文是Throwable的原创文章,转载请提前告知作者并且标明出处。 博客内容遵循 署名-非商业性使用-相同方式共享 4.0 国际 (CC BY-NC-SA 4.0) 协议 本文永久链接是:https://cloud.tencent.com/developer/article/1650097

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2019年3月30日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 使用自定义的监听器
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档