quarz

第1章Quartz任務調度框架

1.1Quarz任務調度框架的使用

1.1.1Quartz是什麼?

     1.     作什麼事情 ; job 任務  

     2.     什麼時間作 ; trigger 觸發 器

1.1.2觸發器

1.SimpleTrigger:每隔一段時間執行,和日曆無關; eg:從如今開始執行一個任務,每隔1分鐘循環執行

2. CronTrigger:在固定時間執行,日曆/日期有關 eg:每週一凌晨2點執行一個任務

 週一-週五天天8:50上課

 

   秒分時日月星期

   0 50 8 ? * 2/6

   

   天天晚上6:30

   秒分時日月星期

   0 30 18 * * ?

 

?:不指定

*:任意

注意:

 1.?只能用在日期(4)和星期(6)

 2.知足上面條件後,?不一樣同時使用,星期與日期必須指定一個,另一個用?

 3.*也不一樣同時放在日期(4)和日期(6)

1.1.3Quartz應用場景

Quartz是一個任務調度框架。好比你遇到這樣的問題

想每個月25號，信用卡自動還款

想每一年4月1日本身給當年暗戀女神發一封匿名賀卡

想每隔1小時，備份一下本身的學習筆記到雲盤

這些問題總結起來就是：在某一個有規律的時間點幹某件事。而且時間的觸發的條件能夠很是複雜（好比每個月最後一個工做日的17:50），複雜到須要一個專門的框架來幹這個事。 Quartz就是來幹這樣的事，你給它一個觸發條件的定義，它負責到了時間點，觸發相應的Job起來幹活。

 

1.2Quartz下載及環境配置

1.2.1下載地址:

 http://www.quartz-scheduler.org/

1.2.2環境配置

即jar包導入

<dependency>     <groupId>org.quartz-scheduler</groupId>     <artifactId>quartz</artifactId>     <version>2.2.1</version> </dependency> <dependency>     <groupId>org.quartz-scheduler</groupId>     <artifactId>quartz-jobs</artifactId>     <version>2.2.1</version> </dependency>

1.3Quartz快速入門

1.3.1建立maven項目（jar）1.3.2          導入maven座標

<dependencies>      <dependency>         <groupId>org.quartz-scheduler</groupId>         <artifactId>quartz</artifactId>         <version>2.2.1</version>      </dependency>      <dependency>         <groupId>org.quartz-scheduler</groupId>         <artifactId>quartz-jobs</artifactId>         <version>2.2.1</version>      </dependency>      <dependency>        <groupId>org.slf4j</groupId>         <artifactId>slf4j-log4j12</artifactId>         <version>1.7.12</version>      </dependency>    </dependencies>

 

1.3.3編寫Job工做對象類代碼

package cn.peihua.test; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException;   publicclass JobDemo implements Job {      publicvoid execute(JobExecutionContext context) throws JobExecutionException {         System.out.println("Hell,quarz!!!");    } }

 

1.3.4簡單代碼實例

建立job工做任務

1.3.4.1       案例1:SimpleTrigger 使用

每隔特定的時間間隔進行執行

 

package cn.peihua.test; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SimpleScheduleBuilder; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.impl.StdSchedulerFactory;   publicclass Demo2 {     publicstaticvoid main(String[] args) throws SchedulerException {         /*******建立定時器對象*******/         Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();           /*******定義工做對象*******/         JobDetail jobDetail = JobBuilder.newJob()                 .withIdentity("job1", "group1") //用於身份識別,給個名字和分組                 .build();                 /*******建立觸發器*******/         Trigger trigger = TriggerBuilder.newTrigger()                 .withIdentity("trigger1", "group1")                 .startNow()     //當即開始運行                  //設置將用於定義的ScheduleBuilder  觸發器的時間表。                 .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(5))                 .build();           /**將給定的JobDetail添加到調度程序，並將給定的觸發器與它關聯**/         scheduler.scheduleJob(jobDetail, trigger);                 /*******開啓定時任務*******/         scheduler.start();     } }

對象 TriggerBuilder 啓動任務時間

startNow 當即啓動

startAt (Date) 指定時間啓動

對象 SimpleScheduleBuilder 進行簡單任務重複執行

repeatSecondly …() 多少秒後重復執行

repeatminutely …() 多少分鐘後重復執行

repeatHourly …() 多少小時後重複執行

1.3.4.2       案例2:CronTrigger 的使用

像日曆那樣按日程執行,好比下個月的幾號開始執行

　　corn從左到右（用空格隔開）：秒 分 小時 月份中的日期 月份 星期中的日期 年份

1.3.4.3       各字段的含義

注意事項：

每個域都使用數字，但還能夠出現以下特殊字符，它們的含義是：

　　（1）*：表示匹配該域的任意值。假如在Minutes域使用*, 即表示每分鐘都會觸發事件。

　　（2）?：只能用在DayofMonth和DayofWeek兩個域。它也匹配域的任意值，但實際不會。由於DayofMonth和DayofWeek會相互影響。例如想在每個月的20日觸發調度，無論20日究竟是星期幾，則只能使用以下寫法： 13 13 15 20 * ?, 其中最後一位只能用？，而不能使用*，若是使用*表示無論星期幾都會觸發，實際上並非這樣。

　　（3）-：表示範圍。例如在Minutes域使用5-20，表示從5分到20分鐘每分鐘觸發一次

　　（4）/：表示起始時間開始觸發，而後每隔固定時間觸發一次。例如在Minutes域使用5/20,則意味着5分鐘觸發一次，而25，45等分別觸發一次.

　　（5）,：表示列出枚舉值。例如：在Minutes域使用5,20，則意味着在5和20分每分鐘觸發一次。

　　（6）L：表示最後，只能出如今DayofWeek和DayofMonth域。若是在DayofWeek域使用5L,意味着在最後的一個星期四觸發。

　　（7）W:表示有效工做日(週一到週五),只能出如今DayofMonth域，系統將在離指定日期的最近的有效工做日觸發事件。例如：在 DayofMonth使用5W，若是5日是星期六，則將在最近的工做日：星期五，即4日觸發。若是5日是星期天，則在6日(週一)觸發；若是5日在星期一到星期五中的一天，則就在5日觸發。另一點，W的最近尋找不會跨過月份 。

　　（8）LW:這兩個字符能夠連用，表示在某個月最後一個工做日，即最後一個星期五。

　　（9）#:用於肯定每月第幾個星期幾，只能出如今DayofMonth域。例如在4#2，表示某月的第二個星期三。

1.3.4.4       經常使用表達式例子

　　（1）0 0 2 1 * ? *   表示在每個月的1日的凌晨2點調整任務

　　（2）0 15 10 ? * MON-FRI   表示週一到週五天天上午10:15執行做業

　　（3）0 15 10 ? 6L 2002-2006   表示2002-2006年的每月的最後一個星期五上午10:15執行做

　　（4）0 0 10,14,16 * * ?   天天上午10點，下午2點，4點

　　（5）0 0/30 9-17 * * ?   朝九晚五工做時間內每半小時

　　（6）0 0 12 ? * WED    表示每一個星期三中午12點

　　（7）0 0 12 * * ?   天天中午12點觸發

　　（8）0 15 10 ? * *    天天上午10:15觸發

　　（9）0 15 10 * * ?     天天上午10:15觸發

　　（10）0 15 10 * * ? *    天天上午10:15觸發

　　（11）0 15 10 * * ? 2005    2005年的天天上午10:15觸發

　　（12）0 * 14 * * ?     在天天下午2點到下午2:59期間的每1分鐘觸發

　　（13）0 0/5 14 * * ?    在天天下午2點到下午2:55期間的每5分鐘觸發

　　（14）0 0/5 14,18 * * ?     在天天下午2點到2:55期間和下午6點到6:55期間的每5分鐘觸發

　　（15）0 0-5 14 * * ?    在天天下午2點到下午2:05期間的每1分鐘觸發

　　（16）0 10,44 14 ? 3 WED    每一年三月的星期三的下午2:10和2:44觸發

　　（17）0 15 10 ? * MON-FRI    週一至週五的上午10:15觸發

　　（18）0 15 10 15 * ?    每個月15日上午10:15觸發

　　（19）0 15 10 L * ?    每個月最後一日的上午10:15觸發

　　（20）0 15 10 ? * 6L    每個月的最後一個星期五上午10:15觸發

　　（21）0 15 10 ? * 6L 2002-2005   2002年至2005年的每個月的最後一個星期五上午10:15觸發

　　（22）0 15 10 ? * 6#3   每個月的第三個星期五上午10:15觸發

注：

　　（1）有些子表達式能包含一些範圍或列表

例如：子表達式（天（星期））能夠爲 「MON-FRI」，「MON，WED，FRI」，「MON-WED,SAT」,「*」字符表明全部可能的值

所以，「*」在子表達式（月）裏表示每月的含義，「*」在子表達式（天（星期））表示星期的每一天.

「/」字符用來指定數值的增量

　　例如：在子表達式（分鐘）裏的「0/15」表示從第0分鐘開始，每15分鐘

在子表達式（分鐘）裏的「3/20」表示從第3分鐘開始，每20分鐘（它和「3，23，43」）的含義同樣,

 

「？」字符僅被用於天（月）和天（星期）兩個子表達式，表示不指定值

　當2個子表達式其中之一被指定了值之後，爲了不衝突，須要將另外一個子表達式的值設爲「？」

 

　　「L」 字符僅被用於天（月）和天（星期）兩個子表達式，它是單詞「last」的縮寫

　　可是它在兩個子表達式裏的含義是不一樣的。

　　在天（月）子表達式中，「L」表示一個月的最後一天

　　在天（星期）自表達式中，「L」表示一個星期的最後一天，也就是SAT

 

　　若是在「L」前有具體的內容，它就具備其餘的含義了

 

　　例如：「6L」表示這個月的倒數第６天，「FRIL」表示這個月的最一個星期五

　　注意：在使用「L」參數時，不要指定列表或範圍，由於這會致使問題

1.4Quartz調度核心元素：

1.4.1Scheduler:任務調度器

是實際執行任務調度的控制器。在spring中經過SchedulerFactoryBean封裝起來。

1.4.2Trigger：觸發器

用於定義任務調度的時間規則，有SimpleTrigger,CronTrigger,DateIntervalTrigger和NthIncludedDayTrigger，其中CronTrigger用的比較多，本文主要介紹這種方式。CronTrigger在spring中封裝在CronTriggerFactoryBean中。

1.4.3Calendar: 日曆特定時間點集合

它是一些日曆特定時間點的集合。一個trigger能夠包含多個Calendar，以便排除或包含某些時間點。

1.4.4JobDetail: 描述Job實現類

用來描述Job實現類及其它相關的靜態信息，如Job名字、關聯監聽器等信息。在spring中有JobDetailFactoryBean和 MethodInvokingJobDetailFactoryBean兩種實現，若是任務調度只須要執行某個類的某個方法，就能夠經過MethodInvokingJobDetailFactoryBean來調用。

1.4.5Job：定義運行任務

是一個接口，只有一個方法void execute(JobExecutionContext context),開發者實現該接口定義運行任務，JobExecutionContext類提供了調度上下文的各類信息。Job運行時的信息保存在JobDataMap實例中。實現Job接口的任務，默認是無狀態的，若要將Job設置成有狀態的，在quartz中是給實現的Job添加@DisallowConcurrentExecution註解（之前是實現StatefulJob接口，如今已被Deprecated）,在與spring結合中能夠在spring配置文件的job detail中配置concurrent參數。

1.5Quartz和Spring整合

1.5.1環境搭建

maven座標引入

<dependencies>              <dependency>                      <groupId>org.quartz-scheduler</groupId>                      <artifactId>quartz</artifactId>                      <version>2.2.1</version>               </dependency>               <dependency>                      <groupId>org.quartz-scheduler</groupId>                      <artifactId>quartz-jobs</artifactId>                      <version>2.2.1</version>               </dependency>               <dependency>                      <groupId>org.slf4j</groupId>                      <artifactId>slf4j-log4j12</artifactId>                      <version>1.7.12</version>               </dependency>                             <dependency>                      <groupId>org.springframework</groupId>                      <artifactId>spring-context</artifactId>                      <version>4.1.7.RELEASE</version>               </dependency>               <dependency>                      <groupId>org.springframework</groupId>                      <artifactId>spring-context-support</artifactId>                      <version>4.1.7.RELEASE</version>               </dependency>               <dependency>                      <groupId>org.springframework</groupId>                      <artifactId>spring-web</artifactId>                      <version>4.1.7.RELEASE</version>               </dependency>               <dependency>                      <groupId>org.springframework</groupId>                      <artifactId>spring-tx</artifactId>                      <version>4.1.7.RELEASE</version>               </dependency>        </dependencies>

1.5.2配置 web.xml spring 的監聽器

<!-- spring配置文件位置 -->     <context-param>        <param-name>contextConfigLocation</param-name>        <param-value>classpath:applicationContext.xml</param-value>     </context-param>     <!-- spring核心監聽器 -->     <listener>        <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>     </listener>

 

1.5.3編寫job程序

package cn.peihua.job; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.springframework.beans.factory.annotation.Autowired; import cn.peihua.job.service.HelloService;   publicclass HelloJob implements Job {       @Autowired     private HelloService helloService;       publicvoid execute(JobExecutionContext context)            throws JobExecutionException {        helloService.sayHello();     }   }

 

1.5.4編寫service

package cn.peihua.job.service;   import org.springframework.stereotype.Service;   @Service publicclass HelloService {     publicvoid sayHello() {        System.out.println("hello,quartz spring !!!~~");     } }

 

1.5.5applicationContext-quartz.xml配置

而後將此文件引入到applicationContext.xml文件中

<?xml version="1.0"encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans"     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"     xmlns:context="http://www.springframework.org/schema/context"     xsi:schemaLocation="http://www.springframework.org/schema/beans     http://www.springframework.org/schema/beans/spring-beans.xsd     http://www.springframework.org/schema/context     http://www.springframework.org/schema/context/spring-context.xsd ">         <context:component-scan base-package="cn.peihua.job.service" />         <!-- 配置job工做任務 -->     <bean id="helloJob" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">         <property name="jobClass" value="cn.peihua.job.HelloJob"/>     </bean>     <!-- 配置Trigger觸發器 -->     <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean">         <!-- 3秒後第一次執行job-->         <property name="startDelay" value="3000"/>         <!--  60秒爲週期重複執行 -->         <property name="repeatInterval" value="60000"/>         <!-- 觸發器生效後執行的job -->         <property name="jobDetail" ref="helloJob"/>     </bean>         <!-- 配置scheduler調度任務 -->     <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">         <!-- 解決集成Spring以後Bean的值沒法注入的問題 -->         <property name="jobFactory" ref="jobFactory"/>         <property name="triggers">             <list>                 <ref bean="simpleTrigger"/>             </list>         </property>     </bean> </beans>

1.5.6提供JobFactory(輔助job的注入)

package cn.peihua.job.service; import org.quartz.spi.TriggerFiredBundle; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.AutowireCapableBeanFactory; import org.springframework.scheduling.quartz.AdaptableJobFactory; import org.springframework.stereotype.Service;   @Service("jobFactory") public class JobFactory extends AdaptableJobFactory {        @Autowired        private AutowireCapableBeanFactory capableBeanFactory;        @Override        protected Object createJobInstance(TriggerFiredBundle bundle)                      throws Exception {               Object jobInstance = super.createJobInstance(bundle);               capableBeanFactory.autowireBean(jobInstance);               return jobInstance;        } }

 

 

1.6使用的注意事項：

注意:

       1.?只能用在日期(4)和星期(6)   

       2.知足上面條件後,?不一樣同時使用,星期與日期必須指定一個,另一個用? 

       3.*也不一樣同時放在日期(4)和日期(6)

                    

       cron在線生成器:http://www.pdtools.net/tools/becron.jsp