Spring Quartz配置

梦里梦外; 2022-08-13 12:59 238阅读 0赞

**Quartz**

Quartz是一个完全由java编写的开源作业调度框架.

Quartz最主要的功能就是调度器(完成定时任务)，可以与javaEE或者javaSE应用程序相结合也可以单独使用。

Quartz能借助关系数据库和JDBC作业存储支持集群，负载均衡。

**需要的jar包：**

spring.jar   
[quartz][]\-1.6.1.jar   
commons-logging.jar   
commons-collections.jar   
log4j-1.2.15.jar

**Spring Quartz**

Spring中继承并简化了Quartz, 我们可以通过配置Spring简化Quartz的配置。

在ApplicationContext.xml配置数据源，并且引入ApplicationContext-quartz.xml文件。

ApplicationContext.xml:

1.  <beanid="dataSource"class="org.springframework.jndi.JndiObjectFactoryBean">
2.  <propertyname="jndiName"value="java:comp/env/jdbc/publicdb"></property>
3.  </bean>
4.                      .   
5.                      .   
6.                      .   
7.                      .   
8.  
9.  <importresource="ApplicationContext-quartz.xml"/>

ApplicationContext-quartz.xml：

1.  <?xml version="1.0" encoding="UTF-8"?>   
2.  <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN""http://www.springframework.org/dtd/spring-beans.dtd">   
3.     
4.  <beans default-autowire="byName">   
5.         
6.      <bean id="reportCreateJob"class="org.quartz.JobDetail">   
7.          <property name="jobClass">   
8.              <value>com.hundsun.u3c.reportserver.quartz.job.ReportCreateJob</value>   
9.          </property>   
10.         <property name="name" value="reportCreate-processor-job" />   
11.     </bean>   
12.        
13.     <bean id="reportCreateTrigger"class="org.springframework.scheduling.quartz.CronTriggerBean">   
14.         <property name="jobDetail">   
15.             <ref bean="reportCreateJob" />   
16.         </property>   
17.         <property name="cronExpression">   
18.             <value>0 \* \* \* \* ?</value>   
19.         </property>   
20.     </bean>   
21.        
22.     <bean id="scheduler"
23. class="org.springframework.scheduling.quartz.SchedulerFactoryBean">   
24.         <property name="dataSource" ref="dataSource" />   
25.             
26.         <property name="startupDelay" value="300" />   
27.         <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />   
28.         <property name="quartzProperties">   
29.             <props>   
30.                 <prop key="org.quartz.scheduler.instanceName">qmsQuartzScheduler</prop>   
31.                 <prop key="org.quartz.scheduler.instanceId">AUTO</prop>   
32.                 <prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>   
33.                 <prop key="org.quartz.threadPool.threadCount">3</prop>   
34.                 <prop key="org.quartz.threadPool.threadPriority">5</prop>   
35.                 <prop key="org.quartz.jobStore.misfireThreshold">60000</prop>   
36.                 <prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>   
37.                 <prop key="org.quartz.jobStore.driverDelegateClass">$\{QUARTZ\_DRIVERDELEGATECLASS\}</prop>   
38.                 <prop key="org.quartz.jobStore.selectWithLockSQL">SELECT \* FROM \{0\}LOCKS UPDLOCK WHERE LOCK\_NAME = ?</prop>   
39.                 <prop key="org.quartz.jobStore.tablePrefix">U3C\_QRTZ\_</prop>   
40.                 <prop key="org.quartz.jobStore.isClustered">true</prop>   
41.                 <prop key="org.quartz.jobStore.clusterCheckinInterval">20000</prop>   
42.             </props>   
43.         </property>   
44.            
45.         <property name="triggers">   
46.             <list>   
47.                 <ref bean="reportCreateTrigger" />   
48.             </list>   
49.         </property>   
50.     </bean>   
51. </beans>

