浅谈Trigger
什么是Trigger?
Quartz中的觸發(fā)器用來(lái)告訴調(diào)度程序作業(yè)什么時(shí)候觸發(fā)。即Trigger對(duì)象是用來(lái)觸發(fā)Job的
JobKey表示Job實(shí)例的標(biāo)識(shí),觸發(fā)器被觸發(fā)時(shí),該指定的Job實(shí)例會(huì)執(zhí)行。
StartTime 表示觸發(fā)器的時(shí)間表首次被觸發(fā)的時(shí)間。它的值的類型是Java.util.Date
EndTime 指定觸發(fā)器的不再被觸發(fā)的時(shí)間。它的值的類型是Java.util.Date
具體案例
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
public class HelloScheduler {
public static void main(String[] args) throws SchedulerException {
//打印當(dāng)前的執(zhí)行時(shí)間
Date date = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String currentTime = sdf.format(date);
System.out.println("Current Time : "+currentTime);
//獲取當(dāng)前時(shí)間3秒后的時(shí)間
date.setTime(date.getTime()+3000);
//獲取距離當(dāng)前時(shí)間6秒后的時(shí)間
Date endDate = new Date();
endDate.setTime(endDate.getTime()+6000);
//創(chuàng)建一個(gè)JobDetail實(shí)例,將該實(shí)例與HelloJob class綁定
JobDetail jobDetail = JobBuilder.newJob(HelloJob.class)
.withIdentity("myJob", "group1")
.build();
//創(chuàng)建一個(gè)Trigger實(shí)例,定義該Job立即執(zhí)行,并且每隔2秒鐘重復(fù)執(zhí)行一次,直到永遠(yuǎn)
Trigger trigger = TriggerBuilder.newTrigger()
.withIdentity("myTrigger", "group1")
.startAt(date)
.endAt(endDate)
.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever())
.build();
//創(chuàng)建Scheduler實(shí)例
SchedulerFactory sfact = new StdSchedulerFactory();
Scheduler scheduler = sfact.getScheduler();
scheduler.start();
scheduler.scheduleJob(jobDetail, trigger);
}
}
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.Trigger;
public class HelloJob implements Job{
public void execute(JobExecutionContext context) throws JobExecutionException {
//打印當(dāng)前的執(zhí)行時(shí)間
Date date = new Date();
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
String currentTime = sdf.format(date);
System.out.println("Current Exec Time : "+currentTime);
//編寫(xiě)具體的業(yè)務(wù)邏輯
Trigger currentTrigger = context.getTrigger();
System.out.println("Start Time is:"+sdf.format(currentTrigger.getStartTime()));
System.out.println("End Time is:"+sdf.format(currentTrigger.getEndTime()));
JobKey jobKey = currentTrigger.getJobKey();
System.out.println("JobKey info --" +jobKey.getName()+": "+jobKey.getGroup()+": "+jobKey.getClass());
}
}
總結(jié)
- 上一篇: 官降小 5 万,大众 ID.4 CROZ
- 下一篇: WAMP设置