【spring配置】——spring整合Quartz定時器

時間  2019-11-20
標籤 spring配置 spring 整合 quartz 定時器 欄目 Spring 简体版
原文   原文鏈接

第一種：爲普通java類中的某個方法配置跑批任務

[java] view plain copy
  1. MethodInvokingJobDetailFactoryBean  
  2. CronTriggerBean  
  3. SchedulerFactoryBean  

1.定義要跑批的類和方法：

[java] view plain copy
  1. package com.xy.utils.quartz;  
  2.   
  3. import org.joda.time.DateTime;  
  4. import org.slf4j.Logger;  
  5. import org.slf4j.LoggerFactory;  
  6.   
  7. /** 
  8.  * 測試定時器類 
  9.  * @author javaw 
  10.  * 
  11.  */  
  12. public class TestQuartz {  
  13.         
  14.        public static Logger logger = LoggerFactory.getLogger(TestQuartz.class);    
  15.        public void TestMethod(){  
  16.             logger.info("Auto Execute TestMethod start! Date={}" ,new DateTime().toString("YYYY-MM-DD HH:mm:ss" ));  
  17.             logger.info("**********測試跑批類************");  
  18.             logger.info("Auto Execute TestMethod end! Date={}" ,new DateTime().toString("YYYY-MM-DD HH:mm:ss" ));  
  19.       }  
  20. }  

2.配置Spring定時器讓quartz自動執行testMethod方法:

 

[html] view plain copy
  1. <!-- 實例化bean -->  
  2. <bean id= "testMethodQuartz" class ="com.xy.utils.quartz.TestQuartz"/>  
  3.   
  4. <!-- 配置MethodInvokingJobDetailFactoryBean -->  
  5. <bean id= "testTaskMethod"  
  6. class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  
  7.        <property name="targetObject" ref="testMethodQuartz"/>  
  8.        <property name="targetMethod" value="TestMethod"/>  
  9.        <property name="concurrent" value="false"/>  
  10. </bean>  
  11.   
  12. <!-- 配置定時表達式 -->  
  13. <bean id= "testTaskTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean" >  
  14.        <property name="jobDetail" ref="testTaskMethod" />   
  15.       <!-- 每一分鐘執行一次 -->   
  16.       <property name="cronExpression" value="0 0/1 * * * ?" />   
  17. </bean>  
  18.   
  19. <!-- 配置調度工廠 -->  
  20. <bean id= "testSchedulerFactoryBean"  
  21.     class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
  22.        <property name="triggers" >  
  23.              <list>  
  24.                    <ref bean="testTaskTrigger" />  
  25.              </list>  
  26.        </property>  
  27. </bean>  

3.寫測試方法進行調用(不用啓動tomcat):

[java] view plain copy
  1. public static void main(String[] args) {  
  2.       SchedulerFactoryBean schedulerFactoryBean = (SchedulerFactoryBean) SpringUtilsFromClassPathXml.getBean( "testSchedulerFactoryBean");  
  3.              //啓動調度器  
  4.       schedulerFactoryBean.start();  
  5. }  

第二種：爲繼承QuartzJobBean的java類配置跑批任務

1.寫java類繼承QuartzJobBean，重寫executeInternal 方法:

[java] view plain copy
  1. package com.xy.utils.quartz;  
  2.   
  3. import org.joda.time.DateTime;  
  4. import org.quartz.JobExecutionContext;  
  5. import org.quartz.JobExecutionException;  
  6. import org.slf4j.Logger;  
  7. import org.slf4j.LoggerFactory;  
  8. import org.springframework.scheduling.quartz.QuartzJobBean;  
  9. import org.springframework.scheduling.quartz.SchedulerFactoryBean;  
  10.   
  11. /** 
  12.  * 測試繼承QuartzJobBean的java類配置定時器 
  13.  * @author javaw 
  14.  * 
  15.  */  
  16. public class TestQuartzExtendsJobBean extends QuartzJobBean{  
  17.         
  18.        private static Logger logger = LoggerFactory.getLogger(TestQuartzExtendsJobBean. class);  
  19.         
  20.        @Override  
  21.        protected void executeInternal(JobExecutionContext context)  
  22.                    throws JobExecutionException {  
  23.             logger.info("Auto Execute TestQuartzExtendsJobBean start! Date={}",new DateTime().toString( "YYYY-MM-DD HH:mm:ss"));  
  24.             logger.info("**********"+content.getMergedJobDataMap().get("descString")+"************");  
  25.             logger.info("Auto Execute TestQuartzExtendsJobBean end! Date={}",new DateTime().toString( "YYYY-MM-DD HH:mm:ss"));  
  26.       }  
  27. }  

2.配置文件：

[html] view plain copy
  1. <!--  
  2.       第二種：爲繼承Quartz的java類實現跑批  
  3.       **********1.JobDetailBean  
  4.       **********2.CronTriggerBean  
  5.       **********3.SchedulerFactoryBean  
  6.  -->  
  7. <bean id= "testJobDetailBean"  
  8.      class="org.springframework.scheduling.quartz.JobDetailBean">     
  9.       <property name="name" value="exampleJob" />     
  10.       <property name="jobClass"  
  11.           value="com.xy.utils.quartz.TestQuartzExtendsJobBean"/>  
  12.       <!-- 能夠封裝各類數據到JobExecutionContext裏 -->     
  13.       <property name="jobDataAsMap">    
  14.        <map>    
  15.          <entry key="descString" value="測試跑批"/>  
  16.        </map>    
  17.      </property>    
  18.   </bean >   
  19.    
  20. <bean id= "testTaskTrigger"  
  21.      class="org.springframework.scheduling.quartz.CronTriggerBean">  
  22.        <property name="jobDetail" ref="testJobDetailBean" />   
  23.       <property name="cronExpression" value="0 0/1 * * * ?" />   
  24. </bean>  
  25.   
  26. <bean id= "testSchedulerFactoryBean"  
  27.     class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
  28.        <property name="triggers" >  
  29.              <list>  
  30.                    <ref bean="testTaskTrigger" />  
  31.              </list>  
  32.        </property>  
  33. </bean>  

第三種：定時任務持久化(JobDetailTx)

優點：

集羣部署定時器經過故障切換和負載均衡的功能，提升調度器的可用性和擴展性。
html

本質：

集羣上的全部節點經過共享一個數據庫來來工做的。全部節點quartz經過啓動兩個維護線程來維護數據庫狀態實現集羣管理，一個是檢測節點狀態線程，一個是恢復任務線程。一個 Quartz 集羣中的每一個節點是一個獨立的 Quartz 應用，它又管理着其餘的節點。java

模式：

1.獲取任務

負載均衡是自動完成的，集羣的每一個節點會盡快觸發任務。當第一個節點獲取到任務，會經過鎖定，阻止其餘線程獲取到該任務。web

2.故障切換

當一個節點執行任務失敗(服務down掉或其餘緣由)，其餘節點會檢測到並標識在失敗節點上正在執行的數據庫中的任務。任何標記爲可恢復(任務詳細裏的requests recovery屬性)的任務都會被其餘節點繼續執行。沒有標記可恢復的任務會被釋放掉。spring

[sql] view plain copy
  1. CREATE TABLE qrtz_job_details  
  2.   (  
  3.   ....  
  4.   JOB_NAME VARCHAR2(80) NOT NULL,  
  5.   JOB_GROUP VARCHAR2(80) NOT NULL,  
  6.   REQUESTS_RECOVERY VARCHAR2(1) NOT NULL, --可恢復標記  
  7.   );  


[html] view plain copy
  1. SchedulerFactoryBean  
  2. JobDetail  
  3. Trigger  
  4. Job  

將定時任務持久化能夠解決分佈式跑批的問題，避免服務器重啓信息丟失。sql