<?xml version="1.0" encoding="UTF-8"?>
    <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
    
    
    <beans default-autowire="byName">
        
        <bean id="reportCreateJob" class="org.quartz.JobDetail">
            <property name="jobClass">
                <value>com.hundsun.u3c.reportserver.quartz.job.ReportCreateJob</value>
            </property>
            <property name="name" value="reportCreate-processor-job" />
        </bean>
        
        <bean id="reportCreateTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
            <property name="jobDetail">
                <ref bean="reportCreateJob" />
            </property>
            <property name="cronExpression">
                <value>0 * * * * ?</value>
            </property>
        </bean>
        
        <bean id="scheduler"
            class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
            <property name="dataSource" ref="dataSource" />
             
            <property name="startupDelay" value="300" />
            <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
            <property name="quartzProperties">
                <props>
                    <prop key="org.quartz.scheduler.instanceName">qmsQuartzScheduler</prop>
                    <prop key="org.quartz.scheduler.instanceId">AUTO</prop>
                    <prop key="org.quartz.threadPool.class">org.quartz.simpl.SimpleThreadPool</prop>
                    <prop key="org.quartz.threadPool.threadCount">3</prop>
                    <prop key="org.quartz.threadPool.threadPriority">5</prop>
                    <prop key="org.quartz.jobStore.misfireThreshold">60000</prop>
                    <prop key="org.quartz.jobStore.class">org.quartz.impl.jdbcjobstore.JobStoreTX</prop>
                    <prop key="org.quartz.jobStore.driverDelegateClass">${QUARTZ_DRIVERDELEGATECLASS}</prop>
                    <prop key="org.quartz.jobStore.selectWithLockSQL">SELECT * FROM {0}LOCKS UPDLOCK WHERE LOCK_NAME = ?</prop>
                    <prop key="org.quartz.jobStore.tablePrefix">U3C_QRTZ_</prop>
                    <prop key="org.quartz.jobStore.isClustered">true</prop>
                    <prop key="org.quartz.jobStore.clusterCheckinInterval">20000</prop>
                </props>
            </property>
            
            <property name="triggers">
                <list>
                    <ref bean="reportCreateTrigger" />
                </list>
            </property>
        </bean>
    </beans>

**JobDetail:** 可以使用Quartz的JobDetail在Spring中配置一个JobDetail Bean，但是JobDetail使用带参的构造函数。\[public void execute(JobExecutionContext arg0)\]

也可以使用JobDetailBean,Spring通过扩展JobDetail提供了一个更具Bean风格的JobDetailBean。此外，Spring提供了一个MethodInvokingJobDetailFactoryBean，通过这个FactoryBean可以将Spring容器中Bean的方法包装成Quartz任务，这样开发者就不必为Job创建对应的类。

**CronTriggerBean调度器**：每到指定时间则触发一次。与之相对的还有SimpleTriggerBean调度器，每隔指定时间则触发一次。

属性解释：

1.jobDetail：对应的JobDetail.

2.cronExpression:Cron表达式，后面详解。

**SchedulerFactoryBean**是Spring继承Quartz而提供的类。  
Scheduler和Spring容器的生命周期相关联。Spring容器启动后，Scheduler自动开始工作，而在Spring容器关闭前，自动关闭Scheduler。Scheduler在Spring容器的生命周期完成自动启动和关闭的操作。  
SchedulerFactoryBean功能:  
  1.以更具Bean风格的方式为Scheduler提供配置信息。  
  2.让Scheduler和Spring容器的生命周期建立关联，相生相息。  
  3.通过属性配置部分或全部代替Quartz自身的配置文件。

参数解释：

1.dataSource： 当需要使用数据库来持久化任务调度数据时，你可以在Quartz中配置数据源，也可以直接在Spring中通过dataSource指定一个Spring管理的数据源。如果指定了该属性，即使quartz.properties中已经定义了数据源，也会被此dataSource覆盖。

2.startupDelay：在SchedulerFactoryBean初始化完成后，延迟启动Scheduler，以便让Spring能够更快初始化容器中剩余的Bean。

3.quartzProperties：类型为Properties,允许你在Spring中定义Quartz的属性。其值将覆盖quartz.properties配置文件中的设置,这些属性必须是Quartz能够识别的合法属性。在配置时你可以需要查看Quartz的相关文档。

4.transactionManager：可以通过该属性设置一个Spring事务管理器。在设置dataSource时,Spring强烈推荐你使用一个事务管理器,否则数据表锁定可能不能正常工作。

**JobDetailBean:**

1.   \* @author jiangbo   
2.   \*    
3.   \*/   
4.  publicclass ReportCreateJob implements StatefulJob \{   
5.  privatestatic Logger log = Logger.getLogger(ReportCreateJob.class);   
6.  @Override
7.  publicvoid execute(JobExecutionContext arg0) throws JobExecutionException \{   
8.      log.debug("===into quartz job =======>");   
9.      ReportCreateBusiness.getInstance().createReport();   
10.   \}   
11. \}

