Spring整合Quartz框架定时任务

   最近项目中经常用到队列和定时任务及线程的整合应用，涉及的场景是当多人访问系统时需要回调客户系统处理结果时，如何减少服务器压力并能处理业务需求，这里用到了队列减少服务器压力加入定时任务发送机制，使用的是spring框架整合 Quartz框架实现的定时任务，因此学习了一下Quartz的前因后果 在此记录学习一下。

一、引入

      你曾经需要应用执行一个任务吗？这个任务每天或每周星期二晚上11：30，或许仅仅每个月的最后一天执行。一个自动执行而无须干预的任务在执行过程中如果发生一个严重错误，应用能够知到其执行失败并尝试重新执行吗？你和你的团队是用Java编程吗？如果这些问题中任何一个你回答是，那么你应该使用Quartz调度器。

二、为什么研发团队会选择quartz

java编写的开源作业调度框架设计，用于J2SE和J2EE应用方便集成。

资历够老,创立于1998年,比struts1还早，而且一直在更新(24 Sept 2013: Quartz 2.2.1 Released),文档齐全。

设计清晰简单:核心概念scheduler,trigger,job,jobDetail,listener,calendar 

支持集群:org.quartz.jobStore.isClustered  最重要的一点原因是quartz是支持集群的。不然JDK自带Timer就可以实现相同的功能。

支持任务恢复:requestsRecovery 

普及面很广，JAVA开发人员比较熟悉。

Apache2.0开源协议，允许代码修改，再商业发布。

 

三、如何使定时任务的开发方便，易于管理。

阿里开源项目easySchedule在quartz集群的基础上搭建了一个简单的管理平台。解决了可视化、易配置、统一监控告警功能。
实现调度与执行的分离，使任务不需要再去关注定时，只需要实现任务接口即可。
调度通过HTTP来调用执行任务。

easySchedule系统特点：

1、 Server和Client分别支持集群和分布式部署

2、 任务的执行与调度分离

3、 可视化管理所有任务

4、 任务状态持久化于DB

5、 完善的日志跟踪和告警策略

6、 任务支持异步调度

7、 灵活支持各种自定义任务，扩展方便

 

1、Job：是一个接口，只有一个方法void execute(JobExecutionContext context)，开发者实现该接口定义运行任务，JobExecutionContext类提供了调度上下文的各种信息。Job运行时的信息保存在JobDataMap实例中；

2、JobDetail：Quartz在每次执行Job时，都重新创建一个Job实例，所以它不直接接受一个Job的实例，相反它接收一个Job实现类，以便运行时通过newInstance()的反射机制实例化Job。因此需要通过一个类来描述Job的实现类及其它相关的静态信息，如Job名字、描述、关联监听器等信息，JobDetail承担了这一角色。

3、Trigger：是一个类，描述触发Job执行的时间触发规则。主要有SimpleTrigger和CronTrigger这两个子类。当仅需触发一次或者以固定时间间隔周期执行，SimpleTrigger是最适合的选择；而CronTrigger则可以通过Cron表达式定义出各种复杂时间规则的调度方案：如每早晨9:00执行，周一、周三、周五下午5:00执行等；

4、Calendar：org.quartz.Calendar和java.util.Calendar不同，它是一些日历特定时间点的集合（可以简单地将org.quartz.Calendar看作java.util.Calendar的集合——java.util.Calendar代表一个日历时间点，无特殊说明后面的Calendar即指org.quartz.Calendar）。一个Trigger可以和多个Calendar关联，以便排除或包含某些时间点。假设，我们安排每周星期一早上10:00执行任务，但是如果碰到法定的节日，任务则不执行，这时就需要在Trigger触发机制的基础上使用Calendar进行定点排除。

5、Scheduler：代表一个Quartz的独立运行容器，Trigger和JobDetail可以注册到Scheduler中，两者在Scheduler中拥有各自的组及名称，组及名称是Scheduler查找定位容器中某一对象的依据，Trigger的组及名称必须唯一，JobDetail的组和名称也必须唯一（但可以和Trigger的组和名称相同，因为它们是不同类型的）。Scheduler定义了多个接口方法，允许外部通过组及名称访问和控制容器中Trigger和JobDetail。

 6、 Scheduler可以将Trigger绑定到某一JobDetail中，这样当Trigger触发时，对应的Job就被执行。一个Job可以对应多个Trigger，但一个Trigger只能对应一个Job。可以通过SchedulerFactory创建一个Scheduler实例。Scheduler拥有一个SchedulerContext，它类似于ServletContext，保存着Scheduler上下文信息，Job和Trigger都可以访问SchedulerContext内的信息。SchedulerContext内部通过一个Map，以键值对的方式维护这些上下文数据，SchedulerContext为保存和获取数据提供了多个put()和getXxx()的方法。可以通过Scheduler# getContext()获取对应的SchedulerContext实例；

7、ThreadPool：Scheduler使用一个线程池作为任务运行的基础设施，任务通过共享线程池中的线程提高运行效率。

 

Quartz内部架构

　　在规模方面，Quartz跟大多数开源框架类似。大约有300个Java类和接口，并被组织到12个包中。这可以和Apache Struts把大约325个类和接口以及组织到11个包中相比。尽管规模几乎不会用来作为衡量框架质量的一个特性，但这里的关键是quarts内含很多功能，这些功能和特性集是否成为、或者应该成为评判一个开源或非开源框架质量的因素。

Quartz调度器

Quartz框架的核心是调度器。调度器负责管理Quartz应用运行时环境。调度器不是靠自己做所有的工作，而是依赖框架内一些非常重要的部件。Quartz不仅仅是线程和线程管理。为确保可伸缩性，Quartz采用了基于多线程的架构。

　　启动时，框架初始化一套worker线程，这套线程被调度器用来执行预定的作业。这就是Quartz怎样能并发运行多个作业的原理。Quartz依赖一套松耦合的线程池管理部件来管理线程环境。本文中，我们会多次提到线程池管理，但Quartz里面的每个对象是可配置的或者是可定制的。所以，例如，如果你想要插进自己线程池管理设施，我猜你一定能！

作业和触发器

Quartz设计者做了一个设计选择来从调度分离开作业。Quartz中的触发器用来告诉调度程序作业什么时候触发。框架提供了一把触发器类型，但两个最常用的是SimpleTrigger和CronTrigger。SimpleTrigger为需要简单打火调度而设计。

　　典型地，如果你需要在给定的时间和重复次数或者两次打火之间等待的秒数打火一个作业，那么SimpleTrigger适合你。另一方面，如果你有许多复杂的作业调度，那么或许需要CronTrigger。

 

Cron表达式

CronTrigger是基于Calendar-like调度的。当你需要在除星期六和星期天外的每天上午10点半执行作业时，那么应该使用CronTrigger。正如它的名字所暗示的那样，CronTrigger是基于Unix克隆表达式的。

　　作为一个例子，下面的Quartz克隆表达式将在星期一到星期五的每天上午10点15分执行一个作业。

0 15 10 ? * MON-FRI

下面的表达式

0 15 10 ? * 6L 2002-2005

　　将在2002年到2005年的每个月的最后一个星期五上午10点15分执行作业。你不可能用SimpleTrigger来做这些事情。你可以用两者之中的任何一个，但哪个跟合适则取决于你的调度需要。

 

Quartz有两大触发器，除了上面使用的SimpleTrigger外，就是CronTrigger。CronTrigger能够提供复杂的触发器表达式的支持。CronTrigger是基于Unix Cron守护进程，它是一个调度程序，支持简单而强大的触发器语法。

 

使用CronTrigger主要的是要掌握Cron表达式。Cron表达式包含6个必要组件和一个可选组件，如下表所示。


特殊字符的含义

Cron表达式举例：

 

"30 * * * * ?" 每半分钟触发任务

"30 10 * * * ?" 每小时的10分30秒触发任务

"30 10 1 * * ?" 每天1点10分30秒触发任务

"30 10 1 20 * ?" 每月20号1点10分30秒触发任务

"30 10 1 20 10 ? *" 每年10月20号1点10分30秒触发任务

"30 10 1 20 10 ? 2011" 2011年10月20号1点10分30秒触发任务

"30 10 1 ? 10 * 2011" 2011年10月每天1点10分30秒触发任务

"30 10 1 ? 10 SUN 2011" 2011年10月每周日1点10分30秒触发任务

"15,30,45 * * * * ?" 每15秒，30秒，45秒时触发任务

"15-45 * * * * ?" 15到45秒内，每秒都触发任务

"15/5 * * * * ?" 每分钟的每15秒开始触发，每隔5秒触发一次

"15-30/5 * * * * ?" 每分钟的15秒到30秒之间开始触发，每隔5秒触发一次

"0 0/3 * * * ?" 每小时的第0分0秒开始，每三分钟触发一次

"0 15 10 ? * MON-FRI" 星期一到星期五的10点15分0秒触发任务

"0 15 10 L * ?" 每个月最后一天的10点15分0秒触发任务

"0 15 10 LW * ?" 每个月最后一个工作日的10点15分0秒触发任务

"0 15 10 ? * 5L" 每个月最后一个星期四的10点15分0秒触发任务

"0 15 10 ? * 5#3" 每个月第三周的星期四的10点15分0秒触发任务

 

在线生成Cron

错过触发(misfire)

trigger还有一个重要的属性misfire；如果scheduler关闭了，或者Quartz线程池中没有可用的线程来执行job，此时持久性的trigger就会错过(miss)其触发时间，即错过触发(misfire)。不同类型的trigger，有不同的misfire机制。它们默认都使用“智能机制(smart policy)”，即根据trigger的类型和配置动态调整行为。当scheduler启动的时候，查询所有错过触发(misfire)的持久性trigger。然后根据它们各自的misfire机制更新trigger的信息。当你在项目中使用Quartz时，你应该对各种类型的trigger的misfire机制都比较熟悉，这些misfire机制在JavaDoc中有说明。关于misfire机制的细节，会在讲到具体的trigger时作介绍。

 

 五、Spring整合Quartz

     定时任务两种方式，Spring很好的封装使用Quartz的细节，第一种方式是利用SPring封装的Quartz类进行特定方法的实现，第二种是通过透明的使用Quartz达到定时任务开发的目的，总体说第二种对开发人员更方便！

   配置Spring的任务调度抽象层简化了任务调度，在Quartz的基础上提供了更好的调度对象。Spring使用Quartz框架来完成任务调度，创建Quartz的作业Bean（JobDetail），有一下两种方法：

   1:利用JobDetailBean包装QuartzJobBean子类（即Job类）的实例。

   2：利用MethodInvokingJobDetailFactoryBean工厂Bean包装普通的Java对象（即Job类）。

   说明：

      1:采用第一种方法 创建job类，一定要继承QuartzJobBean ，实现 executeInternal(JobExecutionContext
jobexecutioncontext)方法,此方法就是被调度任务的执行体，然后将此Job类的实例直接配置到JobDetailBean中即可。这种方法和在普通的Quartz编程中是一样的。

      2：采用第二种方法 创建Job类，无须继承父类，直接配置MethodInvokingJobDetailFactoryBean即可。但需要指定一下两个属性：

        targetObject：指定包含任务执行体的Bean实例。

        targetMethod:指定将指定Bean实例的该方法包装成任务的执行体。 

这里我们介绍第二种：直接上代码

package com.test.quartz;  

 

import org.springframework.scheduling.annotation.Scheduled;

