Spring+quartz 动态任务调度

需求是这样的:系统中会有很多的执行时间,三个或者四个这样,不确定,以后可能是五个!当用户在页面添加执行时间时,我们后台也要对应执行用户添加的时间。

数据库设计:

DROP TABLE IF EXISTS `test_time_task`;
CREATE TABLE `test_time_task` (
  `status` int(11) DEFAULT NULL COMMENT '状态:0为正常,1为禁用',
  `job` varchar(255) CHARACTER SET utf8 DEFAULT NULL COMMENT '执行时间',
  `id` int(11) DEFAULT NULL COMMENT '编号'
) ENGINE=InnoDB DEFAULT CHARSET=utf-8;
-- ----------------------------
-- Records of test_time_task
-- ----------------------------
INSERT INTO `test_time_task` VALUES ('0', '0 30 9 * * ?', '1');
INSERT INTO `test_time_task` VALUES ('0', '0 30 11 * * ?', '2');
INSERT INTO `test_time_task` VALUES ('0', '0 30 16 * * ?', '3');

查询语句,其中的#{hourMinute}为查询条件,格式——‘12:11‘:

select  case when (select job
         from (select job,RTRIM(substr(substr(job,6,7),1,2)) as hour,  LTRIM(substr(job,2,3)) as minute from test_time_task where  status = 0 ) as mytable 
        where 
         str_to_date( CONCAT(hour,':',minute),'%k:%i')>  str_to_date(  #{hourMinute} ,'%k:%i')  order by str_to_date(hour,'%k') LIMIT 1) is null then
        (select job
         from (select job,RTRIM(substr(substr(job,6,7),1,2)) as hour,  LTRIM(substr(job,2,3)) as minute from test_time_task where  status = 0 ) as mytable 
         order by  str_to_date( CONCAT(hour,':',minute),'%k:%i') LIMIT 1) else
         (select job
         from (select job,RTRIM(substr(substr(job,6,7),1,2)) as hour,  LTRIM(substr(job,2,3)) as minute from test_time_task where  status = 0 ) as mytable
        where   
         str_to_date( CONCAT(hour,':',minute),'%k:%i')>  str_to_date(  #{hourMinute} ,'%k:%i')  order by str_to_date(hour,'%k') LIMIT 1) end

Spring配置文件:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
    <!-- 被执行类 -->
    <bean id="testQuarzt" class="cmcc.gz.pmp.timetest.service.ScheduleInfoService">
        <property name="scheduler" ref="schedulerFactory" />
    </bean>
 
    <!-- 将testQuarzt注入到job中 -->
    <bean id="testQuartzJob"
        class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject" ref="testQuarzt" />
        <property name="targetMethod" value="loadJob" />
        <property name="concurrent" value="false" />
    </bean>
 
    <!-- 将job注入到定时触发器 -->
    <bean id="testTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
        <property name="jobDetail" ref="testQuartzJob" />
        <property name="cronExpression">
            <value>0/1 * * * * ?</value>
        </property>
    </bean>
 
    <!-- 将触发器注入任务工程 -->
    <bean id="schedulerFactory"
        class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="testTrigger" />
            </list>
        </property>
    </bean>
</beans>
java程序代码:

import java.text.ParseException;
import java.util.Date;
 
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.CronTriggerBean;
 
import cmcc.gz.pmp.timetest.db.mapper.JobMapper;
import cmcc.gz.pmp.util.CommonDate;
 
/**
 * 
 * 类描述:时间任务调度测试方法
 * @author 胡汉三
 * 创建时间:2014-5-26 下午6:11:55
 *
 */
public class ScheduleInfoService {
     
    @Autowired  
    private JobMapper mapper;
     
    private Scheduler scheduler;
    // 设值注入,通过setter方法传入被调用者的实例scheduler  
    public void setScheduler(Scheduler scheduler) {     
        this.scheduler = scheduler;     
    }    
     
    public void loadJob() throws SchedulerException, ParseException{
        Object j = mapper.findJob(CommonDate.getTimeNow(new Date())); 
        // 运行时可通过动态注入的scheduler得到trigger,注意采用这种注入方式在有的项目中会有问题,如果遇到注入问题,可以采        取在运行方法时候,获得bean来避免错误发生。  
        CronTriggerBean trigger =  (CronTriggerBean)scheduler.getTrigger("testTrigger",Scheduler.DEFAULT_GROUP);
        String originConExpression = trigger.getCronExpression();
        // 如果相等,则表示用户并没有重新设定数据库中的任务时间,这种情况不需要重新rescheduleJob 也不需要去执行任务 
        if(!originConExpression.equalsIgnoreCase(j.toString())){
             
            //如果不是系统启动时的任务,就去执行它
            if(!originConExpression.equalsIgnoreCase("0/1 * * * * ?")){
                /** 执行任务 **/  
                test();
            }
            System.out.println(j.toString());
            trigger.setCronExpression(j.toString());  
            scheduler.rescheduleJob("testTrigger", Scheduler.DEFAULT_GROUP, trigger);  
        }   
    }
     
    /**
     * 执行任务
     */
    public void test(){
        System.out.println("XML任务进行中...");  
    } 
     
 
}

测试时,当我把我的系统时间改为九点29的时候等到30就会执行,结果跟过程都正常,
更改到十一点半正常,更改到十六点半正常,当我更改到第二天九29的时候,执行就出错了:

Invocation of method ‘resetJob‘ on target class [class cmcc.gz.pmp.timetest.service.ScheduleInfoService$$EnhancerByCGLIB$$11b080f3] failed; nested exception is org.springframework.transaction.CannotCreateTransactionException: Could not open JDBC Connection for transaction; nested exception is com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure

解决办法:

Mysql服务器默认的“wait_timeout”是8小时,也就是说一个connection空闲超过8个小时,Mysql将自动断开该connection。
它默认是8小时,我们手动改大一些,在测试就通过了!

查看:show global variables like ‘wait_timeout‘;
修改:set global wait_timeout=86999;


帖子地址:点击打开链接




Spring+quartz 动态任务调度,古老的榕树,5-wow.com

郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。