定時任務定義須要實例化JobDetail和Trigger，而後使用Scheduler進行調度。這個須要使用到Quartz的jar包。數據庫

每一個jar包建立任務的方式都不相同。具體須要查看官方api。api

quartz2.2.1中給出的示例：tomcat

[java] view plain copy
  1. JobDetail job = newJob(MyJob.class)  
  2.              .withIdentity("myJob")  
  3.              .build();  
  4.                
  5. Trigger trigger = newTrigger()   
  6.              .withIdentity(triggerKey("myTrigger", "myTriggerGroup"))  
  7.              .withSchedule(simpleSchedule()  
  8.                  .withIntervalInHours(1)  
  9.                  .repeatForever())  
  10.              .startAt(futureDate(10, MINUTES))  
  11.              .build();  
  12.            
  13. scheduler.scheduleJob(job, trigger);  

導入jar包後，寫以下測試類：服務器

[java] view plain copy
  1. package com.xy.utils.scheduler;  
  2.   
  3. import org.quartz.JobBuilder;  
  4. import org.quartz.JobDetail;  
  5. import org.quartz.Scheduler;  
  6. import org.quartz.SchedulerFactory;  
  7. import org.quartz.SimpleScheduleBuilder;  
  8. import org.quartz.Trigger;  
  9. import org.quartz.TriggerBuilder;  
  10. import org.quartz.impl.StdSchedulerFactory;  
  11.   
  12. public class quartzTest {  
  13.   
  14.     public static void main(String args[]) throws Exception {  
  15.         JobDetail jobDetail= JobBuilder.newJob(TestJob.class)  
  16.                 .withIdentity("job","group")  
  17.                 .build();  
  18.    
  19.         Trigger trigger= TriggerBuilder.newTrigger().withIdentity("job","group").startNow().withSchedule(  
  20.                 SimpleScheduleBuilder.simpleSchedule()  
  21.                         .withIntervalInSeconds(10)   //時間間隔  
  22.                         .withRepeatCount(10)        //重複次數n+1  
  23.                         )  
  24.                 .build();  
  25.         SchedulerFactory sf = new StdSchedulerFactory();  
  26.         Scheduler sched = sf.getScheduler();  
  27.         sched.scheduleJob(jobDetail, trigger);  
  28.           
  29.         sched.start();  
  30.     }  
  31. }  

定時執行的任務類：app

[java] view plain copy
  1. package com.xy.utils.scheduler;  
  2.   
  3. import org.quartz.Job;  
  4. import org.quartz.JobExecutionContext;  
  5. import org.quartz.JobExecutionException;  
  6.   
  7. public class TestJob implements Job {  
  8.     public void execute(JobExecutionContext arg0) throws JobExecutionException {  
  9.         System.out.println("*****執行批處理任務******");  
  10.     }  
  11. }  

這種任務並無持久化到數據庫中。

在Spring中配置SchedulerFactoryBean：

[html] view plain copy
  1. <!--   
  2. 第三種：從數據庫中讀取跑批任務(適合集羣部署跑批)  
  3. **********1.SchedulerFactoryBean  
  4. -->  
  5. <bean id="schedulerBeanFactory" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  
  6. <!-- 注入數據源，包含任務執行表 -->  
  7. <property name="dataSource" ref="dataSource"/>  
  8. <!--applicationContextSchedulerContextKey：   
  9.     把spring上下文以key/value的方式存放在了quartz的上下文中了，  
  10.     能夠用applicationContextSchedulerContextKey所定義的key獲得對應的spring上下文-->    
  11. <property name="applicationContextSchedulerContextKey" value="applicationContext"/>     
  12. <!-- 讀取配置文件 -->  
  13. <property name="configLocation" value="classpath:/properties/quartz.properties"/>  
  14. <property name="autoStartup" value="true"/>  
  15. </bean>  

配置quartz.properties:

下載了quartz.jar後，在\quartz-2.2.1\src\org\quartz\目錄下有個quartz.properties的文件，能夠根據本身的須要更改其中的配置內容。

[plain] view plain copy
  1. #批處理常量表 QUARTZ2.2.1  
  2. #============================================================================  
  3. # Configure Main Scheduler Properties  
  4. #============================================================================  
  5. org.quartz.scheduler.instanceName = MyQuartzScheduler  
  6. org.quartz.scheduler.instanceId = AUTO  
  7. #============================================================================  
  8. # Configure ThreadPool  
  9. #============================================================================  
  10. org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool  
  11. org.quartz.threadPool.threadCount = 10  
  12. org.quartz.threadPool.threadPriority = 5  
  13. org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread:true  
  14. #============================================================================  
  15. # Configure JobStore  
  16. #============================================================================  
  17. org.quartz.jobStore.misfireThreshold = 10000  
  18. org.quartz.jobStore.class = org.springframework.scheduling.quartz.LocalDataSourceJobStore  
  19. org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
  20. org.quartz.jobStore.isClustered = true --是否集羣部署  
  21. #任務表前綴  
  22. org.quartz.jobStore.tablePrefix = test_qrtz_  

建立任務表：

jar包文件中，給出了全部數據庫的建表語句。能夠根據給出的sql語句建立表。

調度類：

[java] view plain copy
  1. package com.xy.utils.scheduler;  
  2.   
  3. import org.quartz.JobBuilder;  
  4. import org.quartz.JobDetail;  
  5. import org.quartz.Scheduler;  
  6. import org.quartz.SimpleScheduleBuilder;  
  7. import org.quartz.Trigger;  
  8. import org.quartz.TriggerBuilder;  
  9.   
  10. import com.xy.utils.SpringUtils.SpringUtilsFromClassPathXml;  
  11.   
  12. public class quartzTest {  
  13.     //從Spring中獲取調度bean工廠  
  14.     public static Scheduler scheduler = (Scheduler)SpringUtilsFromClassPathXml.getBean("schedulerBeanFactory");  
  15.       
  16.     public static void main(String args[]) throws Exception {  
  17.         JobDetail jobDetail= JobBuilder.newJob(TestJob.class)  
  18.                 .withIdentity("job","group")  
  19.                 .build();  
  20.    
  21.         Trigger trigger= TriggerBuilder.newTrigger().withIdentity("job","group").startNow().withSchedule(  
  22.                 SimpleScheduleBuilder.simpleSchedule()  
  23.                         .withIntervalInSeconds(10) //時間間隔  
  24.                         .repeatForever()  
  25.                         )  
  26.                 .build();  
  27.         scheduler.scheduleJob(jobDetail, trigger);  
  28.         scheduler.start();  
  29.     }  
  30. }  

任務類（須要實現job接口）：

[java] view plain copy
  1. package com.xy.utils.scheduler;  
  2.   
  3. import org.quartz.Job;  
  4. import org.quartz.JobExecutionContext;  
  5. import org.quartz.JobExecutionException;  
  6.   
  7. public class TestJob implements Job {  
  8.     public void execute(JobExecutionContext arg0) throws JobExecutionException {  
  9.         System.out.println("*****執行批處理任務******");  
  10.     }  
  11. }  

此時執行該類就會將任務數據寫入數據庫中。


調度任務工具類：

自定義任務調度工具類：