import org.springframework.stereotype.Service;

 

@Service

public class QuartzJob  

{  

@Scheduled(cron="0/5 * * * * ? ")

    public void work()  

    {  

    System.out.println("Quartz的任务调度！！！");  

    }  

}  

 

 

 

   <listener>    

   <listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>    

 </listener>    

 

    web.xml

<servlet>

<servlet-name>hello</servlet-name>

<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>

<load-on-startup>1</load-on-startup>

 

<init-param>

      <param-name>contextConfigLocation</param-name>

      <param-value>WEB-INF/applicationContext.xml</param-value>

    </init-param> 

</servlet> 

 

 

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"

    xmlns:mvc="http://www.springframework.org/schema/mvc"

    xmlns:task="http://www.springframework.org/schema/task"    

    xsi:schemaLocation="

        http://www.springframework.org/schema/beans 

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

        http://www.springframework.org/schema/context 

        http://www.springframework.org/schema/context/spring-context-3.0.xsd

        http://www.springframework.org/schema/mvc 

        http://www.springframework.org/schema/mvc/spring-mvc-3.0.xsd

        http://www.springframework.org/schema/task            

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

          

        >

        <!-- 组件扫描 -->

        <context:component-scan base-package="com.test.controller,com.test.quartz"/>

        

         <task:executor id="executor" pool-size="5" />        

         <task:scheduler id="scheduler" pool-size="10" />      

         <task:annotation-driven executor="executor" scheduler="scheduler" />    

        

        

        <!-- 注解驱动 -->

        <mvc:annotation-driven/>

        <!-- 映射静态资源 -->

<mvc:resources mapping="/resources/**" location="/resources/" />

        <!-- 内部资源视图解析器 -->

        <bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">

        <!-- 引入jstl标签库所使用，帮助文档建议加上，不加应该也可以 -->

        <property name="viewClass" value="org.springframework.web.servlet.view.JstlView"/>

        <!-- 前缀 -->

        <property name="prefix" value="/WEB-INF/jsp/"/>

        <!-- 后缀 -->

        <property name="suffix" value=".jsp"/>

        </bean>

        

        

        

        

        

        

          <!-- 要调用的工作类 -->  

        <bean id="quartzJob" class="com.test.quartz.QuartzJob"></bean>  

        <!-- 定义调用对象和调用对象的方法 -->  

        <bean id="jobtask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">  

            <!-- 调用的类 -->  

            <property name="targetObject">  

                <ref bean="quartzJob"/>  

            </property>  

            <!-- 调用类中的方法 -->  

            <property name="targetMethod">  

                <value>work</value>  

            </property>  

        </bean>  

        <!-- 定义触发时间 -->  

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

            <property name="jobDetail">  

                <ref bean="jobtask"/>  

            </property>  

            <!-- cron表达式 -->  

            <property name="cronExpression">  

                <value>1,5,10,15,20,25,30,35,40,45,50,55 * * * * ?</value>  

            </property>  

        </bean>  

        

        <!-- 总管理类 如果将lazy-init='false'那么容器启动就会执行调度程序  -->  

        <bean id="startQuertz" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">  

            <property name="triggers">  

                <list>  

                    <ref bean="doTime"/>  

                </list>  

            </property>  

        </bean>  

        

 

        

        <!-- 全局异常配置 -->

        <bean class="org.springframework.web.servlet.handler.SimpleMappingExceptionResolver">

        <!-- 注入Properties -->

        <property name="exceptionMappings">

        <props>

        <!-- error是jsp页面 -->

        <prop key="com.test.exception.UserException">error</prop>

        </props>

        </property>

        </bean>

        

        

        <!-- 文件上传解析器 ,id必须是multipartResolver-->

<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">

<!-- 设置最大上传5M -->

<property name="maxUploadSize" value="5000000" />

</bean>

 

 

 

 

</beans>