Spring Quartz2 动态任务的实例详解
SpringQuartz2动态任务的实例详解
此处使用的是Quartz中SimpleScheduleBuilder类，非CronScheduleBuilder，CronScheduleBuilder是Cron表达式的。具体请自行百度。
实现代码：
/**
*新增任务
*@paramscheduleJob
*@throwsException
*/
@Override
@SuppressWarnings("unchecked")
publicvoidaddJobSimple(ScheduleJobscheduleJob)throwsException{
TriggerKeytriggerKey=TriggerKey.triggerKey(scheduleJob.getJobName(),scheduleJob.getJobGroup());
//任务触发
Triggertrigger=scheduler.getTrigger(triggerKey);
if(null==trigger){
JobDetailjobDetail=JobBuilder.newJob((Class)Class.forName(scheduleJob.getClazz()))
.withIdentity(scheduleJob.getJobName(),scheduleJob.getJobGroup()).build();
jobDetail.getJobDataMap().put("scheduleJob",scheduleJob);
SimpleScheduleBuildersimpleScheduleBuilder=SimpleScheduleBuilder.simpleSchedule();
if("秒".equals(scheduleJob.getTimeType())||
"second".equalsIgnoreCase(scheduleJob.getTimeType())){
simpleScheduleBuilder.withIntervalInSeconds(scheduleJob.getTimeValue()).repeatForever();
}elseif("分".equals(scheduleJob.getTimeType())||"分钟".equals(scheduleJob.getTimeType())||
"minute".equalsIgnoreCase(scheduleJob.getTimeType())){
simpleScheduleBuilder.withIntervalInMinutes(scheduleJob.getTimeValue()).repeatForever();
}elseif("时".equals(scheduleJob.getTimeType())||"小时".equals(scheduleJob.getTimeType())||
"hour".equalsIgnoreCase(scheduleJob.getTimeType())){
simpleScheduleBuilder.withIntervalInHours(scheduleJob.getTimeValue()).repeatForever();
}elseif("天".equals(scheduleJob.getTimeType())||
"date".equalsIgnoreCase(scheduleJob.getTimeType())){
simpleScheduleBuilder.withIntervalInHours(scheduleJob.getTimeValue()).repeatForever();
}
ScheduleBuilderschedBuilder=simpleScheduleBuilder.withMisfireHandlingInstructionNextWithRemainingCount();
trigger=TriggerBuilder.newTrigger().withIdentity(scheduleJob.getJobName(),scheduleJob.getJobGroup())
.withSchedule(schedBuilder).build();
trigger=TriggerBuilder.newTrigger().withIdentity(scheduleJob.getJobName(),scheduleJob.getJobGroup()).withSchedule(schedBuilder).build();
scheduler.scheduleJob(jobDetail,trigger);
log.info(CC.LOG_PREFIX+"新增简单任务："+JasonUtils.Object2String(scheduleJob));
}else{
this.updateJobCron(scheduleJob);
}
}
需要注意是的，当定时任务只执行一次时，就要仔细看代码，如上面的简单定时任务，刚开始是我这样的：
simpleScheduleBuilder.withIntervalInSeconds(scheduleJob.getTimeValue());
结果只执行一次，而我需要的是不断循环执行，最后改成：
simpleScheduleBuilder.withIntervalInSeconds(scheduleJob.getTimeValue()).repeatForever();
可以看出，后面多了个：repeatForever()，表示永远重复。
如果是希望执行多少次后不执行，就使用：.withRepeatCount(triggerRepeatCount)，如下：
simpleScheduleBuilder.withIntervalInHours(scheduleJob.getTimeValue()).withRepeatCount(triggerRepeatCount);
如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！