* @author jiangbo
     * 
     */
    public class ReportCreateJob implements StatefulJob {
    
      private static Logger log = Logger.getLogger(ReportCreateJob.class);
    
      @Override
      public void execute(JobExecutionContext arg0) throws JobExecutionException {
        log.debug("===into quartz job =======>");
        ReportCreateBusiness.getInstance().createReport();
      }
    }

**Quartz的集群配置**

**org.quartz.scheduler.instanceName**属性可为任何值，用在 JDBC JobStore 中来唯一标识实例，但是所有集群节点中必须相同。

**org.quartz.scheduler.instanceId**属性为AUTO即可，基于主机名和时间戳来产生实例ID。

**org.quartz.jobStore.isClustered**设置为"true"激活集群特性

**org.quartz.jobStore.class**属性为JobStoreTX,将任务持久化到数据中。因为集群中节点依赖于数据库来传播Scheduler实例的状态,你只能在使用JDBC JobStore时应用Quartz集群。这意味着你必须使用JobStoreTX或是JobStoreCMT作为Job存储。你不能在集群中使用RAMJobStore。

**org.quartz.jobStore.clusterCheckinInterval**属性定义了Scheduler实例检入到数据库中的频率(单位:毫秒)。Scheduler检查是否其他的实例到了它们应当检入的时候未检入。这能指出一个失败的Scheduler实例，且当前 Scheduler会以此来接管任何执行失败并可恢复的Job。通过检入操作，Scheduler 也会更新自身的状态记录。clusterChedkinInterval越小，Scheduler节点检查失败的Scheduler实例就越频繁。默认值是15000 (即15秒)。

**dataSource**：项目中用到的数据源，里面包含了quartz用到的12张数据库表。

**applicationContextSchedulerContextKey**：org.springframework.scheduling.quartz.SchedulerFactoryBean这个类中把spring上下文以key/value的方式存放在了quartz的上下文中了，可以用applicationContextSchedulerContextKey所定义的key得到对应的spring上下文.

**configLocation**：用于指明quartz的配置文件的位置.

**Quartz集群12张表**：

<table style=""> 
 <tbody> 
  <tr> 
   <td>表名</td> 
   <td>描述</td> 
  </tr> 
  <tr> 
   <td>QRTZ_CALENDARS</td> 
   <td>以Blob类型存储Quartz的Calendar信息.</td> 
  </tr> 
  <tr> 
   <td>QRTZ_CRON_TRIGGERS</td> 
   <td>存储Cron&nbsp;Trigger,包括Cron表达式和时区信息.</td> 
  </tr> 
  <tr> 
   <td>QRTZ_FIRED_TRIGGERS</td> 
   <td>存储与已触发的Trigger相关的状态信息,以及相联Job的执行信息.</td> 
  </tr> 
  <tr> 
   <td>QRTZ_PAUSED_TRIGGER_GRPS</td> 
   <td>存储已暂停的Trigger组的信息。</td> 
  </tr> 
  <tr> 
   <td>QRTZ_SCHEDULER_STATE</td> 
   <td>存储少量的有关Scheduler的状态信息,和别的cheduler&nbsp;实例(假如是用于一个集群中)</td> 
  </tr> 
  <tr> 
   <td>QRTZ_LOCKS</td> 
   <td>存储程序的非观锁的信息(假如使用了悲观锁)。</td> 
  </tr> 
  <tr> 
   <td>QRTZ_JOB_DETAILS</td> 
   <td>存储每一个已配置的Job的详细信息。</td> 
  </tr> 
  <tr> 
   <td>QRTZ_JOB_LISTENERS</td> 
   <td>存储有关已配置的JobListener的信息。</td> 
  </tr> 
  <tr> 
   <td>QRTZ_SIMPLE_TRIGGERS</td> 
   <td>存储简单的Trigger,包括重复次数,间隔,以及已触的次数。</td> 
  </tr> 
  <tr> 
   <td>QRTZ_BLOG_TRIGGERS</td> 
   <td>Trigger作为Blob类型存储(用于Quartz用户用JDBC创建他们自己定制的Trigger类型,JobStore并不知道如何存储实例的时候)</td> 
  </tr> 
  <tr> 
   <td>QRTZ_TRIGGER_LISTENERS</td> 
   <td>存储已配置的TriggerListener的信息.</td> 
  </tr> 
  <tr> 
   <td>QRTZ_TRIGGERS</td> 
   <td>存储已配置的Trigger的信息.</td> 
  </tr> 
 </tbody> 
