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参数的。
但是只能说以上代码只是个解决思路，但是任务调度真正的知识不限于这么少。例如，在任务执行过程中强制终止，休眠，更改表达式等。
供参考：任务调度暂停等实现
来自：http://blog.csdn.net/ccyours/article/details/43273663