时间戳

首页 > 技术文章 > sping的quartz设置定时任务

sping的quartz设置定时任务

jinzhiming 2017-01-09 17:36 原文

除了spring相关的jar包之外，还需要引入quartz-all-1.8.6.jar

下载地址：http://www.quartz-scheduler.org/downloads/

spring配置文件增加quartz-bean.xml和quartz-set.xml

quartz-bean.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:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
            http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
            http://www.springframework.org/schema/aop 
            http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
            http://www.springframework.org/schema/tx 
            http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">
           
    <!-- 测试  -->
    <bean id="testQuartzTask" class="com.tech.jin.quartz.TestQuartzTask"/>
    
</beans>

quartz-set.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:aop="http://www.springframework.org/schema/aop"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xsi:schemaLocation="http://www.springframework.org/schema/beans 
            http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
            http://www.springframework.org/schema/aop 
            http://www.springframework.org/schema/aop/spring-aop-3.0.xsd
            http://www.springframework.org/schema/tx 
            http://www.springframework.org/schema/tx/spring-tx-3.0.xsd">

    <!-- 定时任务定义 -->
    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<!--         <property name="dataSource" ref="dataSource"></property>
        <property name="configLocation" value="classpath:spring-quartz.properties" /> 用于数据库中配置任务，集群使用-->
        <property name="overwriteExistingJobs" value="true" /><!--可选，QuartzScheduler 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了 -->
        <property name="startupDelay" value="1" /><!-- 启动完1秒后执行任务 -->
        <property name="autoStartup" value="true" /><!-- 自动启动 --> 
        <property name="quartzProperties">
           <props>
              <prop key="org.quartz.threadPool.threadCount">50</prop>
           </props>
        </property>
        <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />
        
        <property name="triggers">
            <list>
                <!-- 配置多个任务，继续在list中添加 -->
                <ref bean="testQuartzTaskTrigger" /><!-- 测试自动任务 -->
                
            </list>
        </property>
    </bean>
    
    <!-- 测试自动任务 -->
    <bean id="testQuartzTaskTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail">
            <ref bean="testQuartzTaskJobDetail"/>
        </property>
        <property name="cronExpression">
             <value>0/10 * * * * ? </value>
        </property>
        <property name="jobDataAsMap">
            <map>
                <entry key="jobClass" value="testQuartzTask"/>
                <entry key="jobName" value="测试自动任务"/>
            </map>
         </property>
    </bean>
    
    <!-- MethodInvokingJobDetailFactoryBean不支持序列化 --> 
     <bean id="testQuartzTaskJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject"><ref bean="testQuartzTask"/></property>    
        <property name="targetMethod"><value>doTask</value></property>   
        <property name="concurrent" value="false"/><!-- concurrent(并发) : false表示等上一个任务执行完后再开启新的任务 -->
    </bean>
    
    <!-- 这种支持job序列化，但是这个jobClass对应的类，必须实现job，有execute方法-->
<!--      <bean id="testQuartzTaskJobDetail" class="org.springframework.scheduling.quartz.JobDetailFactoryBean">  
        <property name="jobClass" value="com.tech.jin.quartz.TestQuartzTask"></property>  
        <property name="durability" value="true" />
        <property name="requestsRecovery" value="true" />   
    </bean> -->
    
</beans>

 

 

使用MethodInvokingJobDetailFactoryBean调用的类TestQuartzTask：

package com.tech.jin.quartz;

import org.apache.log4j.Logger;

public class TestQuartzTask {
    
    private Logger logger = Logger.getLogger(TestQuartzTask.class);
    
    public void doTask(){
        logger.info("66666666666666666666666");
    }
}

 

使用JobDetailFactoryBean调用的类TestQuartzTask：

package com.tech.jin.quartz;

import org.apache.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class TestQuartzTask implements Job{
    
    private Logger logger = Logger.getLogger(TestQuartzTask.class);
    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        logger.info("5555555");
        
    }


}

 

 

除此之外，还需要将quartz-bean.xml 和quartz-set.xml引入到ApplicationContext.xml文件中（推荐）

<import resource="spring-quartz.xml"/>

或者在web.xml中添加上读取sping配置文件的配置：classpath:spring/quartz-*xml。

  <context-param>
    <param-name>contextConfigLocation</param-name>
    <param-value>
        classpath:spring/ApplicationContext.xml;
        classpath:spring/quartz-*xml
    </param-value>
  </context-param>

 

--------------------------------------------------------------------------------------------------------------------------------------------------------

 

如果需要集群使用，就打开quartz-set.xml中SchedulerFactoryBean注掉的datasource和配置文件。

每个server把将要及正在运行的job所有状态都即时同步到中央数据库,然后再次触发调用时从数据库中分析是否已有别的server正在运行相同job

(同名同定时时间点的job属于相当job),如果相同job正在别的server运行,那么当前server忽略本次运行的job.

Quartz的 Task（11 张表）实例化采用数据库存储，基于数据库引擎及 High-Available 的策略（集群的一种策略）自动协调每个节点的 Quartz。

spring-quartz.properties：

#==============================================================  
#Configure Main Scheduler Properties  
#==============================================================   
org.quartz.scheduler.instanceName = defaultScheduler
org.quartz.scheduler.instanceId = AUTO

#==============================================================  
#Configure JobStore  
#============================================================== 
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.tablePrefix = QRTZ_
org.quartz.jobStore.isClustered = true
org.quartz.jobStore.clusterCheckinInterval = 20000  
org.quartz.jobStore.dataSource = myDS
org.quartz.jobStore.maxMisfiresToHandleAtATime = 1
org.quartz.jobStore.misfireThreshold = 120000
org.quartz.jobStore.txIsolationLevelSerializable = true
 
#==============================================================  
#Configure ThreadPool  
#============================================================== 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

#==============================================================
#Skip Check Update
#update:true
#not update:false
#==============================================================
org.quartz.scheduler.skipUpdateCheck = true 

#============================================================================   
# Configure Plugins    
#============================================================================      
org.quartz.plugin.triggHistory.class = org.quartz.plugins.history.LoggingJobHistoryPlugin   
org.quartz.plugin.shutdownhook.class = org.quartz.plugins.management.ShutdownHookPlugin
org.quartz.plugin.shutdownhook.cleanShutdown = true

数据库的sql版本要和squartz完全一致,在下载解压后的quartz\quartz-1.8.6\docs\dbTables文件夹在都有

tables_mysql.sql、tables_oracle.sql等...

推荐阅读