AI 助理
备案控制台
开发者社区 开发与运维 文章 正文

总结几点Quartz的经验

2017-06-28 1448
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：

总结一下经典的定时处理框架quartz的使用经验。基于 Ver. 1.8.0

  1.配置方式

        最常用的方式properties + xml定义

Java代码  复制代码  收藏代码
  1. org.quartz.scheduler.instanceName = CMS_Batch   
  2. org.quartz.scheduler.instanceId = AUTO   
  3.   
  4. org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool   
  5. org.quartz.threadPool.threadCount = 5  
  6. org.quartz.threadPool.threadPriority = 5  
  7.   
  8. org.quartz.jobStore.misfireThreshold = 60000  
  9. org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore   
  10.   
  11. org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin   
  12.   
  13. org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin   
  14. org.quartz.plugin.jobInitializer.fileNames = quartz_data.xml   
  15. org.quartz.plugin.jobInitializer.failOnFileNotFound = true  
  16.   
  17. #默认会联网检查是否有更新，还是skip为好   
  18. org.quartz.scheduler.skipUpdateCheck = true  
org.quartz.scheduler.instanceName = CMS_Batch
org.quartz.scheduler.instanceId = AUTO

org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 5
org.quartz.threadPool.threadPriority = 5

org.quartz.jobStore.misfireThreshold = 60000
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin

org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin
org.quartz.plugin.jobInitializer.fileNames = quartz_data.xml
org.quartz.plugin.jobInitializer.failOnFileNotFound = true

#默认会联网检查是否有更新，还是skip为好
org.quartz.scheduler.skipUpdateCheck = true

 

        properties定义全局信息(全局Listener也在这定义)，xml定义Job、trigger信息

Java代码  复制代码  收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>   
  2. <job-scheduling-data xmlns="http://www.quartz-scheduler.org/xml/JobSchedulingData"  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  4.     xsi:schemaLocation="http://www.quartz-scheduler.org/xml/JobSchedulingData http://www.quartz-scheduler.org/xml/job_scheduling_data_1_8.xsd"  
  5.     version="1.8">   
  6.        
  7.     <pre-processing-commands>   
  8.         <delete-jobs-in-group>*</delete-jobs-in-group>  <!-- clear all jobs in scheduler -->   
  9.         <delete-triggers-in-group>*</delete-triggers-in-group> <!-- clear all triggers in scheduler -->   
  10.     </pre-processing-commands>   
  11.        
  12.     <processing-directives>   
  13.         <overwrite-existing-data>true</overwrite-existing-data>   
  14.         <ignore-duplicates>false</ignore-duplicates>    
  15.     </processing-directives>   
  16.        
  17.     <schedule>   
  18.         <job>   
  19.             <name>FooJob</name>   
  20.             <group>FooBatch</group>   
  21.             <description>定时运行Job</description>   
  22.             <job-class>xxx.yyy.FooJob</job-class>   
  23.             <volatility>false</volatility>   
  24.             <durability>true</durability>   
  25.             <recover>false</recover>   
  26.         </job>   
  27.         <trigger>   
  28.             <cron>   
  29.                 <name>FooTrigger</name>   
  30.                 <group>FooBatch</group>   
  31.                 <job-name>FooJob</job-name>   
  32.                 <job-group>FooBatch</job-group>   
  33.                 <misfire-instruction>MISFIRE_INSTRUCTION_FIRE_ONCE_NOW</misfire-instruction>   
  34.                 <cron-expression>30/15 * 13 * * ?</cron-expression>   
  35.                 <!-- 秒 分 时 日 月 星期 年 -->   
  36.             </cron>   
  37.         </trigger>   
  38.         <job>   
  39.             <name>barJob</name>   
  40.             <group>FooBatch</group>   
  41.             <description>无trigger的Job</description>   
  42.             <job-class>xxx.yyy.barJob</job-class>   
  43.             <volatility>false</volatility>   
  44.             <durability>true</durability>   
  45.             <recover>false</recover>   
  46.         </job>   
  47.     </schedule>       
  48. </job-scheduling-data>  
