定时器quartz的应用

yahaitt

浏览: 760776 次
性别:
来自: 杭州

最近访客更多访客>>

akingde

xuriyunhai

llx156158574

sqllib

博主相关

博客

微博

相册

留言

关于我

文章分类

社区版块

存档分类

博客分类：

java web应用

quartz 应用服务器 XML Web 配置管理

用quartz可以实现web或非web模式的定时器

1、配置文件

quartz_job.xml

xml version="1.0" encoding="UTF-8"?>
<quartz xmlns="http://www.opensymphony.com/quartz/JobSchedulingData"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
overwrite-existing-jobs="true">
<job>
<job-detail>
<name>yayaittname>
<group>CRAWLER_JOB_GROUPgroup>
<description>send task per daydescription>
<job-class>com.yahaitt.quartz.QuartzSystemjob-class>
<job-data-map allows-transient-data="true">
<entry>
<key>usernamekey>
<value>wujinlivalue>
entry>
<entry>
<key>passwordkey>
<value>mahaibovalue>
entry>
job-data-map>
job-detail>
<trigger>
<cron>
<name>hourTaskJob-triggername>
<group>CRAWLER_TRIGGER_GROUPgroup>
<job-name>yayaittjob-name>
<job-group>CRAWLER_JOB_GROUPjob-group>
<cron-expression>1/12 * * * * ?cron-expression>
cron>
trigger>
job>
quartz>

该定时器实现了每12秒触发类com.yahaitt.quartz.QuartzSystem的execute函数，并通过java-data-map标签来实现参数的传递，如果不需要传递参数，可以将整个java-data-map标签去除。

需要注意的是job-detail与trigger中各子标签间的关系，比如trigger中job-name和job-group要与job-detail中的name和group对应。

可以通过在quartz标签中添加多个job来实现多个定时器的管理。

2、定义org.quartz.Job接口的实现类

QuartzSystem.java

package com.yahaitt.quartz;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class QuartzSystem implements Job {
public void execute(JobExecutionContext context) throws JobExecutionException {
// TODO Auto-generated method stub
String username = context.getJobDetail().getJobDataMap().getString("username");
String password = context.getJobDetail().getJobDataMap().getString("password");
System.out.println("username:" + username);
System.out.println("password:" + password);
}
}

通过调用JobExecutionContext 的getJobDetail().getJobDataMap().getString(String paramname)来取得配置文件中定义的参数的值。

当定时器触发时，将执行该类的execute函数。

3、设置监听器

TaskScheduler.java

package com.yahaitt.quartz;
import java.util.Properties;
import org.apache.log4j.Logger;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.xml.JobSchedulingDataProcessor;
public class TaskScheduler {
// Logger
private static Logger logger = Logger.getLogger(TaskScheduler.class);
private static Scheduler scheduler;
private String jobsConfigFile = "quartz-jobs.xml";
public TaskScheduler() {
initScheduler();
}
/**
*
* @param fileName
* @return
*/
public void initScheduler() {
try {
StdSchedulerFactory factory = new StdSchedulerFactory();
//
Properties properties = new Properties();
properties.put("org.quartz.scheduler.instanceName","DefaultQuartzScheduler");
properties.put("org.quartz.scheduler.rmi.export","false");
properties.put("org.quartz.scheduler.rmi.proxy","false");
properties.put("org.quartz.scheduler.wrapJobExecutionInUserTransaction","false");
properties.put("org.quartz.threadPool.class","org.quartz.simpl.SimpleThreadPool");
properties.put("org.quartz.threadPool.threadCount","20");
properties.put("org.quartz.threadPool.threadPriority","5");
properties.put("org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread","true");
properties.put("org.quartz.jobStore.misfireThreshold","60000");
properties.put("org.quartz.jobStore.class","org.quartz.simpl.RAMJobStore");
// org.quartz.plugin.jobInitializer.validating = false
// org.quartz.plugin.jobInitializer.validatingSchema = false
// org.quartz.plugin.jobInitializer.class = org.quartz.plugins.xml.JobInitializationPlugin
// org.quartz.plugin.jobInitializer.fileName = quartz-jobs.xml
// org.quartz.plugin.jobInitializer.overWriteExistingJobs = false
// org.quartz.plugin.jobInitializer.failOnFileNotFound = true
factory.initialize(properties);
SchedulerFactory sf = (StdSchedulerFactory)factory;
scheduler = sf.getScheduler();
//Placing a Scheduler in Stand-by Mode
//scheduler.standby();
} catch (SchedulerException e) {
e.printStackTrace();
logger.error(e);
}
}
/**
* 从指定的任务配置文件中初始化计划任务
* @param jobsConfig
* @throws Exception
*/
public void initJobs(String jobsConfig) throws Exception {
//
this.jobsConfigFile = jobsConfig;
//
JobSchedulingDataProcessor xmlProcessor = new JobSchedulingDataProcessor();
//the last parameter here (the boolean one)is for overwriting existing jobs
xmlProcessor.processFileAndScheduleJobs(jobsConfigFile, scheduler, true);
}
/**
* 开启计划任务
* @throws SchedulerException
*/
public void startScheduler() throws SchedulerException {
// Scheduler will not execute jobs until it has been started (though they can be scheduled before start())
scheduler.start();
}
/**
* 停止计划任务
* @throws SchedulerException
*/
public void shutdownScheduler() throws SchedulerException {
scheduler.shutdown();
}
/**
* @param args
*/
public static void main(String[] args) {
String jobsConfigfile = "E:/workspace/crawler/conf/quartz_job.xml";
TaskScheduler scheduler = new TaskScheduler();
try {
scheduler.initJobs(jobsConfigfile);
scheduler.startScheduler();
} catch (Exception e) {
e.printStackTrace();
}
}
}

使用多线程和定时器的例子.rar (1.7 MB)
下载次数: 583

分享到：

mysql数据库优化策略 | web标准常见问题大全让FireFox与IE兼容 ...

2007-09-10 23:09
浏览 8625
评论(1)
查看更多

1 楼 yahaitt 2007-09-10

只有当执行
scheduler.initJobs(jobsConfigfile);
scheduler.startScheduler();
后，定时器才会被启动。
所以，在web中应用时，可以写一个servlet程序，在其init函数中new一个TaskScheduler，并初始化和启动这个TaskScheduler，并通过在web.xml中设置
<load-on-startup>1</load-on-startup>
使得在web服务器启动时将定时器启动。

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论