SimpleJob.java
package com.test.job;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class SimpleJob implements Job{
public void execute(JobExecutionContext context)
throws JobExecutionException {
// your business logic
// ...
System.out.println("simpleJob running ....");
}
}
TestSimpleJob.java
package com.test.job;
import java.text.ParseException;
import org.quartz.CronExpression;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleTrigger;
import org.quartz.impl.StdSchedulerFactory;
public class TestSimpleJob {
public static void main(String[] args){
try {
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
String jobName = "simpleJob";
String groupName = "DEFAULT";
//刪除作業(yè)
if(scheduler.getJobDetail(jobName,groupName) != null){
scheduler.deleteJob(jobName, groupName);
}
//作業(yè)的詳細信息
//任務名稱，任務組名稱，任務實現(xiàn)類
JobDetail jobDetail = new JobDetail(jobName,groupName,SimpleJob.class);
//創(chuàng)建簡單觸發(fā)器
SimpleTrigger simpleTrigger = new SimpleTrigger("simpleTrigger",null);
simpleTrigger.setRepeatCount(100); // 調用100次
simpleTrigger.setRepeatInterval(5*1000); //每5秒鐘調用一次
//注冊作業(yè)
scheduler.scheduleJob(jobDetail, simpleTrigger);
CronTrigger cronTrigger = new CronTrigger("cronTrigger",null);
CronExpression cronExpression = null;
try {
cronExpression = new CronExpression("0 0 12 * * ?"); //每天12點運行
cronTrigger.setCronExpression(cronExpression);
//注冊作業(yè)
scheduler.scheduleJob(jobDetail, cronTrigger);
if(! scheduler.isShutdown()){
scheduler.start();
}
} catch (ParseException e) {
e.printStackTrace();
}
} catch (SchedulerException e) {
e.printStackTrace();
}
}
}