Spring Quartz2 动态任务的实例详解


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



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