当前位置：主页 > 查看内容

Spring Quartz2 动态任务的实例详解

发布时间：2021-04-18 00:00| 有 位朋友查看

简介：Spring Quartz2 动态任务的实例详解 此处使用的是Quartz中SimpleScheduleBuilder类，非CronScheduleBuilder，CronScheduleBuilder是Cron表达式的。具体请自行百度。 实现代码： /** * 新增任务 * @param scheduleJob * @throws Exception */ @Override @Supp……

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);

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


本文转载自网络，原文链接：https://m.jb51.net/article/122427.htm
本站部分内容转载于网络，版权归原作者所有，转载之目的在于传播更多优秀技术内容，如有侵权请联系QQ/微信：153890879删除，谢谢！
上一篇：Spring MVC之DispatcherServlet_动力节点Java学院整理 下一篇：Spring quartz Job依赖注入使用详解

推荐图文

  • 周排行
  • 月排行
  • 总排行

随机推荐