[java] view plain copy
  1. package com.xy.utils.scheduler;  
  2.   
  3. import java.text.ParseException;  
  4. import java.text.SimpleDateFormat;  
  5. import java.util.Date;  
  6.   
  7. import org.quartz.CronScheduleBuilder;  
  8. import org.quartz.CronTrigger;  
  9. import org.quartz.DateBuilder;  
  10. import org.quartz.Job;  
  11. import org.quartz.JobBuilder;  
  12. import org.quartz.JobDetail;  
  13. import org.quartz.Scheduler;  
  14. import org.quartz.SchedulerException;  
  15. import org.quartz.SimpleScheduleBuilder;  
  16. import org.quartz.Trigger;  
  17. import org.quartz.TriggerBuilder;  
  18. import org.quartz.TriggerKey;  
  19. import org.quartz.DateBuilder.IntervalUnit;  
  20. import org.slf4j.Logger;  
  21. import org.slf4j.LoggerFactory;  
  22.   
  23. import com.xy.common.SysContent;  
  24.   
  25. public class SchedulerJobUtils {  
  26.     private static Logger logger = LoggerFactory.getLogger(SchedulerJobUtils.class);  
  27.       
  28.     public static Scheduler scheduler = (Scheduler)SysContent.applicationContext.getBean("schedulerBeanFactory");  
  29.     //public static Scheduler scheduler = (Scheduler)SpringUtilsFromClassPathXml.getBean("schedulerBeanFactory");  
  30.     public static String dateFormate = "ss mm HH dd MM ? yyyy";  
  31.     public static SimpleDateFormat cronSdf = new SimpleDateFormat(dateFormate);  
  32.     public static SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
  33.       
  34.     /** 
  35.      * 數據庫放入一個指定時間的任務，任務只執行一次 
  36.      * @see 適合對數據進行定時刪除，修改等等 
  37.      * @param <T> 
  38.      * @param clazz  要執行任務類class，任務類必須繼承Job類 
  39.      * @param jobName 任務名稱 
  40.      * @param groupName 分組名稱 
  41.      * @param executeTime 執行時間，格式:yyyy-MM-dd HH:mm:ss 
  42.      * @return 
  43.      */  
  44.     public static<T> boolean putSpecifyTimeSchedulerJobToDB(Class<? extends Job> clazz,String jobName,String groupName,String executeTime){  
  45.         //定義一個job  
  46.         JobDetail job = JobBuilder.newJob(clazz).withIdentity(jobName, groupName).build();  
  47.         //定義一個TriggerKey  
  48.         TriggerKey triggerKey = TriggerKey.triggerKey(jobName, groupName);  
  49.           
  50.         SchedulerJob schedulerJob = new SchedulerJob();  
  51.         schedulerJob.setJobName(jobName);  
  52.         schedulerJob.setGroupName(groupName);  
  53.         job.getJobDataMap().put("schedulerJob", schedulerJob);  
  54.           
  55.         Date executeDate = null;  
  56.           
  57.         try {  
  58.             executeDate = sdf.parse(executeTime);  
  59.         } catch (ParseException e) {  
  60.             logger.info("method putSchedulerJobToDB execute error!exception={}",e);  
  61.         }  
  62.         String dbExecuteTime = cronSdf.format(executeDate);  
  63.         CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity(triggerKey).withSchedule(CronScheduleBuilder.cronSchedule(dbExecuteTime)).build();  
  64.           
  65.         try {  
  66.             scheduler.scheduleJob(job, cronTrigger);  
  67.         } catch (SchedulerException e) {  
  68.             logger.info("method putSchedulerJobToDB execute error!exception={}",e);  
  69.         }  
  70.         return true;  
  71.     }  
  72.       
  73.     /** 
  74.      * 數據庫放入一條指定開始時間，指定間隔時間，指定次數的任務 
  75.      * @param <T>  
  76.      * @param clazz 任務類 
  77.      * @param jobName  任務名 
  78.      * @param groupName 分組名 
  79.      * @param seconds   間隔時間，以秒爲單位 
  80.      * @param count 執行次數，0爲一直執行 
  81.      * @param startSecondsToNow 開始時間(距離如今?秒) 
  82.      * @return 
  83.      * @throws SchedulerException  
  84.      */  
  85.     @SuppressWarnings("unchecked")  
  86.     public static<T> boolean putPeriodSchedulerJobToDB(Class<? extends Job> clazz,String jobName,String groupName,  
  87.             int seconds,int count,int startSecondsToNow){  
  88.         JobDetail jobDetail= JobBuilder.newJob(clazz).withIdentity(jobName,groupName).build();  
  89.         TriggerBuilder triggerBuilder = TriggerBuilder.newTrigger().withIdentity(jobName,groupName);  
  90.         if(startSecondsToNow==0){  
  91.             triggerBuilder.startNow();  
  92.         }else{  
  93.             triggerBuilder.startAt(DateBuilder.futureDate(startSecondsToNow,IntervalUnit.SECOND));  
  94.         }  
  95.         SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(seconds);  
  96.         if(count==0){  
  97.             scheduleBuilder.repeatForever();  
  98.         }else{  
  99.             scheduleBuilder.withRepeatCount(count);  
  100.         }  
  101.         Trigger trigger = triggerBuilder.withSchedule(scheduleBuilder).build();  
  102.         try {  
  103.             scheduler.scheduleJob(jobDetail,trigger);  
  104.         } catch (SchedulerException e) {  
  105.             logger.info("put putPeriodSchedulerJobToDB error,error={}",e);  
  106.         }  
  107.         return true;  
  108.     }  
  109. }  

