package com.mandi.quartz;
|
|
import java.util.Date;
|
import java.util.Map;
|
import java.util.Map.Entry;
|
|
import org.quartz.Job;
|
import org.quartz.JobBuilder;
|
import org.quartz.JobDataMap;
|
import org.quartz.JobDetail;
|
import org.quartz.Scheduler;
|
import org.quartz.SchedulerException;
|
import org.quartz.Trigger;
|
|
|
import org.quartz.SchedulerFactory;
|
import org.quartz.Trigger.TriggerState;
|
import org.quartz.TriggerBuilder;
|
import org.quartz.TriggerKey;
|
import org.quartz.impl.StdSchedulerFactory;
|
|
/**
|
* @author mengly
|
* @version 创建时间：2015年12月22日 下午2:52:02
|
* 类说明 :简易启动quartz job。
|
*/
|
|
public class Quartzjob {
|
private static SchedulerFactory sf=null;//new StdSchedulerFactory();
|
|
static{
|
Quartzjob.sf=new StdSchedulerFactory();
|
}
|
public static SchedulerFactory instance(){
|
return Quartzjob.sf;
|
}
|
/**
|
*
|
* @param jobName
|
* @param clz
|
* @param trigger
|
* @author mengly
|
* @version 创建时间：2016年3月1日 下午6:33:42
|
*/
|
public static void runJob(String jobName, Class<? extends Job> clz,Trigger trigger ) {
|
try {
|
Scheduler sched = sf.getScheduler();
|
JobBuilder jb= JobBuilder.newJob(clz);
|
jb=jb.withIdentity(jobName, jobName+"group");
|
JobDetail jobDetail =jb.build();
|
|
sched.scheduleJob(jobDetail, trigger);
|
// 启动
|
if (!sched.isShutdown()) {
|
sched.start();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
public static void runJob(String jobName, Class<? extends Job> clz,Trigger trigger,Map<String, Object> params ) {
|
try {
|
Scheduler sched = sf.getScheduler();
|
JobBuilder jb= JobBuilder.newJob(clz);
|
jb=jb.withIdentity(jobName, jobName+"group");
|
JobDetail jobDetail =jb.build();
|
JobDataMap jdm=jobDetail.getJobDataMap();
|
for (Entry<String, Object> en : params.entrySet()) {
|
jdm.put(en.getKey(), en.getValue());
|
}
|
sched.scheduleJob(jobDetail, trigger);
|
// 启动
|
if (!sched.isShutdown()) {
|
sched.start();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
public static void runJobNowOnce(String jobName, Class<? extends Job> clz) {
|
try {
|
Scheduler sched = sf.getScheduler();
|
JobBuilder jb= JobBuilder.newJob(clz);
|
jb=jb.withIdentity(jobName, jobName+"group");
|
JobDetail jobDetail =jb.build();
|
|
@SuppressWarnings("rawtypes")
|
TriggerBuilder tb=TriggerBuilder.newTrigger();
|
tb.withIdentity(jobName+"trigger", jobName+"triggergroup").startNow().build();
|
Trigger tr=tb.build();
|
sched.scheduleJob(jobDetail, tr);
|
System.out.println("start to do...runjobnowonce");
|
// 启动
|
if (!sched.isShutdown()) {
|
sched.start();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
public static void runJobNowOnce(String jobName, Class<? extends Job> clz,Map<String, Object> params) {
|
try {
|
Scheduler sched = sf.getScheduler();
|
JobBuilder jb= JobBuilder.newJob(clz);
|
jb=jb.withIdentity(jobName, jobName+"group");
|
JobDetail jobDetail =jb.build();
|
if(params!=null&&!params.isEmpty())
|
{
|
jobDetail.getJobDataMap().putAll(params);
|
}
|
@SuppressWarnings("rawtypes")
|
TriggerBuilder tb=TriggerBuilder.newTrigger();
|
tb.withIdentity(jobName+"trigger", jobName+"triggergroup").startNow().build();
|
Trigger tr=tb.build();
|
sched.scheduleJob(jobDetail, tr);
|
System.out.println("start to do...runjobnowonce");
|
// 启动
|
if (!sched.isShutdown()) {
|
sched.start();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
|
|
public static TriggerState getJobState(String triggername,String triggergroup){
|
try {
|
Scheduler sched = sf.getScheduler();
|
TriggerKey tk=TriggerKey.triggerKey(triggername, triggergroup);
|
return sched.getTriggerState(tk);
|
} catch (SchedulerException e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
public static void runJobOnce(String jobName, Class<? extends Job> clz,Date startDate) {
|
try {
|
Scheduler sched = sf.getScheduler();
|
JobBuilder jb= JobBuilder.newJob(clz);
|
jb=jb.withIdentity(jobName, jobName);
|
JobDetail jobDetail =jb.build();
|
TriggerBuilder tb=TriggerBuilder.newTrigger();
|
tb.withIdentity(jobName+"trigger", jobName+"triggergroup").startAt(startDate).build();
|
Trigger tr=tb.build();
|
sched.scheduleJob(jobDetail, tr);
|
System.out.println("start to do...runjobnowonce");
|
// 启动
|
if (!sched.isShutdown()) {
|
sched.start();
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
