Spring Quartz2 動(dòng)態(tài)任務(wù)的實(shí)例詳解
此處使用的是Quartz中SimpleScheduleBuilder類,非CronScheduleBuilder,CronScheduleBuilder是Cron表達(dá)式的。具體請(qǐng)自行百度。
實(shí)現(xiàn)代碼:
/** * 新增任務(wù) * @param scheduleJob * @throws Exception */ @Override @SuppressWarnings("unchecked") public void addJobSimple(ScheduleJob scheduleJob) throws Exception{ TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); //任務(wù)觸發(fā) 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("時(shí)".equals(scheduleJob.getTimeType()) || "小時(shí)".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(); } ScheduleBuilderSimpleTrigger> 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 + "新增簡(jiǎn)單任務(wù):"+JasonUtils.Object2String(scheduleJob)); }else { this.updateJobCron(scheduleJob); } }
需要注意是的,當(dāng)定時(shí)任務(wù)只執(zhí)行一次時(shí),就要仔細(xì)看代碼,如上面的簡(jiǎn)單定時(shí)任務(wù),剛開(kāi)始是我這樣的:
simpleScheduleBuilder.withIntervalInSeconds(scheduleJob.getTimeValue());
結(jié)果只執(zhí)行一次,而我需要的是不斷循環(huán)執(zhí)行,最后改成:
simpleScheduleBuilder.withIntervalInSeconds(scheduleJob.getTimeValue()).repeatForever();
可以看出,后面多了個(gè):repeatForever(),表示永遠(yuǎn)重復(fù)。
如果是希望執(zhí)行多少次后不執(zhí)行,就使用:.withRepeatCount(triggerRepeatCount),如下:
simpleScheduleBuilder.withIntervalInHours(scheduleJob.getTimeValue()).withRepeatCount(triggerRepeatCount);
如有疑問(wèn)請(qǐng)留言或者到本站社區(qū)交流討論,感謝閱讀,希望能幫助到大家,謝謝大家對(duì)本站的支持!
標(biāo)簽:銅川 樂(lè)山 黃石 貸款邀約 廣州 內(nèi)江 大連 南京
巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《Spring Quartz2 動(dòng)態(tài)任務(wù)的實(shí)例詳解》,本文關(guān)鍵詞 Spring,Quartz2,動(dòng)態(tài),任務(wù),的,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問(wèn)題,煩請(qǐng)?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無(wú)關(guān)。