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