天天看点

Quartz任务调度(5)TriggerListener分版本超详细解析TriggerListener源码下载

在我们的触发器监听器中,也包含了一系列监听方法

方法

说明

getname()

定义并返回监听器的名字

triggerfired()

当与监听器相关联的 trigger 被触发,job 上的 execute() 方法将要被执行时,scheduler 就调用这个方法。在全局 triggerlistener 情况下,这个方法为所有 trigger 被调用。

vetojobexecution()

在 trigger 触发后,job 将要被执行时由 scheduler 调用这个方法。triggerlistener 给了一个选择去否决 job 的执行。假如这个方法返回 true,这个 job 将不会为此次 trigger 触发而得到执行。

triggermisfired()

scheduler 调用这个方法是在 trigger 错过触发时。如这个方法的 javadoc 所指出的,你应该关注此方法中持续时间长的逻辑:在出现许多错过触发的 trigger 时,长逻辑会导致骨牌效应。你应当保持这上方法尽量的小。

triggercomplete()

trigger 被触发并且完成了 job 的执行时,scheduler 调用这个方法。这不是说这个 trigger 将不再触发了,而仅仅是当前 trigger 的触发(并且紧接着的 job 执行) 结束时。这个 trigger 也许还要在将来触发多次的。

下面是我们的监听器实例配置

使用triggerlistener和joblistener的方法大同小异,思路都是一样的。

相对于上一篇文章的配置,我们只需将joblistener替换成triggerlistener即可。下面是我们的完整测试代码:

运行程序,我们会看到:

trigger 被触发了,此时job 上的 execute() 方法将要被执行 发现此次job的相关资源准备存在问题,不便展开任务,返回true表示否决此次任务执行——————我们的trigger监听器要否决我们的任务,触发了相应的监听方法,同时后续的complete监听方法自然不会再被执行 被否决执行了,可以做些日志记录。——————我们的picknewsjob被否决了,触发了相应的监听方法 在13:15:39根据文章的阅读量和评论量来生成我们的最热文章列表 发现此次job的相关资源准备存在问题,不便展开任务,返回true表示否决此次任务执行 被否决执行了,可以做些日志记录。 在13:15:42根据文章的阅读量和评论量来生成我们的最热文章列表

如果我们将triggerlistener中的vetojobexecution()方法改成如下所示:

再运行我们的测试程序,会打印:

不否决job,正常执行 myjoblistener触发对class tool.job.picknewsjob的开始执行的监听工作,这里可以完成任务前的一些资源准备工作或日志记录 在13:20:20扒取新闻 在13:20:20根据文章的阅读量和评论量来生成我们的最热文章列表 myjoblistener触发对class tool.job.picknewsjob结束执行的监听工作,这里可以进行资源销毁工作或做一些新闻扒取结果的统计工作 trigger 被触发并且完成了 job 的执行,此方法被调用 在13:20:22扒取新闻 在13:20:23根据文章的阅读量和评论量来生成我们的最热文章列表 我们的job不被否决,同时有后续的job成功执行的监听方法调用

我们可以调用如下所示测试代码:

调用此方法,我们和得到和1.+版本中类似的结果:

根据文章的阅读量和评论量来生成我们的最热文章列表