碼上歡樂
相關內容    簡體    繁體

總結幾點Quartz的經驗

本文轉載自   查看原文   2012-03-23 13:27   8245    Java/ quartz

總結一下經典的定時處理框架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);
}

 

 

摘自http://foxswily.iteye.com/blog/683007 


免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。



猜您在找 公司做項目的幾點經驗總結（個人經驗） 基於RabbitMQ使用的幾點實踐經驗總結 面試經驗總結：注意這幾點，面試通過率上漲30% 深度學習中網絡設計的幾點經驗 切圖工具優化的幾點總結 工作的思考八：帶新人的幾點總結 Grid++Report的幾點總結 Quartz.NET 2.0 學習筆記(2) ：和1.0的幾點不同 Quartz使用總結 Quartz使用記錄總結
 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM