• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Spring Quartz2 动态任务的实例详解

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

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

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


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Spring quartz Job依赖注入使用详解发布时间:2022-02-05
下一篇:
Spring MVC之DispatcherServlet_动力节点Java学院整理发布时间:2022-02-05
热门推荐
热门话题
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap