public classQuartzManager {private static SchedulerFactory schedulerFactory = newStdSchedulerFactory();/*** @Description: 添加一个定时任务
*
*@paramjobName 任务名
*@paramjobGroupName 任务组名
*@paramtriggerName 触发器名
*@paramtriggerGroupName 触发器组名
*@paramjobClass 任务
*@paramcron 时间设置，参考quartz说明文档*/@SuppressWarnings({"unchecked", "rawtypes"})public static voidaddJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class jobClass, String cron) {try{
Scheduler sched=schedulerFactory.getScheduler();//任务名，任务组，任务执行类
JobDetail jobDetail=JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();//触发器
TriggerBuilder triggerBuilder =TriggerBuilder.newTrigger();//触发器名,触发器组
triggerBuilder.withIdentity(triggerName, triggerGroupName);
triggerBuilder.startNow();//触发器时间设定
triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));//创建Trigger对象
CronTrigger trigger =(CronTrigger) triggerBuilder.build();//调度容器设置JobDetail和Trigger
sched.scheduleJob(jobDetail, trigger);//启动
if (!sched.isShutdown()) {
sched.start();
}
}catch(Exception e) {throw newRuntimeException(e);
}
}/*** @Description: 修改一个任务的触发时间
*
*@paramjobName
*@paramjobGroupName
*@paramtriggerName 触发器名
*@paramtriggerGroupName 触发器组名
*@paramcron 时间设置，参考quartz说明文档*/
public static voidmodifyJobTime(String jobName, String jobGroupName, String triggerName, String triggerGroupName, String cron) {try{
Scheduler sched=schedulerFactory.getScheduler();
TriggerKey triggerKey=TriggerKey.triggerKey(triggerName, triggerGroupName);
CronTrigger trigger=(CronTrigger) sched.getTrigger(triggerKey);if (trigger == null) {return;
}
String oldTime=trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(cron)) {/**方式一 ：调用 rescheduleJob 开始*/
//触发器
TriggerBuilder triggerBuilder =TriggerBuilder.newTrigger();//触发器名,触发器组
triggerBuilder.withIdentity(triggerName, triggerGroupName);
triggerBuilder.startNow();//触发器时间设定
triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron));//创建Trigger对象
trigger =(CronTrigger) triggerBuilder.build();
sched.rescheduleJob(triggerKey, trigger);/**方式二：先删除，然后在创建一个新的Job*/
/*JobDetail jobDetail = sched.getJobDetail(JobKey.jobKey(jobName, jobGroupName));
Class extends Job> jobClass = jobDetail.getJobClass();
removeJob(jobName, jobGroupName, triggerName, triggerGroupName);
addJob(jobName, jobGroupName, triggerName, triggerGroupName, jobClass, cron);*/}
}catch(Exception e) {throw newRuntimeException(e);
}
}/*** @Description: 移除一个任务
*
*@paramjobName
*@paramjobGroupName
*@paramtriggerName
*@paramtriggerGroupName*/
public static voidremoveJob(String jobName, String jobGroupName,
String triggerName, String triggerGroupName) {try{
Scheduler sched=schedulerFactory.getScheduler();
TriggerKey triggerKey=TriggerKey.triggerKey(triggerName, triggerGroupName);
sched.pauseTrigger(triggerKey);//停止触发器
sched.unscheduleJob(triggerKey);//移除触发器
sched.deleteJob(JobKey.jobKey(jobName, jobGroupName));//删除任务
} catch(Exception e) {throw newRuntimeException(e);
}
}/*** @Description:启动所有定时任务*/
public static voidstartJobs() {try{
Scheduler sched=schedulerFactory.getScheduler();
sched.start();
}catch(Exception e) {throw newRuntimeException(e);
}
}/*** @Description:关闭所有定时任务*/
public static voidshutdownJobs() {try{
Scheduler sched=schedulerFactory.getScheduler();if (!sched.isShutdown()) {
sched.shutdown();
}
}catch(Exception e) {throw newRuntimeException(e);
}
}
}