</table>

QRTZ\_TRIGGERS表中TRIGGER\_STATE字段显示任务的属性：

WAITING:等待    
  PAUSED:暂停   
  ACQUIRED:正常执行   
  BLOCKED：阻塞   
  ERROR：错误

**Cron表达式**

Quartz使用类似于Linux下的Cron表达式定义时间规则，Cron表达式由6或7个由空格分隔的时间字段组成。

Cron表达式时间字段：

<table style=""> 
 <tbody> 
  <tr> 
   <td>位置</td> 
   <td>时间域名</td> 
   <td>允许值</td> 
   <td>允许的特殊字符</td> 
  </tr> 
  <tr> 
   <td>1</td> 
   <td>秒</td> 
   <td>0-59</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;/</td> 
  </tr> 
  <tr> 
   <td>2</td> 
   <td>分钟</td> 
   <td>0-59</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;/</td> 
  </tr> 
  <tr> 
   <td>3</td> 
   <td>小时</td> 
   <td>0-23</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;/</td> 
  </tr> 
  <tr> 
   <td>4</td> 
   <td>日期</td> 
   <td>1-31</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;?&nbsp;/&nbsp;L&nbsp;W&nbsp;C</td> 
  </tr> 
  <tr> 
   <td>5</td> 
   <td>月份</td> 
   <td>1-12</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;/</td> 
  </tr> 
  <tr> 
   <td>6</td> 
   <td>星期</td> 
   <td>1-7</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;?&nbsp;/&nbsp;L&nbsp;C&nbsp;#</td> 
  </tr> 
  <tr> 
   <td>7</td> 
   <td>年(可选)</td> 
   <td>空值1970-2099</td> 
   <td>,&nbsp;-&nbsp;*&nbsp;/</td> 
  </tr> 
 </tbody> 
</table>

Cron表达式示例：

<table style=""> 
 <tbody> 
  <tr> 
   <td>表达式</td> 
   <td>说明</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;0&nbsp;12&nbsp;*&nbsp;*&nbsp;?&nbsp;"</td> 
   <td>每天12点运行</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;*&nbsp;*&nbsp;?"</td> 
   <td>每天10:15运行</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;*&nbsp;*&nbsp;?&nbsp;2011"</td> 
   <td>2011年的每天10：15运行</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;*&nbsp;14&nbsp;*&nbsp;*&nbsp;?"</td> 
   <td>每天14点到15点之间每分钟运行一次，开始于14:00，结束于14:59。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;0/5&nbsp;14&nbsp;*&nbsp;*&nbsp;?"</td> 
   <td>每天14点到15点每5分钟运行一次，开始于14:00，结束于14:55。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;0/5&nbsp;14,18&nbsp;*&nbsp;*&nbsp;?"</td> 
   <td>每天14点到15点每5分钟运行一次，此外每天18点到19点每5钟也运行一次。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;0-5&nbsp;14&nbsp;*&nbsp;*&nbsp;?"</td> 
   <td>每天14:00点到14:05，每分钟运行一次。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;10,44&nbsp;14&nbsp;?&nbsp;3&nbsp;WED"</td> 
   <td> <p style="padding-bottom:0px; list-style-type:none; margin:0px auto; padding-left:0px; padding-right:0px; padding-top:0px"> 3月每周三的14:10分到14:44，每分钟运行一次。</p> </td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;?&nbsp;*&nbsp;MON-FRI"</td> 
   <td>每周一，二，三，四，五的10:15分运行。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;15&nbsp;*&nbsp;?"</td> 
   <td>每月15日10:15分运行。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;L&nbsp;*&nbsp;?"</td> 
   <td>每月最后一天10:15分运行。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;?&nbsp;*&nbsp;6L"</td> 
   <td>每月最后一个星期五10:15分运行。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;?&nbsp;*&nbsp;6L&nbsp;2007-2009"</td> 
   <td>在2007,2008,2009年每个月的最后一个星期五的10:15分运行。</td> 
  </tr> 
  <tr> 
   <td>"0&nbsp;15&nbsp;10&nbsp;?&nbsp;*&nbsp;6#3"</td> 
   <td>每月第三个星期五的10:15分运行。</td> 
  </tr> 
 </tbody> 
</table>

来源：http://xsxjb.iteye.com/blog/1068151

[quartz]: http://www.so.com/s?q=quartz&ie=utf-8&src=se_lighten_f