直接上代碼

import org.apache.tools.ant.util.DateUtils; import org.quartz.CronTrigger; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerFactory; import org.quartz.impl.StdSchedulerFactory;import java.util.Calendar; import java.util.Date;/*** @Description: 定時(shí)任務(wù)管理類* Created by zhangxb on 2017/2/10.*/ public class QuartzManager {private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";/*** @Description: 添加一個(gè)定時(shí)任務(wù)，使用默認(rèn)的任務(wù)組名，觸發(fā)器名，觸發(fā)器組名** @param jobName* 任務(wù)名* @param cls* 任務(wù)* @param time* 時(shí)間設(shè)置，參考quartz說(shuō)明文檔** @Title: QuartzManager.java*/@SuppressWarnings("unchecked")public static void addJob(String jobName, Class cls, String time,Object params) {try {Scheduler sched = gSchedulerFactory.getScheduler();JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, cls);// 任務(wù)名，任務(wù)組，任務(wù)執(zhí)行類jobDetail.getJobDataMap().put("params", params);// 觸發(fā)器CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 觸發(fā)器名,觸發(fā)器組trigger.setCronExpression(time);// 觸發(fā)器時(shí)間設(shè)定 sched.scheduleJob(jobDetail, trigger);// 啟動(dòng)if (!sched.isShutdown()) {sched.start();}} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 添加一個(gè)定時(shí)任務(wù)** @param jobName* 任務(wù)名* @param jobGroupName* 任務(wù)組名* @param triggerName* 觸發(fā)器名* @param triggerGroupName* 觸發(fā)器組名* @param jobClass* 任務(wù)* @param time* 時(shí)間設(shè)置，參考quartz說(shuō)明文檔**/@SuppressWarnings("unchecked")public static void addJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName, Class jobClass,String time,Object params) {try {Scheduler sched = gSchedulerFactory.getScheduler();JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass);// 任務(wù)名，任務(wù)組，任務(wù)執(zhí)行類jobDetail.getJobDataMap().put("params",params);// 觸發(fā)器CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 觸發(fā)器名,觸發(fā)器組trigger.setCronExpression(time);// 觸發(fā)器時(shí)間設(shè)定 sched.scheduleJob(jobDetail, trigger);} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 修改一個(gè)任務(wù)的觸發(fā)時(shí)間(使用默認(rèn)的任務(wù)組名，觸發(fā)器名，觸發(fā)器組名)** @param jobName* @param time**/@SuppressWarnings("unchecked")public static void modifyJobTime(String jobName, String time) {try {Scheduler sched = gSchedulerFactory.getScheduler();CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName,TRIGGER_GROUP_NAME);if (trigger == null) {return;}String oldTime = trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(time)) {JobDetail jobDetail = sched.getJobDetail(jobName,JOB_GROUP_NAME);Class objJobClass = jobDetail.getJobClass();removeJob(jobName);addJob(jobName, objJobClass, time ,jobDetail.getJobDataMap());}} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 修改一個(gè)任務(wù)的觸發(fā)時(shí)間**/public static void modifyJobTime(String triggerName,String triggerGroupName, String time) {try {Scheduler sched = gSchedulerFactory.getScheduler();CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerName,triggerGroupName);if (trigger == null) {return;}String oldTime = trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(time)) {CronTrigger ct = (CronTrigger) trigger;// 修改時(shí)間 ct.setCronExpression(time);// 重啟觸發(fā)器 sched.resumeTrigger(triggerName, triggerGroupName);}} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 移除一個(gè)任務(wù)(使用默認(rèn)的任務(wù)組名，觸發(fā)器名，觸發(fā)器組名)** @param jobName**/public static void removeJob(String jobName) {try {Scheduler sched = gSchedulerFactory.getScheduler();sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止觸發(fā)器sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除觸發(fā)器sched.deleteJob(jobName, JOB_GROUP_NAME);// 刪除任務(wù)} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 移除一個(gè)任務(wù)**/public static void removeJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName) {try {Scheduler sched = gSchedulerFactory.getScheduler();sched.pauseTrigger(triggerName, triggerGroupName);// 停止觸發(fā)器sched.unscheduleJob(triggerName, triggerGroupName);// 移除觸發(fā)器sched.deleteJob(jobName, jobGroupName);// 刪除任務(wù)} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description:啟動(dòng)所有定時(shí)任務(wù)*/public static void startJobs() {try {Scheduler sched = gSchedulerFactory.getScheduler();sched.start();} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description:關(guān)閉所有定時(shí)任務(wù)**/public static void shutdownJobs() {try {Scheduler sched = gSchedulerFactory.getScheduler();if (!sched.isShutdown()) {sched.shutdown();}} catch (Exception e) {throw new RuntimeException(e);}}public static String formatTime(Date date){//0/1 * * * * ?String time = DateUtils.format( date, "s m h d * ?");System.out.println(time);return time;} }

測(cè)試類

import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException;import java.text.SimpleDateFormat; import java.util.Calendar; import java.util.Date;/*** @Description: 任務(wù)執(zhí)行類* Created by zhangxb on 2017/2/10.*/ public class QuartzJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {Object params = context.getJobDetail().getJobDataMap().get("params");System.out.println(params);System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+ "★★★★★★★★★★★");System.out.println("【移除定時(shí)】開(kāi)始...");QuartzManager.removeJob((String)params);System.out.println("【移除定時(shí)】成功");}public static void main(String[] args) {try {String job_name = "動(dòng)態(tài)任務(wù)調(diào)度";System.out.println("【系統(tǒng)啟動(dòng)】開(kāi)始(每1秒輸出一次)...");Calendar cal = Calendar.getInstance();cal.add( Calendar.SECOND,10);QuartzManager.addJob(job_name, QuartzJob.class, QuartzManager.formatTime(cal.getTime()),job_name);Thread.sleep(11);cal.setTime( new Date());cal.add( Calendar.SECOND,10);QuartzManager.addJob(job_name+1, QuartzJob.class, QuartzManager.formatTime(cal.getTime()),job_name+1);Thread.sleep(11); // System.out.println("【修改時(shí)間】開(kāi)始(每2秒輸出一次)..."); // QuartzManager.modifyJobTime(job_name, "10/2 * * * * ?"); // Thread.sleep(6000); // System.out.println("【移除定時(shí)】開(kāi)始..."); // QuartzManager.removeJob(job_name); // System.out.println("【移除定時(shí)】成功"); // // System.out.println("【再次添加定時(shí)任務(wù)】開(kāi)始(每10秒輸出一次)..."); // QuartzManager.addJob(job_name, QuartzJob.class, "*/10 * * * * ?"); // Thread.sleep(60000); // System.out.println("【移除定時(shí)】開(kāi)始..."); // QuartzManager.removeJob(job_name); // System.out.println("【移除定時(shí)】成功");} catch (Exception e) {e.printStackTrace();}} }

不過(guò)最后發(fā)現(xiàn)，還是沒(méi)法做動(dòng)態(tài)延遲。后面用延時(shí)mq實(shí)現(xiàn)的。

轉(zhuǎn)載于:https://www.cnblogs.com/foreverzxb/p/6491190.html

總結(jié)

以上是生活随笔為你收集整理的java 动态增加定时任务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。