spring+quartz

1. 首先用一個純quartz例子講一下quartz的基本概念

   其中有兩個基本概念,job(封裝業務)與trigger(任務調度)，trigger又分兩種，simpleTrigger與cronTrigger,分別模擬了window下的schedule task與linux下的cron table,詳見本文最末

　以一個maven project爲例，在pom.xml中要引入quartz

複製代碼

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <groupId>OTV_Quartz</groupId>

    <artifactId>OTV_Quartz</artifactId>

    <version>0.0.1-SNAPSHOT</version>

    <dependencies>

        <!-- 引入Quartz library -->

        <dependency>

            <groupId>org.quartz-scheduler</groupId>

            <artifactId>quartz</artifactId>

            <version>2.1.3</version>

        </dependency>

        <!-- Log4j library -->

        <dependency>

            <groupId>log4j</groupId>

            <artifactId>log4j</artifactId>

            <version>1.2.16</version>

        </dependency>    

    </dependencies>

</project>

複製代碼

寫一個業務類testjob類，須要實現quartz中的job接口(其中只有一個函數可用於封裝業務邏輯，execute)

複製代碼

package com.otv.job;

import org.apache.log4j.Logger;

import org.quartz.Job;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

public class TestJob implements Job {

    private Logger log = Logger.getLogger(TestJob.class);    

    public void execute(JobExecutionContext jExeCtx) throws JobExecutionException {

        log.debug("[vigar]: TestJob run successfully...");

    }

}

複製代碼

開始進行調度

複製代碼

package com.otv;

import org.quartz.JobBuilder;

import org.quartz.JobDetail;

import org.quartz.Scheduler;

import org.quartz.SchedulerException;

import org.quartz.SchedulerFactory;

import org.quartz.SimpleScheduleBuilder;

import org.quartz.Trigger;

import org.quartz.TriggerBuilder;

import org.quartz.impl.StdSchedulerFactory;

import com.otv.job.TestJob;

public class JobScheduler {    

    public static void main(String[] args) {

        try {

            // job 中有testJob中的信息

            JobDetail job = JobBuilder.newJob(TestJob.class)

                .withIdentity("testjob").build();

            

            // 這是trigger 部分，與時間調度相關

            Trigger trigger = TriggerBuilder.newTrigger()

                  .withSchedule(SimpleScheduleBuilder.simpleSchedule()

                        .withIntervalInSeconds(5).repeatForever()).build();  

            

            //開始調度job

            SchedulerFactory schFactory = new StdSchedulerFactory();

            Scheduler sch = schFactory.getScheduler();

            sch.start();            

            sch.scheduleJob(job, trigger);        

        

        } catch (SchedulerException e) {

            e.printStackTrace();

        }

    }

}

複製代碼

執行JobScheduler，結果

複製代碼

04.01.2013 09:28:56 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

04.01.2013 09:29:01 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

04.01.2013 09:29:06 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

04.01.2013 09:29:11 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

04.01.2013 09:29:16 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

04.01.2013 09:29:21 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

04.01.2013 09:29:26 DEBUG (TestJob.java:13) - [vigar]: TestJob run successfully...

複製代碼

 2. 以spring中的quartz模塊爲例寫一個例子，講述quartz在spring框架中的應用

目前，spring框架中加強了對quartz的支持，將JobDetai/SimpleTrigger/CronTrigger等相關對象都封裝成bean,能夠直接在xml中配置，也蠻好用

 將spring配置文件貼一下

複製代碼

<beans xmlns="http://www.springframework.org/schema/beans" 

    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

    xsi:schemaLocation="http://www.springframework.org/schema/beans

    http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

    <bean id="runMeTask" class="com.mkyong.common.RunMeTask" />

    <!-- Spring Quartz -->

    <bean name="runMeJob" class="org.springframework.scheduling.quartz.JobDetailBean">

        <property name="jobClass" value="com.mkyong.common.RunMeJob" />

        <property name="jobDataAsMap">

            <map><entry key="runMeTask" value-ref="runMeTask" /></map>

        </property>

    </bean>

    <!-- Simple Trigger, run every 5 seconds -->

    <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerBean">

        <property name="jobDetail" ref="runMeJob" />

        <property name="repeatInterval" value="5000" />

        <property name="startDelay" value="1000" />

    </bean>

    <!-- Cron Trigger, run every 5 seconds -->

    <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">

        <property name="jobDetail" ref="runMeJob" /><!--要執行的job，這裏已經定義好了-->

        <property name="cronExpression" value="0/5 * * * * ?" />

    </bean>

    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

        <property name="jobDetails">

            <list><ref bean="runMeJob" /></list>

        </property>

        <property name="triggers">

            <list><ref bean="simpleTrigger" /></list>

        </property>

    </bean>

</beans>

複製代碼

RunMeTask.java源碼

package com.mkyong.common;

public class RunMeTask {

    public void printMe() {

        System.out.println("Spring 3 + Quartz 1.8.6 ~");

    }

}

RunMeJob源碼，擴展了QuartzJobBean

複製代碼

package com.mkyong.common;

import org.quartz.JobExecutionContext;

import org.quartz.JobExecutionException;

import org.springframework.scheduling.quartz.QuartzJobBean;

public class RunMeJob extends QuartzJobBean {

    private RunMeTask runMeTask;

    public void setRunMeTask(RunMeTask runMeTask) {

        this.runMeTask = runMeTask;

    }

    protected void executeInternal(JobExecutionContext context)

            throws JobExecutionException {

        runMeTask.printMe();

    }

}

複製代碼

程序入口:

複製代碼

package com.mkyong.common;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class App {

    public static void main(String[] args) throws Exception {

        new ClassPathXmlApplicationContext("Spring-Quartz.xml");

    }

}

複製代碼

 

.quartz 時間配置規則

格式: [秒] [分] [小時] [日] [月] [周] [年] 

 序號 說明  是否必填  容許填寫的值 容許的通配符

 1  秒  是  0-59   , - * /

 2  分  是  0-59   , - * /

 3 小時  是  0-23   , - * /

 4  日  是  1-31   , - * ? / L W

 5  月  是  1-12 or JAN-DEC   , - * /

 6  周  是  1-7 or SUN-SAT   , - * ? / L #

 7  年  否  empty 或 1970-2099  , - * /

通配符說明:

*表示全部值. 例如:在分的字段上設置 "*",表示每一分鐘都會觸發。

?表示不指定值。使用的場景爲不須要關心當前設置這個字段的值。例如:要在每個月的10號觸發一個操做，但不關心是周幾，因此須要周位置的那個字段設置爲"?" 具體設置爲 0 0 0 10*?

-表示區間。例如 在小時上設置 "10-12",表示 10,11,12點都會觸發。

, 表示指定多個值，例如在周字段上設置"MON,WED,FRI" 表示週一，週三和週五觸發

/用於遞增觸發。如在秒上面設置"5/15" 表示從5秒開始，每增15秒觸發(5,20,35,50)。在月字段上設置'1/3'所示每個月1號開始，每隔三天觸發一次。

L表示最後的意思。在日字段設置上，表示當月的最後一天(依據當前月份，若是是二月還會依據是不是潤年[leap]),在周字段上表示星期六，至關於"7"或"SAT"。若是在"L"前加上數字，則表示該數據的最後一個。例如在周字段上設置"6L"這樣的格式,則表示「本月最後一個星期五"

W表示離指定日期的最近那個工做日(週一至週五).例如在日字段上設置"15W"，表示離每個月15號最近的那個工做日觸發。若是15號正好是週六，則找最近的週五(14號)觸發,若是15號是周未，則找最近的下週一(16號)觸發.若是15號正好在工做日(週一至週五)，則就在該天觸發。若是指定格式爲"1W",它則表示每個月1號日後最近的工做日觸發。若是1號正是週六，則將在3號下週一觸發。(注，"W"前只能設置具體的數字,不容許區間"-").

小提示

'L'和 'W'能夠一組合使用。若是在日字段上設置"LW",則表示在本月的最後一個工做日觸發(通常指發工資 ) 

#序號(表示每個月的第幾個周幾)，例如在周字段上設置"6#3"表示在每個月的第三個週六.注意若是指定"#5",正好第五週沒有周六，則不會觸發該配置(用在母親節和父親節再合適不過了)

小提示

周字段的設置，若使用英文字母是不區分大小寫的 MON 與mon相同.

 經常使用示例:

0 0 12 * * ? 天天12點觸發

0 15 10 ? * * 天天10點15分觸發

0 15 10 * * ? 天天10點15分觸發

0 15 10 * * ? * 天天10點15分觸發

0 15 10 * * ? 2005 2005年天天10點15分觸發

0 * 14 * * ? 天天下午的 2點到2點59分每分觸發

0 0/5 14 * * ? 天天下午的 2點到2點59分(整點開始，每隔5分觸發)

0 0/5 14,18 * * ? 天天下午的 2點到2點59分(整點開始，每隔5分觸發)

天天下午的 18點到18點59分(整點開始，每隔5分觸發)

0 0-5 14 * * ? 天天下午的 2點到2點05分每分觸發

0 10,44 14 ? 3 WED 3月分每週三下午的 2點10分和2點44分觸發

0 15 10 ? * MON-FRI 從週一到週五天天上午的10點15分觸發

0 15 10 15 * ? 每個月15號上午10點15分觸發

0 15 10 L * ? 每個月最後一天的10點15分觸發

0 15 10 ? * 6L 每個月最後一週的星期五的10點15分觸發

0 15 10 ? * 6L 2002-2005 從2002年到2005年每個月最後一週的星期五的10點15分觸發

0 15 10 ? * 6#3 每個月的第三週的星期五開始觸發

0 0 12 1/5 * ? 每個月的第一個中午開始每隔5天觸發一次

0 11 11 11 11 ? 每一年的11月11號 11點11分觸發(光棍節)