任務類：

[java] view plain copy
  1. package com.xy.utils.scheduler;  
  2.   
  3. import org.joda.time.DateTime;  
  4. import org.quartz.Job;  
  5. import org.quartz.JobExecutionContext;  
  6. import org.quartz.JobExecutionException;  
  7. import org.slf4j.Logger;  
  8. import org.slf4j.LoggerFactory;  
  9.   
  10. public class TestSchedulerTask implements Job{  
  11.     private static Logger logger = LoggerFactory.getLogger(TestSchedulerTask.class);  
  12.   
  13.     public void execute(JobExecutionContext context) throws JobExecutionException {  
  14.         logger.info("**********TestSchedulerTask1 start at={}",new DateTime().toString("yyyy-MM-dd HH:mm:ss"));  
  15.         logger.info("**********I'm Ok!************");  
  16.         logger.info("**********TestSchedulerTask1 end at={}",new DateTime().toString("yyyy-MM-dd HH:mm:ss"));  
  17.     }  
  18.       
  19.     /** 
  20.      * 調度任務工具類測試 
  21.      * 10秒執行一次，無限次數，30秒後開始 
  22.      * @param args 
  23.      */  
  24.     public static void main(String[] args) {  
  25.         System.out.println(SchedulerJobUtils.putPeriodSchedulerJobToDB(TestSchedulerTask.class, "myJob", "myGroup", 10, 0, 30));  
  26.     }  
  27. }  

數據庫裏的任務表：


打印出的日誌：
2016-01-10 00:37:34,810  INFO TestSchedulerTask1:14 - **********TestSchedulerTask1 start at=2016-01-10 00:37:34
2016-01-10 00:37:34,810  INFO TestSchedulerTask1:15 - **********I'm Ok!************
2016-01-10 00:37:34,811  INFO TestSchedulerTask1:16 - **********TestSchedulerTask1 end at=2016-01-10 00:37:34

2016-01-10 00:37:44,690  INFO TestSchedulerTask1:14 - **********TestSchedulerTask1 start at=2016-01-10 00:37:44
2016-01-10 00:37:44,691  INFO TestSchedulerTask1:15 - **********I'm Ok!************
2016-01-10 00:37:44,691  INFO TestSchedulerTask1:16 - **********TestSchedulerTask1 end at=2016-01-10 00:37:44

2016-01-10 00:37:54,697  INFO TestSchedulerTask1:14 - **********TestSchedulerTask1 start at=2016-01-10 00:37:54
2016-01-10 00:37:54,697  INFO TestSchedulerTask1:15 - **********I'm Ok!************
2016-01-10 00:37:54,697  INFO TestSchedulerTask1:16 - **********TestSchedulerTask1 end at=2016-01-10 00:37:54

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程