`
eksliang
  • 浏览: 592202 次
  • 性别: Icon_minigender_1
  • 来自: 广州
社区版块
存档分类
最新评论

Quartz——DateIntervalTrigger触发器

阅读更多

转载请出自出处:http://eksliang.iteye.com/blog/2208559

一.概述

simpleTrigger 内部实现机制是通过计算间隔时间来计算下次的执行时间,这就导致他有不适合调度的定时任务。例如我们想每天的 1:00AM 执行任务,如果使用 SimpleTrigger,间隔时间就是一天。注意这里就会有一个问题,即当有 misfired 的任务并且恢复执行时,该执行时间是随机的(取决于何时执行 misfired 的任务,例如某天的 3:00PM)。这会导致之后每天的执行时间都会变成 3:00PM,而不是我们原来期望的 1:00AM。

那应该怎么解决?

答:使用DateIntervalTrigger触发器

DateIntervalTrigger 是 Quartz 1.7 之后的版本加入的,其最适合调度类似每 N(1, 2, 3...)小时,每 N 天,每 N 周等的任务。虽然 SimpleTrigger 也能实现类似的任务,但是 DateIntervalTrigger 不会受到我们上面说到的 misfired 任务的影响。另外,DateIntervalTrigger 也不会受到 DST(Daylight Saving Time, 即中国的夏令时)调整的影响。笔者就曾经因为该原因将项目中的 SimpleTrigger 改为了 DateIntervalTrigger,因为如果使用 SimpleTrigger,本来设定的调度时间就会由于 DST 的调整而提前或延迟一个小时,而 DateIntervalTrigger 不会受此影响。

 

二.参考实例

简单的Job实现类:打印任务详情

 

package com.ickes.job;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
 * 实现Job接口,定义运行的任务
 * @author Ickes
 */
public class SimpleJob implements Job {

	public void execute(JobExecutionContext context)
			throws JobExecutionException {
		//打印任务详情
		System.out.println(
				context.getJobDetail().getGroup() 
				+"——"+context.getJobDetail().getName()
				+"——"+context.getTrigger().getName()
				+"——"+context.getTrigger().getGroup());
	}

}

 

DateIntervalTriggerDemo测试实例

 

package com.ickes.job;

import org.quartz.DateIntervalTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;
/**
 * @author Ickes
 */
public class DateIntervalTriggerDemo {
	public static void main(String[] args) throws Exception {
		//第一步:创建一个JobDetail实例
		JobDetail jobDetail = new JobDetail("j_job1","j_group1", SimpleJob.class);
		//第二步:通过DateIntervalTrigger触发器定义调度规则:每隔1秒钟调度一次
		/*
		 * 第三个参数:DateIntervalTrigger.IntervalUnit.SECOND 这是间隔单位
		 * 第四个参数:每多少次第三个参数单位触发一次job
		 * 例如:下面就是每隔一秒触发一次
		 */
		DateIntervalTrigger trigger = new DateIntervalTrigger("t_trigger1","t_group1",
				DateIntervalTrigger.IntervalUnit.SECOND, 1);
		//第三步:通过SchedulerFactory获取一个调度器实例
		SchedulerFactory schedulerFactory = new StdSchedulerFactory();
		Scheduler scheduler = schedulerFactory.getScheduler();
		//第四步:将job跟trigger注册到scheduler中进行调度
		scheduler.scheduleJob(jobDetail, trigger);
		//第五步:调度启动
		scheduler.start();
	}
}

 

 

1
2
分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics