首页 > 编程 > JSP > 正文

Spring Quartz2 动态任务的实例详解

2020-07-27 21:20:55
字体:
来源:转载
供稿:网友

Spring Quartz2 动态任务的实例详解

此处使用的是Quartz中SimpleScheduleBuilder类,非CronScheduleBuilder,CronScheduleBuilder是Cron表达式的。具体请自行百度。

实现代码: 

/**    * 新增任务    * @param scheduleJob    * @throws Exception    */   @Override   @SuppressWarnings("unchecked")   public void addJobSimple(ScheduleJob scheduleJob) throws Exception{     TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());     //任务触发     Trigger trigger = scheduler.getTrigger(triggerKey);     if (null == trigger) {       JobDetail jobDetail = JobBuilder.newJob((Class<? extends Job>) Class.forName(scheduleJob.getClazz()))        .withIdentity(scheduleJob.getJobName(), scheduleJob.getJobGroup()).build();       jobDetail.getJobDataMap().put("scheduleJob", scheduleJob);              SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule();       if("秒".equals(scheduleJob.getTimeType()) ||            "second".equalsIgnoreCase(scheduleJob.getTimeType())){         simpleScheduleBuilder.withIntervalInSeconds(scheduleJob.getTimeValue()).repeatForever();       }else if("分".equals(scheduleJob.getTimeType()) || "分钟".equals(scheduleJob.getTimeType()) ||            "minute".equalsIgnoreCase(scheduleJob.getTimeType())){         simpleScheduleBuilder.withIntervalInMinutes(scheduleJob.getTimeValue()).repeatForever();       }else if("时".equals(scheduleJob.getTimeType()) || "小时".equals(scheduleJob.getTimeType()) ||            "hour".equalsIgnoreCase(scheduleJob.getTimeType())){         simpleScheduleBuilder.withIntervalInHours(scheduleJob.getTimeValue()).repeatForever();       }else if("天".equals(scheduleJob.getTimeType()) ||            "date".equalsIgnoreCase(scheduleJob.getTimeType())){         simpleScheduleBuilder.withIntervalInHours(scheduleJob.getTimeValue()).repeatForever();       }       ScheduleBuilder<SimpleTrigger> schedBuilder = 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); 

如有疑问请留言或者到本站社区交流讨论,感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!

发表评论 共有条评论
用户名: 密码:
验证码: 匿名发表