首页 > 代码库 > Spring 和Quartz2 整合实现动态定时任务
Spring 和Quartz2 整合实现动态定时任务
问题起始：
最近要做一个定时任务，使用Spring的定时任务配置也可以实现。但是很多时候，我们常常会遇到需要动态的添加或修改任务，而spring中所提供的定时任务组件却只能够通过修改xml中trigger的配置才能控制定时任务的时间以及任务的启用或停止，这在带给我们方便的同时也失去了动态配置任务的灵活性。我搜索了一些网上的解决方法，都没有很好的解决这个问题，而且大多数提到的解决方案都停留在Quartz 1.x系列版本上，所用到的代码和API已经不能适用于新版本的Spring和Quartz。那么让我们来解决它吧、
知识点补充：
1、quartz任务调度快速入门：
任务调度快速入门
该资料使用 的是旧版本的quarzt,里面的实例化 jobdetail 和 Trigger的方式都不适用了。但是，对很多基础的概念解释的相当清晰。推荐只看概念，加深理解任务调度的工作机制。
2、带参数执行 任务调度
在job中，不可能不需要参数，这时候参数的传递就显得尤为重要了。quartz2提供参数传递方法是：
1).jobDetail.getJobDataMap().put("timerconfig", timerConfig); 将 timerConfig 以map集合的形式传递给 任务执行时的上下文。
2). (TimerConfig) context.getJobDetail().getJobDataMap().get("timerconfig"); context是job接口中execute(JobExecutionContext context)；将刚刚传递的timerconfig取出
如果timerconfig是对象，则用get();其他的则使用对应的get方法即可。
3、如何实例化JobDetail
在quartz2中，实例化任务的方式变化较大，是使用builder进行实例化。 JobDetail jobDetail = newJob(MyTask.class) .withIdentity(name, Groupname).build();
4、如何实例化Trigger
Trigger trigger = newTrigger()
.withIdentity(name, Groupname)
.startNow()
.withSchedule(
CronScheduleBuilder
.cronSchedule(new CronExpression(
expression))).build();
此版本不再采用1版本的 SimpleTrigger /cronTrigger.而是在使用调度器（schedule）的时候选择是用 SimpleScheduleBuilder还是 CronScheduleBuilder。
例如： CronScheduleBuilder .cronSchedule(new CronExpression( expression))//采用cronScheduleBuilder生产 cronTrigger定时器
SimpleScheduleBuilder .SimpleSchedule()//采用SimpleScheduleBuilder生产 SimpleTrigger定时器
问题解决：
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:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
">
<!-- 调度器 -->
<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz.SchedulerFactoryBean" lazy-init="false">
</bean>
</beans>Mytask,java
/*
* @(#)MyTask.java V0.0.1 2015-1-28, 下午8:34:14
*
*/
package com.jpgk.system.timer.config;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import com.jpgk.mq.model.TimerConfig;
public class MyTask implements Job {
private String id;
private String category;
private String destination;
private String uri;
private String clientid;
private String content;
private String expression;
private String method;
private TimerConfig timerConfig;// 一组timerconfig数据对象
// 任务执行覆写
public void execute(JobExecutionContext context)
throws JobExecutionException {
TimerConfig timerConfig = (TimerConfig) context.getJobDetail()
.getJobDataMap().get("timerconfig");
// 属性赋值
initPrivate(timerConfig);
System.out.println(timerConfig.getContent());
}
// 初始化私有属性，这个方法的存在是为了解决 线程池在每次反射实例化MyTask的时候使用无参构造函数，但任务需要这些私有属性作为任务执行的参数
public void initPrivate(TimerConfig timerconfig) {
timerConfig = timerconfig;
category = timerConfig.getCategory().toUpperCase();// 取出任务类型
uri = timerConfig.getUri();// 取出请求路径
destination = timerConfig.getDestination();// 取出目的地
clientid = timerConfig.getClientid();// 客户ID
expression = timerConfig.getExpression();// 表达式
content = timerConfig.getContent();// 请求参数,例如 a=1&b=2
method = timerConfig.getMethod().toUpperCase();
}
}调度页面：Testabc.java
/*
* @(#)Testabc.java V0.0.1 2015-1-28, 下午8:06:03
*
* Copyright 2015 www.ifood517.com. All rights reserved.
* www.ifood517.com PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
*/
package com.jpgk.mq.temp;
import static org.quartz.JobBuilder.newJob;
import static org.quartz.TriggerBuilder.newTrigger;
import java.util.HashMap;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.quartz.CronExpression;
import org.quartz.CronScheduleBuilder;
import org.quartz.JobDetail;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.impl.StdScheduler;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.jpgk.mq.model.TimerConfig;
import com.jpgk.mq.service.TimerConfigService;
import com.jpgk.system.timer.config.MyTask;
public class Testabc {
private static StdScheduler stdScheduler;
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext(
"classpath:applicationContext.xml");
// 实例化线程池
stdScheduler = (StdScheduler) context.getBean("schedulerFactoryBean");
// 取出数据库配置信息
TimerConfigService timerConfigService = (TimerConfigService) context
.getBean("timerstaskservice");
List<TimerConfig> configs = timerConfigService.selectAll();
for (int i = 0; i < configs.size(); i++) {
// 进行任务的调度
/*
* String category = configs.get(i).getCategory();// 取出任务类型 String
* uri = configs.get(i).getUri();// 取出请求路径 String destination =
* configs.get(i).getDestination();// 取出目的地 String clientid =
* configs.get(i).getClientid();// 客户ID String expression =
* configs.get(i).getExpression();// 表达式 String content =
* configs.get(i).getContent();// 请求参数,例如 a=1&b=2 String method =
* configs.get(i).getMethod().toUpperCase();//请求方式
*/switch (configs.get(i).getCategory()) {
case "HTTP":
// 必须要请求路径
if (configs.get(i).getUri() == ""
|| configs.get(i).getUri() == null) {
try {
throw (new Exception("请求地址不能为空"));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
// 必须要请频率
if (configs.get(i).getExpression() == ""
|| configs.get(i).getExpression() == null) {
try {
throw (new Exception("执行频率不能为空"));
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if (configs.get(i).getMethod().toUpperCase().equals("GET")) {
// 重新构造uri
configs.get(i).setUri(
configs.get(i).getUri() + "?"
+ configs.get(i).getContent());
} else {
// post须考虑其他方式
System.out.println("aaaa");
}
// System.out.println("category->"+category+"uri->"+uri+"destination->"+destination+"clientid->"+clientid+"expression->"+expression+"content->"+content+"method->"+method);
break;
default:
break;
}
// 构造任务
JobDetail jobDetail = initJobdetail(configs.get(i).getClientid(),
configs.get(i).getClientid() + "Group", configs.get(i));
// 构造定时器
Trigger trigger = initTriger(2, configs.get(i).getClientid(),
configs.get(i).getClientid() + "Group", configs.get(i)
.getExpression());
// 注册定时器和任务
try {
stdScheduler.scheduleJob(jobDetail, trigger);
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}
/**
* 实例化一个Trigger,根据type返回simple/Cron Trigger
*/
private static Trigger initTriger(int type, String name, String Groupname,
String expression) {
try {
if (type == 1) {
// 1 simpleTrigger
// Simp
} else if (type == 2) {
// conTrigger
Trigger trigger = newTrigger()
.withIdentity(name, Groupname)
.startNow()
.withSchedule(
CronScheduleBuilder
.cronSchedule(new CronExpression(
expression))).build();
return trigger;
}
} catch (Exception e) {
}
return null;
}
/**
* 实例化一个JobDetail
*/
private static JobDetail initJobdetail(String name, String Groupname,
TimerConfig timerConfig) {
JobDetail jobDetail = newJob(MyTask.class)
.withIdentity(name, Groupname).build();
// 在每次添加任务的时候要添加额外的参数，这里我传一个对象进行任务私有属性的初始化
jobDetail.getJobDataMap().put("timerconfig", timerConfig);
return jobDetail;
}
}
以上代码涉及到数据库的数据，忽略即可。看看如何实例化JobDetail和Trigger的。留意下怎么在JobDetail中传递TimerConfig参数的。
但是只能说以上代码只是个解决思路，但是任务调度真正的知识不限于这么少。例如，在任务执行过程中强制终止，休眠，更改表达式等。
供参考：任务调度暂停等实现
Spring 和Quartz2 整合实现动态定时任务