<?xml version="1.0" encoding="UTF-8"?>
<job-scheduling-data xmlns="http://www.quartz-scheduler.org/xml/JobSchedulingData"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://www.quartz-scheduler.org/xml/JobSchedulingData http://www.quartz-scheduler.org/xml/job_scheduling_data_1_8.xsd"
    version="1.8">
    
    <pre-processing-commands>
        <delete-jobs-in-group>*</delete-jobs-in-group>  <!-- clear all jobs in scheduler -->
        <delete-triggers-in-group>*</delete-triggers-in-group> <!-- clear all triggers in scheduler -->
    </pre-processing-commands>
    
    <processing-directives>
        <overwrite-existing-data>true</overwrite-existing-data>
        <ignore-duplicates>false</ignore-duplicates> 
    </processing-directives>
    
    <schedule>
	    <job>
	        <name>FooJob</name>
            <group>FooBatch</group>
            <description>定时运行Job</description>
	        <job-class>xxx.yyy.FooJob</job-class>
	        <volatility>false</volatility>
            <durability>true</durability>
            <recover>false</recover>
	    </job>
	    <trigger>
	        <cron>
	            <name>FooTrigger</name>
	            <group>FooBatch</group>
	            <job-name>FooJob</job-name>
	            <job-group>FooBatch</job-group>
                <misfire-instruction>MISFIRE_INSTRUCTION_FIRE_ONCE_NOW</misfire-instruction>
	            <cron-expression>30/15 * 13 * * ?</cron-expression>
                <!-- 秒 分 时 日 月 星期 年 -->
	        </cron>
	    </trigger>
	    <job>
	        <name>barJob</name>
            <group>FooBatch</group>
            <description>无trigger的Job</description>
	        <job-class>xxx.yyy.barJob</job-class>
	        <volatility>false</volatility>
            <durability>true</durability>
            <recover>false</recover>
	    </job>
    </schedule>    
</job-scheduling-data>

 

        与J2ee容器结合，提供QuartzInitializerListener，可设定随容器自动启动，这个很方便

Java代码  复制代码  收藏代码
  1. <?xml version="1.0" encoding="UTF-8"?>   
  2. <web-app xmlns="http://java.sun.com/xml/ns/j2ee"  
  3.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.4"  
  4.     xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee    
  5.     http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">   
  6.   
  7.   <display-name>Foo Batch</display-name>   
  8.   
  9.   <context-param>   
  10.     <param-name>quartz:config-file</param-name>   
  11.     <param-value>/quartz.properties</param-value>   
  12.   </context-param>   
  13.   
  14.   <listener>   
  15.     <listener-class>   
  16.        org.quartz.ee.servlet.QuartzInitializerListener   
  17.     </listener-class>   
  18.   </listener>   
  19.   
  20.   </web-app>  
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://java.sun.com/xml/ns/j2ee"
	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" version="2.4"
	xsi:schemaLocation="http://java.sun.com/xml/ns/j2ee 
	http://java.sun.com/xml/ns/j2ee/web-app_2_4.xsd">

  <display-name>Foo Batch</display-name>

  <context-param>
    <param-name>quartz:config-file</param-name>
    <param-value>/quartz.properties</param-value>
  </context-param>

  <listener>
    <listener-class>
       org.quartz.ee.servlet.QuartzInitializerListener
    </listener-class>
  </listener>

  </web-app>

 

 

  2.Job、Trigger、Listener

        Job需要由Trigger启动，可以有多个Listener

        Trigger同样可以有多个Listener

 

  3.有待改进的地方

       Trigger不完善，只提供了“定时”Trigger，其他诸如基于Job完成与否或完成状态的Trigger需要自己靠Listener实现。

       配置不完善，配置文件只提供全局Listener定义，针对Job或Trigger的Listener要程序添加，另外1.8版本在配置无Trigger的Job时有bug(XMLSchedulingDataProcessor 1015行需要nullcheck)，直接导致xml解析错误，感觉这自带的plugin还很简陋。

       plugin和Job同级别 ，（这个说法有点偏颇，但是产生的效果类似）这意味着在schedule启动前是不会解析配置文件的，只能在启动后调整Job等等内容，同时scheduler.getJobDetail取的Job是通过clone方式取得的，任何对Job的修改都无效...这个很无语 （clone的方式还是有道理的，已经设置好的Job不能随便改动）

Java代码  复制代码  收藏代码
  1. scheduler.start(); //启动后读取配置文件等等   
  2.   
  3. JobDetail fooJob = scheduler.getJobDetail("FooJob",   
  4.         "FooBatch");   
  5.   
  6. fooJob.addJobListener(someListener);   
  7.   
  8. //取Job对应的Trigger   
  9. Trigger[] triggers = scheduler.getTriggersOfJob(fooJob.getName(),   
  10.         fooJob.getGroup());   
  11.   
  12. scheduler.addJob(fooJob, true); //true指明替换已有Job（没有关联Trigger）   
  13.   
  14. //清除旧Trigger，重新建立Job和Trigger关联   
  15. for (Trigger trigger : triggers) {   
  16.     scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger);   
  17. }   
scheduler.start(); //启动后读取配置文件等等

JobDetail fooJob = scheduler.getJobDetail("FooJob",
        "FooBatch");

fooJob.addJobListener(someListener);

//取Job对应的Trigger
Trigger[] triggers = scheduler.getTriggersOfJob(fooJob.getName(),
        fooJob.getGroup());

scheduler.addJob(fooJob, true); //true指明替换已有Job（没有关联Trigger）

//清除旧Trigger，重新建立Job和Trigger关联
for (Trigger trigger : triggers) {
    scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger);
}

 


本文转自茄子_2008博客园博客，原文链接：http://www.cnblogs.com/xd502djj/archive/2012/03/23/2413502.html，如需转载请自行联系原作者。

