Quartz Scheduler失火指令说明

有时,Quartz无法在您需要的时间运行您的工作。 这有三个原因:
  • 所有工作线程都忙于运行其他作业(可能具有更高的优先级)
  • 调度程序本身已关闭
  • 该作业是在过去的开始时间安排的(可能是编码错误)

您可以通过简单地在quartz.properties自定义org.quartz.threadPool.threadCount (默认值为10)来增加工作线程的数量。 但是当整个应用程序/服务器/调度程序停机时,您实际上无法执行任何操作。 当Quartz无法触发给定的触发器时,这种情况称为不点火 。 您知道Quartz在发生时在做什么吗? 事实证明,Quartz可以采用多种策略(称为失火指令 ),并且如果您没有考虑的话,还有一些默认设置。 但是,为了使您的应用程序健壮和可预测(尤其是在高负载或维护情况下),您应该真正确保触发器和作业的配置合理。

根据选择的触发器,有不同的配置选项(可用的失火说明 )。 Quartz的行为也取决于触发器设置(所谓的智能策略 )。 尽管失火说明已在文档中进行了描述,但我发现很难理解它们的真正含义。 因此,我创建了这篇小总结文章。

在深入探讨细节之前,应该先介绍另一个配置选项。 它是org.quartz.jobStore.misfireThreshold (以毫秒为单位),默认为60000(一分钟)。 它定义了触发器应该多长时间才被认为触发失败 。 在默认设置下,如果触发器是在30秒前触发的,那么Quartz会很高兴地运行它。 这种延迟不被认为是错误触发。 但是,如果在计划的时间之后61秒发现触发器,则特殊的失火处理程序线程会按照失火指令来处理它。 出于测试目的,我们将此参数设置为1000(1秒),以便我们可以快速测试错火。

简单触发,无需重复

在我们的第一个示例中,我们将看到计划仅运行一次的简单触发器如何处理错火:

val trigger = newTrigger().startAt(DateUtils.addSeconds(new Date(), -10)).build()

相同的触发器,但显式设置了失火指令处理程序:

val trigger = newTrigger().startAt(DateUtils.addSeconds(new Date(), -10)).withSchedule(simpleSchedule().withMisfireHandlingInstructionFireNow()  //MISFIRE_INSTRUCTION_FIRE_NOW).build()

为了进行测试,我只是将触发器安排在10秒钟前运行(因此,它在创建之时要晚10秒钟!)在现实世界中,您通常不会安排这样的触发器。 而是假设触发器已正确设置,但是在安排好调度程序时,调度程序已关闭或没有任何可用的辅助线程。 然而,石英将如何处理这种特殊情况? 在上面的第一个代码段中,未设置失火处理指令(在这种情况下,使用了智能策略 )。 第二个代码段明确定义了发生错火时我们期望什么样的行为。 见表:

简单触发重复固定次数

这种情况要复杂得多。 想象一下,我们已经安排了一些工作来重复固定的次数:

val trigger = newTrigger().startAt(dateOf(9, 0, 0)).withSchedule(simpleSchedule().withRepeatCount(7).withIntervalInHours(1).WithMisfireHandlingInstructionFireNow()  //or other).build()

在此示例中,假设触发器每小时触发8次(首次执行+ 7次重复),从今天上午9点开始( startAt(dateOf(9, 0, 0)) 。因此,最后一次执行应在下午4点进行。假设由于某种原因,调度程序无法在上午9点和10点运行作业,并且在10:15 AM发现了这一事实,即2次点火失败,调度程序在这种情况下将如何表现?

简单触发无限重复

在这种情况下,触发器以给定的间隔重复无数次:

val trigger = newTrigger().startAt(dateOf(9, 0, 0)).withSchedule(simpleSchedule().withRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY).withIntervalInHours(1).WithMisfireHandlingInstructionFireNow()  //or other).build()

再次应该从今天的上午9点开始每小时触发一次( startAt(dateOf(9, 0, 0))startAt(dateOf(9, 0, 0)) 。然而,调度程序无法在上午9点和10点运行作业,并且它在10:15发现了这一事实AM,即2次点火失败,与简单触发器固定运行次数相比,这是更普遍的情况。

CRON触发器

CRON触发器是Quartz用户中最受欢迎的触发器。 但是,还有两个其他可用的触发器: DailyTimeIntervalTrigger (例如, 每25分钟触发一次 )和CalendarIntervalTrigger (例如, 每5个月触发一次 )。 它们支持在CRON和简单触发器中均不可能的触发策略。 但是,他们了解与CRON触发器相同的失火处理说明。

val trigger = newTrigger().withSchedule(cronSchedule("0 0 9-17 ? * MON-FRI").withMisfireHandlingInstructionFireAndProceed()  //or other).build()

在此示例中,触发器应在周一至周五的上午9点至下午5点之间每小时触发一次。 但是再次错过了前两次调用(因此触发器未触发),这种情况在上午10:15被发现。 请注意,可用的失火指令与简单触发器相比有所不同:


QTZ-283 QTZ-283:MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY不JDBCJobStore工作 -显然存在一个bug,当JDBCJobStore时,留意这个问题。

如您所见,各种触发器的行为基于实际设置而有所不同。 而且,即使提供了所谓的智能策略 ,该决定通常还是基于业务需求。 从本质上讲,有三种主要策略: 忽略立即运行,继续丢弃并等待下一个 。 它们都有不同的用例:

当您要确保触发了所有计划执行时,请使用忽略策略,即使这意味着将触发多个未触发的触发器。 考虑一下一个工作,该工作根据最后一个小时的订单每小时生成一次报告。 如果服务器停机了8个小时,您仍然希望尽快生成报告。 在这种情况下, 忽略策略将简单地以计划程序的速度运行在该8个小时内计划的所有触发器。 他们将迟到几个小时,但最终将被执行。

当有定期执行的作业以及失火情况下,应立即使用*策略,但应尽快运行,但只能运行一次。 想一想每分钟都会清理/tmp目录的作业。 如果调度程序忙了20分钟并且最终可以运行此作业,则您不想运行20次! 一个就足够了,但要确保它能尽快运行。 然后回到正常的一分钟间隔。

最后,当您要确保作业在特定的时间点运行时, next *策略很好。 例如,您需要每小时获取一个季度的股票价格。 它们会Swift变化,因此,如果您的工作失败了,并且已经整整20分钟了,那就不要打扰了。 您错过了5分钟的正确时间,现在您不在乎。 最好有一个差距而不是一个不正确的值。 在这种情况下,Quartz将跳过所有未执行的执行,而仅等待下一个执行。

参考: Quartz调度程序失火指令,由我们的JCG合作伙伴 Tomasz Nurkiewicz在Java和社区博客中解释。


翻译自: https://www.javacodegeeks.com/2012/04/quartz-scheduler-misfire-instructions.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/373082.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

改进租房练习

代码基本没有改动&#xff0c;函数有变化&#xff0c;老师只用了一个函数&#xff0c;自己做写了4个function&#xff0c;减少了代码量 <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitio…

Google App Engine JAX-RS REST服务

在本文中&#xff0c;您将学习如何使用JAX-RS参考实现&#xff08;Jersey&#xff09;创建REST服务并将其部署在Google AppEngine上。 先决条件 对于本教程&#xff0c;您将需要&#xff1a; Google AppEngine帐户 Eclipse Galileo&#xff08;3.5.x&#xff09; 适用于Java的…

鸿蒙系统的全面开源,华为:打造全球的操作系统,鸿蒙今日全面开源!

原标题&#xff1a;华为&#xff1a;打造全球的操作系统&#xff0c;鸿蒙今日全面开源&#xff01;今日下午&#xff0c;2019华为全球开发者大会在华为松山湖基地正式开幕。华为正式对外推出了自研操作系统——鸿蒙系统(Harmony OS)。华为消费者业务CEO余承东指出&#xff0c;鸿…

html5 游戏制作教程,html5一步步实现超级玛丽游戏制作(新手教程源码)

【实例简介】【实例截图】【核心代码】My first Gamebody {border:none 0px;margin:0px;padding:10px;font-size : 16px;background-color : #f3f3f3;}canvas {border : 1px solid blue;}// 页面初始化函数function init(){//加载图片,并存入全局变量 ImgCache,// 加载完成后,调…

交友系统设计:哪种地理空间邻近算法更快?

小熊学Java&#xff1a;https://javaxiaobear.cn 交友与婚恋是人们最基本的需求之一。随着互联网时代的不断发展&#xff0c;移动社交软件已经成为了人们生活中必不可少的一部分。然而&#xff0c;熟人社交并不能完全满足年轻人的社交与情感需求&#xff0c;于是陌生人交友平台…

Apache Camel教程– EIP,路由,组件,测试和其他概念的简介

公司之间的数据交换增加了很多。 必须集成的应用程序数量也增加了。 这些接口使用不同的技术&#xff0c;协议和数据格式。 但是&#xff0c;这些应用程序的集成应以标准化的方式建模&#xff0c;有效实现并由自动测试支持。 企业集成模式&#xff08;EIP&#xff09;[1]中存在…

iOS开发UI篇—UITableview控件简单介绍

一、基本介绍 在众多移动应⽤用中,能看到各式各样的表格数据 。 在iOS中,要实现表格数据展示,最常用的做法就是使用UITableView&#xff0c;UITableView继承自UIScrollView,因此支持垂直滚动,⽽且性能极佳 。 UITableview有分组和不分组两种样式&#xff0c;可以在storyboard或…

动态ADF火车:以编程方式添加火车停靠站

我将展示如何以编程方式“即时”将火车停靠站添加到ADF火车中。 在我的用例中&#xff0c;我有一些票务预订应用程序。 它具有训练模型的有限任务流。 在火车的第一站&#xff0c;用户输入乘客的数量&#xff0c;在随后的站点&#xff0c;他们输入一些乘客的信息。 带有乘客信息…

关于存储过程权限

关于ORACLE账号的权限问题&#xff0c;一般分为两种权限&#xff1a; 系统权限: 允许用户执行特定的数据库动作&#xff0c;如创建表、创建索引、创建存储过程等 对象权限: 允许用户操纵一些特定的对象&#xff0c;如读取视图&#xff0c;可更新某些列、执行存储过程等 像这种查…

宁波镇海2021年高考成绩查询,最新!2021年,宁波镇海区的这14所中小学“爆了...

宁波镇海区教育局发布了2021年公办学校小学一年级、初中一年级招生第一次预警&#xff0c;这也是宁波首个发布2021年公办学校招生预警的县、市、区。根据最新数据摸排&#xff0c;宁波镇海区有8所小学红色预警、2所初中红色预警&#xff0c;1所小学黄色预警、3所初中黄色预警。…

超出了GC开销限制– Java堆分析

这篇文章是我们原来的GC超出限制的问题模式帖子的延续。 正确的Java堆分析对于消除O​​utOfMemoryError&#xff1a;GC开销问题至关重要。 如果您不熟悉此Java HotSpot 1.6错误&#xff0c;建议您首先阅读有关此主题的第一篇文章 。 本文将为您提供一个示例程序和一个教程&…

cdockpane限制调整大小_影视后期制作小伙伴必看:使用AU对声音质量进行调整的三大技巧...

一、增幅一般人进入AU的音频调整界面&#xff0c;会使用图中的旋钮进行音量调整&#xff0c;这种操作是错误的&#xff0c;因为通过拖拽并不能确定调整音量的大小幅度&#xff0c;精准度极低&#xff0c;反复操作才能试出最佳音量&#xff0c;效率极低。最优方案是使用左侧效果…

华润置地php面试题_从一流到顶流|2020华润置地与沈阳一起美好

如果用一句话来形容华润置地进入沈阳13年的发展历程&#xff0c;你认为是什么&#xff1f;“从优秀到卓越”。用2020年的语言你给我翻译一下&#xff1f;“从一流到顶流”&#xff01;01/ 初识的美好犹记2007年1月&#xff0c;央企华润置地首进沈阳&#xff0c;在大馆原址呈现出…

cmd控制屏幕光标_电脑控制手机?上班时间愉快尽情地玩手机吧!它值得您拥有!...

在现今时代&#xff0c;手机已成为人们必不可少的工具&#xff0c;有的时候甚至可以说手机比电脑方便好用多了&#xff0c;例如某些实用的APP软件就只有手机端并没有电脑端&#xff0c;想使用的话就得整天捧着手机盯着不放。但别忘记&#xff0c;我们大多数都是打工族&#xff…

xp系统设置锁定计算机,系统锁定时不关机的诀窍 给XP系统关闭计算机再加一把锁...

很多用户抱怨在使用电脑的过程中&#xff0c;总是经常会被琐碎的事情打断&#xff0c;有时候难免暂时离开电脑&#xff0c;处于便利和资料安全&#xff0c;我们往往会按下“WindowsL”来锁定计算机。这样&#xff0c;操作方便同时又能阻止他人乱动我们的计算机。但是如果遇到好…

gitee项目404问题_七款开源项目,让你数据库管理不再成为一个问题

在开发过程中&#xff0c;数据库是必不可少的一环&#xff0c;但大多数情况下开发者们还是在用命令行来管理数据库。虽然在外人看起来输入一行行代码非常的酷炫&#xff0c;但其中的繁琐可能也只有开发者知道。七款开源项目&#xff0c;让你数据库管理不再成为一个问题今天 Git…

vb 窗体html表格,VB.Net – 高级表格

在本章中&#xff0c;让我们研究以下概念 :在应用程序中添加菜单和子菜单在表单中添加剪切&#xff0c;复制和粘贴功能锚定和对接控件表格模态表格添加菜单和子菜单应用程序中的菜单传统上&#xff0c;菜单&#xff0c;MainMenu&#xff0c;ContextMenu和MenuItem类用于在Windo…

SpringMVC后台接收list类型的数据的实现方式

一、背景 最近在做一些东西的时候&#xff0c;遇到一个需要Springmvc后台接收list类型数据的需求&#xff0c;几经辗转才完美解决了这个问题&#xff0c;今天记下来方便以后使用&#xff0c;也分享给需要的小伙伴们~ 二、实现方式 实现方式一 前端页面 1 <% page language&q…

Maven集成测试和Spring Restful Services

介绍 我的原始博客通过一个非常简单的示例展示了如何分离Maven单元和集成测试。 http://johndobie.blogspot.com/2011/06/seperating-maven-unit-integration-tests.html此后&#xff0c;许多人要求我提供比最初使用的示例更实际的示例。 这篇文章展示了如何在实际环境中&#…

玩cf出现outofmemory_CF画质粗糙平衡感人,却能历经十年经久不衰,靠的是什么?...

Hello大家好&#xff0c;我是沐辰。《穿越火线》这款游戏国内运营时间已长达十年&#xff0c;从最早接触这款游戏开始&#xff0c;很多玩家都在这里烙刻下了许多关于青春的回忆。CF的许多问题一直颇受诟病&#xff0c;例如落后且粗糙的画质、英雄级武器与平民武器的巨大差距、千…