一,最近在开发任务调度（job）这一块,在此进行总结
1,在jdk中提供了基本的Timer,TimerTask可以用作其本的任务调度操作,不过功能不够强大
2,quartz框架为我们提供了一系列的任务调度操作,基本的应用操作等都很容易理解.(JobDetail,Trigger)
二,由于公司要使quartz与公司建模端平台互相协作,产生的问题
建模端(提供xml配置与job类)----------------------中间层(定时扫描xml,根据xml语义的改变而改变)
1,可配置,在起初时使用的是1.6版本,这个版本没有提供插件配置机制,在为如何定义xml,如何让线程合理操作烦恼,看了下官方文档,原来1.8中已经提供了可配置的插件机制,非常方便,
org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin(可认真查看此插件的源码) 这个类提供了全套的服务.,
.可在定义的xml中配置想要的job,此插件还提供了对此xml隔时对此进行查询操作,对xml中配置的内容意义识别(可删除,可替换)
2,在部暑到tomcat上出现了一个问题,那就是webappClassloader缓存了任务调度的xml,也就是说建模端对xml进行更改或是添加job,并不会被读取..
.解决方案,跟踪了下源码发现插件中查找文件是使用了(classloader getResourceAsStream(String name))进行查找,
故自己重新写了个自定义的classloader,用来专门加载quartz
import java.io.File;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
/**
* 任务调度时查询classpath下的scheduler.xml时，
* webappclassloader使用了缓存，不能及时更新
* 该文件下的job，故重写classloader
*
* @author wu_quanyin(09817)
* @version 1.0
* @date 2010-08-19 下午01:53:25
*/
public class QuartzClassLoader extends URLClassLoader {
public QuartzClassLoader(File directoryPath, ClassLoader parent) {
super(new URL[0],parent);
if(directoryPath.isDirectory()){
File[] files=directoryPath.listFiles();
for(int i=0;i<files.length;i++){
try {
this.addURL(files[i].toURI().toURL());
} catch (MalformedURLException e) {
e.printStackTrace();
}
}
}
}
/**
* quartz查找scheduler.xml时，使用些方法查找
*/
public InputStream getResourceAsStream(String name) {
URL url = getResource(name);
try {
return url != null ? url.openStream() : null;
} catch (IOException e) {
return null;
}
}
public URL getResource(String name) {
URL[] urls=this.getURLs();
for(int i=0;i<urls.length;i++){
if(urls[i].getPath().indexOf(name)!=-1){
return urls[i];
}
}
return super.getResource(name);
}
}
然后设置进(parent 为webappclassloader先查找quartzclassloader再查找parent)
/*
* CopyRright (c) 2009-2015 www.fdauto.com
*/
package com.fdauto.bws.common.scheduler;
import java.io.File;
import java.lang.reflect.Method;
import java.util.Properties;
import com.fdauto.bws.common.logger.SystemLogsHelper;
import com.fdauto.bws.service.config.BWSConfigHelper;
/**
* 任务调度
*
* @author wu_quanyin(09817)
* @version 1.0
* @date 2010-5-5 上午07:54:01
*/
public class QuartzStdScheduler {
private Properties ps;
private Object schedulerObject;
private static QuartzStdScheduler inst;
private static String jobs_full_path;
private static String quartz_classpath;
private static String scheduler_name;
private QuartzClassLoader quartzClassLoader;
static {
jobs_full_path = BWSConfigHelper.getBWSConfig().getProperties()
.getProperty("jobFiles");
quartz_classpath = jobs_full_path.substring(0, jobs_full_path
.lastIndexOf("/"));
scheduler_name = jobs_full_path.substring(jobs_full_path
.lastIndexOf("/") + 1);
}
private QuartzStdScheduler() {
initial();
schedulerObject = createScheduler();
}
/** 单例模式 */
public static QuartzStdScheduler getInstance() {
if (inst == null) {
inst = new QuartzStdScheduler();
}
return inst;
}
/** 对属性进行初始化 */
private void initial() {
// -----------------------------------------以自定义的classLoader来控制quartz的执行
quartzClassLoader = new QuartzClassLoader(new File(this.getClass()
.getClassLoader().getResource(quartz_classpath).getFile()),
this.getClass().getClassLoader());
Thread.currentThread().setContextClassLoader(quartzClassLoader);
// --------------------------------------------------------------初始化quartz的环境
ps = new Properties();
ps.setProperty(QuartzProperties.PROP_SCHED_INSTANCE_NAME,
"DefaultQuartzScheduler");
ps.setProperty(QuartzProperties.PROP_THREAD_COUNT, "10");
ps.setProperty(QuartzProperties.PROP_THREAD_POOL_CLASS,
"org.quartz.simpl.SimpleThreadPool");
ps.setProperty(QuartzProperties.PROP_JOB_STORE_CLASS,
"org.quartz.simpl.RAMJobStore");
ps.setProperty("org.quartz.plugin.triggHistory.class",
"org.quartz.plugins.history.LoggingJobHistoryPlugin");
ps.setProperty(QuartzProperties.PROP_PLUGIN_CLASS,
"org.quartz.plugins.xml.XMLSchedulingDataProcessorPlugin");
ps.setProperty(QuartzProperties.PROP_PLUGIN_SCANINTERVAL, "180");
/**
* 根据指定job文件进行创建,以逗号分隔文件,在bws.xml中配置路径
* com/fdauto/bws/common/scheduler/quartz_jobs.xml,
* com/fdauto/bws/common/scheduler/quartz_jobs2.xml
*/
ps.setProperty(QuartzProperties.PROP_PLUGIN_FILESNAME, scheduler_name);
}
/**
* 创建scheduler
*
* @return
*/
private Object createScheduler() {
try {
Object schedulerFactoryObject = quartzClassLoader.loadClass(
"org.quartz.impl.StdSchedulerFactory").getConstructor(
new Class[] { Properties.class }).newInstance(
new Object[] { ps });
Method method = schedulerFactoryObject.getClass().getMethod(
"getScheduler", new Class[] {});
Object schedulerObject = method.invoke(schedulerFactoryObject,
new Object[] {});
return schedulerObject;
} catch (Exception e) {
SystemLogsHelper.error("创建调度器失败", e.getCause());
e.printStackTrace();
}
return null;
}
/** 执行任务调度器里的方法 */
private Object invokeSchedule(String methodName, Object... objects) {
Class<?>[] clazzs = new Class[objects.length];
for (int i = 0; i < objects.length; i++) {
clazzs[i] = objects[i].getClass();
}
try {
Method method = schedulerObject.getClass().getMethod(methodName,
clazzs);
return method.invoke(schedulerObject, objects);
} catch (Exception e) {
SystemLogsHelper.error("调度器执行" + methodName + "失败", e.getCause());
e.printStackTrace();
}
return null;
}
/** 启动调度器 */
public void start() {
if (this.schedulerObject != null) {
SystemLogsHelper.info("开始启动任务调度器.......");
this.invokeSchedule("start", new Object[] {});
SystemLogsHelper.info("任务调度器启动完成！");
}
}
/** 暂停调度器 */
public void pause() {
if (this.schedulerObject != null) {
this.invokeSchedule("standby", new Object[] {});
}
}
/** 停止调度器 */
public void stop() {
if (this.schedulerObject != null) {
// 加true意思是停止之前完成正在执行的 Job,false是立即停止
this.invokeSchedule("shutdown", new Object[] {});
}
}
/** 中断job,要配合Job implements InterruptableJob 使用 */
public void interruptJob(String jobName, String groupName) {
if (this.schedulerObject != null) {
this
.invokeSchedule("interrupt", new Object[] { jobName,
groupName });
}
}
/** 删除job */
public void deleteJob(String jobName, String groupName) {
if (this.schedulerObject != null) {
this.invokeSchedule("deleteJob",
new Object[] { jobName, groupName });
}
}
}
之后可对这个类进行启动等操作,也可定时操作任务调度的xml
注:
以上只能通过反射的方式调用，由于classloader的安全机制，同样的类，父classloader装载的类 和 子classloader装载的类不能互相转换。不能够用强制转换
http://waterdh.iteye.com/blog/520399
分享到：
相关推荐
Quartz任务调度--详细教程,讲的非常详细
基于Quartz.Net组件实现定时任务调度-QuartzServer
quartz quartz-1.8.6 dbTables quartz动态任务调度需要的数据库脚本。
Quartz--JAVA定时任务\Java应用：Java调度任务和Spring Quartz （1）
spring任务调度（Quartz ）非常基础，
quartz 定时任务调度
spring quartz 时间任务调度框架 spring quartz 时间任务调度框架 spring quartz 时间任务调度框架
quartz：是一个任务调度框架，通过触发器设置作业的定时运行规则，来执行定时任务。相当于数据库中的 Job、Windows 的计划任务、Unix/Linux 下的 Cron，但 Quartz 可以把排程控制的更精细。把一系列任务自动安置到一...
Quartz-2.2.1 任务调度框架在Java项目中的使用实例 Demo 在这个小Demo 中使用了Java 类的反射机制，通用的项目实例，高度抽象的实例。 在业务需求不是很复杂的情况下，完全可以减少因为使用Quartz任务调度框架的代码...
Spring Quartz定时任务所需要的6个jar包，找到6个可是不容易哦。commons-logging-1.2.jar,commons-logging-1.2.jar,jta.jar,quartz-1.6.6.jar,commons-collections-3.2.jar,spring.jar
Quartz任务调度器与spring整合，做项目的时候常听测试说谁在起着quartz，也不知道是啥，问了下同事，就是定时去执行某些任务的，刚好bug比较少，学习了一下~
Spring整合任务调度框架Quartz，本文档详细介绍了Spring整合任务调度框架Quartz，希望可以帮助学习者
使用Quartz调度任务，根据需要人为的终止某个任务，适用于很多常见的场景
任务调度Quartz框架 任务调度Quartz框架
Quartz.net作业调度自定义定时执行任务多任务执行c#，定时执行任务，如超时取消订单，自动确认收货等等
任务调度系统基于Quartz.net
定时任务执行(任务调度) 框架中集成springboot+quartz 前端 html js layui vue 等 所有功能均已实现
Spring+Quartz实现任务调度的小例子.本来不要资源分的，可是CSDN发布资源最低要求填写分值为1分，没办法了。
Java使用quartz实现任务调度定时任务