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参数的。

但是只能说以上代码只是个解决思路，但是任务调度真正的知识不限于这么少。例如，在任务执行过程中强制终止，休眠，更改表达式等。

供参考：任务调度暂停等实现