文章标签：
数据格式
XML
Java
容器
开发框架
长征2号
目录
相关文章
hnrk7epeorhrk
|
9月前
|
数据建模
技术经验解读：ZVS振荡电路工作原理分析
技术经验解读：ZVS振荡电路工作原理分析
hnrk7epeorhrk
133 1
67vpym2vvkfhs
|
9月前
|
数据建模 程序员
程序员必知：ZVS振荡电路工作原理分析
程序员必知：ZVS振荡电路工作原理分析
67vpym2vvkfhs
115 1
gswnlrt2j7wj6
|
8月前
|
搜索推荐 算法 网络协议
如何做好IT类的技术面试？
如何做好IT类的技术面试？
gswnlrt2j7wj6
80 0
和你一起去月球
|
10月前
|
前端开发 JavaScript 程序员
如何做好IT类的技术面试
如何做好IT类的技术面试
和你一起去月球
147 0
全栈技术精选
|
前端开发 NoSQL 数据库
项目重点知识点详解
项目重点知识点详解
全栈技术精选
97 2
我是廖志伟
|
XML Java 数据库连接
Spring框架：第一章：介绍和准备工作
Spring框架：第一章：介绍和准备工作
我是廖志伟
112 0
Spring框架：第一章：介绍和准备工作
石云升
|
前端开发 测试技术
如何做好项目转测？
需求功能都做完了，并且通过了自测，就可以转测试了。
石云升
452 0
如何做好项目转测？
技术君
|
消息中间件 监控 算法
分布式定时任务框架选型，写得太好了！
为什么我们需要定时任务 我们先思考下面几个业务场景的解决方案:
技术君
562 0
分布式定时任务框架选型，写得太好了！
阿里云云原生
|
新零售 移动开发 人工智能
程序员写好技术文章的几点小技巧
去年成为了内网技术分享平台的年度作者，受邀写一篇关于“如何写好文章”的文章。我本身并不喜欢写字，去年写的几篇文章，涉及的话题自带流量，所以阅读量多了一些，谈不上有多擅长。不过还是决定分享一下自己在写文章时用到的一些小技巧，希望对大家有帮助。
阿里云云原生
7461 0
程序员写好技术文章的几点小技巧
狂师
|
数据挖掘
如何做好项目总结
每次项目排期时间紧张？项目发版时间总是一延再延？每个版本bug数量堆积成山？测试期间各种bug总是层出不穷？临近上线发现严重bug？如果你总是被这些问题围绕，那么项目总结执行迫在眉睫。那么如何进行项目总结呢？ 一、思维模式 想做好一份项目总结，总结人员必须具备一定的结构化思维，对问题、数据进行结构分析，且能够通过结构化思维表达出来。
狂师
1539 0

热门文章

最新文章

  • 1
    域名ICP备案时网站备注到底该怎么写？全网最全教程来了
  • 2
    网络安全-反弹shell详解（攻击，检测与防御）
  • 3
    上海ACE同城会演讲实录|云原生分布式数据库PolarDB-X
  • 4
    4.[研磨设计模式笔记]适配器模式
  • 5
    ORA-12514: TNS: 监听程序当前无法识别连接描述符中请求的服务
  • 6
    基于Windows 7中的 Ribbon开发技术应用
  • 7
    LVS+keepalived负载均衡兼高可用集群配置
  • 8
    移动应用图片的福音--七牛云存储
  • 9
    oracle与sql server大批量存储过程可以替换部分
  • 10
    lxde 桌面环境使用compiz-gtk
  • 1
    阿里云认证全新发布【Apsara Clouder云计算专项技能认证：云服务器ECS入门】
    13
  • 2
    阿里云云计算ACA、大数据ACA、人工智能ACA三门认证升级调整公告
    12
  • 3
    阿里云新版ACE考试通关经历回顾
    13
  • 4
    算法系列之排序算法-堆排序
    15
  • 5
    认证故事|阿里云新版ACE全球第五人考试经历回顾
    11
  • 6
    阿里云新版ACE考试通关经历回顾
    25
  • 7
    2024阿里云天池大学生竞赛正式开赛，全网招募高校最强大脑！
    12
  • 8
    「阿里云认证」年度标杆企业奖揭晓
    12
  • 9
    对话阿里云CIO蒋林泉：AI时代，企业如何做好智能化系统建设？
    12
  • 10
    基于惯性加权PSO优化的目标函数最小值求解matlab仿真
    12

    • 相关课程

    更多
  • Java面试疑难点解析 - 系统架构及项目设计
  • 大数据Spark2020版（知识精讲与实战演练）第四阶段
  • 大数据Spark2020最新课程（知识精讲与实战演练）第二阶段
  • Oozie知识精讲与实战演练

    • 相关电子书

    更多
  • 中移苏研存储产品规划和实践经验分享
  • 中移苏研-存储产品规划和实践经验分享
  • 云栖专家带你技术进阶之理解Java内存管理机制
    • 下一篇
    通义万相：视觉生成大模型再进化