如何动态的改变Quartz的调度作业的时间
2011-06-26 22:55
190 查看
如何动态的改变Quartz的调度作业的时间
近日碰到一位友人提出的一个问题,如何动态的改变Quartz的调度作业的时间。比如,由每10分钟执行一次改为每5分钟执行一次。个人认为这种需求应该通过某种方式来规避,或者选用其他的技术框架,因为动态改变Quartz的调度时间完全失去了使用Quartz的意义。本人在使用Quartz是基于Spring来配置的,而朋友的项目中不能使用SPring框架,这就需要直接基于Quartz编程。工作之余,写了个例子:
Quartz的管理类
Java代码
public class QuartzManage {
private static SchedulerFactory sf = new StdSchedulerFactory();
private static String JOB_GROUP_NAME = "group";
private static String TRIGGER_GROUP_NAME = "trigger";
public static void startJob(String jobName, Job job, String time)
throws SchedulerException, ParseException {
Scheduler sched = sf.getScheduler();
JobDetail jobDetail = new JobDetail();
jobDetail.setName(jobName);
jobDetail.setGroup(JOB_GROUP_NAME);
jobDetail.setJobClass(job.getClass());
CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);
trigger.setCronExpression(time);
sched.scheduleJob(jobDetail, trigger);
if (!sched.isShutdown()) {
sched.start();
}
}
/**
* 从Scheduler 移除当前的Job,修改Trigger
*
* @param jobDetail
* @param time
* @throws SchedulerException
* @throws ParseException
*/
public static void modifyJobTime(JobDetail jobDetail, String time)
throws SchedulerException, ParseException {
Scheduler sched = sf.getScheduler();
Trigger trigger = sched.getTrigger(jobDetail.getName(),
TRIGGER_GROUP_NAME);
if (trigger != null) {
CronTrigger ct = (CronTrigger) trigger;
// 移除当前进程的Job
sched.deleteJob(jobDetail.getName(), jobDetail.getGroup());
// 修改Trigger
ct.setCronExpression(time);
System.out.println("CronTrigger getName " + ct.getJobName());
// 重新调度jobDetail
sched.scheduleJob(jobDetail, ct);
}
}
}
Job任务:
Java代码
public class JobTest implements Job {
static int a = 0;
@Override
public void execute(JobExecutionContext context)
throws JobExecutionException {
a += 1;
System.out.println("test ++++++++++++++++++++++a=" + a);
if (a == 4) {
try {
QuartzManage.modifyJobTime(context.getJobDetail(),
"0/10 * * * * ?");
} catch (SchedulerException e) {
e.printStackTrace();
} catch (ParseException e) {
e.printStackTrace();
}
}
}
}
启动线程执行调度:
Java代码
public class QuartzTest {
public static void main(String[] args) throws SchedulerException,
ParseException {
/*
* 此进程为主进程,触发了quartz对Job的调度 因此启动Job之后,在该进程修改调度,是没有效果的
*/
JobTest job = new JobTest();
QuartzManage.startJob("ming", job, "0/2 * * * * ?");
}
}
好多人的思路是在启动的主线程内去改变调度的时间,简单的分析就可发现,主线程启动之后就会按照调度时间去运行Job,不会返回主线程再去加载调度时间,只是起到了触发调度的操作。因此要进行动态的修改调度时间,需要在Job任务里,动态改变当前线程的调度计划。
测试代码,开始时按每2秒执行一次打印a,当a打印4次以后,按照每10秒一次执行。虽然代码测试成功,本人还有疑惑。
Java代码
// 移除当前进程的Job
sched.deleteJob(jobDetail.getName(), jobDetail.getGroup());
近日碰到一位友人提出的一个问题,如何动态的改变Quartz的调度作业的时间。比如,由每10分钟执行一次改为每5分钟执行一次。个人认为这种需求应该通过某种方式来规避,或者选用其他的技术框架,因为动态改变Quartz的调度时间完全失去了使用Quartz的意义。本人在使用Quartz是基于Spring来配置的,而朋友的项目中不能使用SPring框架,这就需要直接基于Quartz编程。工作之余,写了个例子:
Quartz的管理类
Java代码
public class QuartzManage {
private static SchedulerFactory sf = new StdSchedulerFactory();
private static String JOB_GROUP_NAME = "group";
private static String TRIGGER_GROUP_NAME = "trigger";
public static void startJob(String jobName, Job job, String time)
throws SchedulerException, ParseException {
Scheduler sched = sf.getScheduler();
JobDetail jobDetail = new JobDetail();
jobDetail.setName(jobName);
jobDetail.setGroup(JOB_GROUP_NAME);
jobDetail.setJobClass(job.getClass());
CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);
trigger.setCronExpression(time);
sched.scheduleJob(jobDetail, trigger);
if (!sched.isShutdown()) {
sched.start();
}
}
/**
* 从Scheduler 移除当前的Job,修改Trigger
*
* @param jobDetail
* @param time
* @throws SchedulerException
* @throws ParseException
*/
public static void modifyJobTime(JobDetail jobDetail, String time)
throws SchedulerException, ParseException {
Scheduler sched = sf.getScheduler();
Trigger trigger = sched.getTrigger(jobDetail.getName(),
TRIGGER_GROUP_NAME);
if (trigger != null) {
CronTrigger ct = (CronTrigger) trigger;
// 移除当前进程的Job
sched.deleteJob(jobDetail.getName(), jobDetail.getGroup());
// 修改Trigger
ct.setCronExpression(time);
System.out.println("CronTrigger getName " + ct.getJobName());
// 重新调度jobDetail
sched.scheduleJob(jobDetail, ct);
}
}
}
public class QuartzManage { private static SchedulerFactory sf = new StdSchedulerFactory(); private static String JOB_GROUP_NAME = "group"; private static String TRIGGER_GROUP_NAME = "trigger"; public static void startJob(String jobName, Job job, String time) throws SchedulerException, ParseException { Scheduler sched = sf.getScheduler(); JobDetail jobDetail = new JobDetail(); jobDetail.setName(jobName); jobDetail.setGroup(JOB_GROUP_NAME); jobDetail.setJobClass(job.getClass()); CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME); trigger.setCronExpression(time); sched.scheduleJob(jobDetail, trigger); if (!sched.isShutdown()) { sched.start(); } } /** * 从Scheduler 移除当前的Job,修改Trigger * * @param jobDetail * @param time * @throws SchedulerException * @throws ParseException */ public static void modifyJobTime(JobDetail jobDetail, String time) throws SchedulerException, ParseException { Scheduler sched = sf.getScheduler(); Trigger trigger = sched.getTrigger(jobDetail.getName(), TRIGGER_GROUP_NAME); if (trigger != null) { CronTrigger ct = (CronTrigger) trigger; // 移除当前进程的Job sched.deleteJob(jobDetail.getName(), jobDetail.getGroup()); // 修改Trigger ct.setCronExpression(time); System.out.println("CronTrigger getName " + ct.getJobName()); // 重新调度jobDetail sched.scheduleJob(jobDetail, ct); } } }
Job任务:
Java代码
public class JobTest implements Job {
static int a = 0;
@Override
public void execute(JobExecutionContext context)
throws JobExecutionException {
a += 1;
System.out.println("test ++++++++++++++++++++++a=" + a);
if (a == 4) {
try {
QuartzManage.modifyJobTime(context.getJobDetail(),
"0/10 * * * * ?");
} catch (SchedulerException e) {
e.printStackTrace();
} catch (ParseException e) {
e.printStackTrace();
}
}
}
}
public class JobTest implements Job { static int a = 0; @Override public void execute(JobExecutionContext context) throws JobExecutionException { a += 1; System.out.println("test ++++++++++++++++++++++a=" + a); if (a == 4) { try { QuartzManage.modifyJobTime(context.getJobDetail(), "0/10 * * * * ?"); } catch (SchedulerException e) { e.printStackTrace(); } catch (ParseException e) { e.printStackTrace(); } } } }
启动线程执行调度:
Java代码
public class QuartzTest {
public static void main(String[] args) throws SchedulerException,
ParseException {
/*
* 此进程为主进程,触发了quartz对Job的调度 因此启动Job之后,在该进程修改调度,是没有效果的
*/
JobTest job = new JobTest();
QuartzManage.startJob("ming", job, "0/2 * * * * ?");
}
}
public class QuartzTest { public static void main(String[] args) throws SchedulerException, ParseException { /* * 此进程为主进程,触发了quartz对Job的调度 因此启动Job之后,在该进程修改调度,是没有效果的 */ JobTest job = new JobTest(); QuartzManage.startJob("ming", job, "0/2 * * * * ?"); } }
好多人的思路是在启动的主线程内去改变调度的时间,简单的分析就可发现,主线程启动之后就会按照调度时间去运行Job,不会返回主线程再去加载调度时间,只是起到了触发调度的操作。因此要进行动态的修改调度时间,需要在Job任务里,动态改变当前线程的调度计划。
测试代码,开始时按每2秒执行一次打印a,当a打印4次以后,按照每10秒一次执行。虽然代码测试成功,本人还有疑惑。
Java代码
// 移除当前进程的Job
sched.deleteJob(jobDetail.getName(), jobDetail.getGroup());
相关文章推荐
- 动态改变Quartz的调度时间(1)
- 动态改变Quartz的调度时间(2)
- 动态改变Quartz的调度时间
- 动态改变Quartz的调度时间
- 动态改变Quartz的调度时间
- Quartz 在 Spring 中如何动态配置时间--转
- Quartz学习6:Quartz在Spring中如何动态配置时间
- Quartz 在 Spring 中如何动态配置时间
- Spring 注解 @Scheduled(cron = "0 0/10 * * * ? ") 任务调度动态改变时间
- Quartz.net 动态调整任务的调度时间
- Quartz 在 Spring 中如何动态配置时间
- 最近用到了Quartz,作业调度的方法,对于其中时间配置的方法,在网上找了下资料,摘抄的,忘原作者见谅,我收藏了。
- Quartz作业调度框架及时间表达式的含义和语法
- Quartz动态改变任务时间
- Spring Quartz如何动态配置时间
- Quartz 在 Spring 中如何动态配置时间
- Quartz 在 Spring 中如何动态配置时间
- Spring整合Quartz 2.2实现作业动态调度
- Quartz 在 Spring 中如何动态配置时间
- Spring + Quartz任务调度实战之动态作业调度