對於quartz定時任務設定結束時間
阿新 • • 發佈:2018-12-10
在使用quartz時,使用cornTrigger再設定一個結束時間 endAt(“結束的時間”),實現在任務執後自動銷燬任務,在到了結束時間之後,job並不會留在記憶體中,job是直接被delete掉,所以不擔心會有記憶體滿的情況;
程式碼:
//按新的cronExpression表示式構建一個新的trigger trigger = TriggerBuilder.newTrigger() .withIdentity(triggerName, triggerGroupName) .withSchedule(scheduleBuilder) .endAt(endDate) .build();
附屬上查詢所有job程式碼:
/** * 查詢所有的job */ public static void getAllJobs(){ try { Scheduler scheduler = sf.getScheduler(); for (String groupName : scheduler.getJobGroupNames()) { for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) { String jobName = jobKey.getName(); String jobGroup = jobKey.getGroup(); //get job's trigger List<Trigger> triggers = (List<Trigger>) scheduler.getTriggersOfJob(jobKey); Date nextFireTime = triggers.get(0).getNextFireTime(); System.out.println("[jobName] : " + jobName + " [groupName] : " + jobGroup + " - " + nextFireTime); } } } catch (Exception e) { e.printStackTrace(); } }
下面是完整的quartz工具類:
import org.quartz.*; import org.quartz.impl.StdSchedulerFactory; import org.quartz.impl.matchers.GroupMatcher; import qgs.framework.core.task.JobFactory; import qgs.framework.util.utilty.DateUtil; import java.text.ParseException; import java.util.Date; import java.util.List; /** * create by XXX on 2018/09/03 * 定時任務工具類 */ public class QuartzUtil { private static SchedulerFactory sf = new StdSchedulerFactory(); private static JobFactory jobFactory = new JobFactory(); private static String JOB_GROUP_NAME = "group1"; private static String TRIGGER_GROUP_NAME = "trigger1"; /** * 新增一個定時任務,使用預設的任務組名,觸發器名,觸發器組名 * * @param jobName 任務名 * @param jobClass 任務類名 * @param time 時間設定,參考quartz說明文件 * @param data 定時任務所帶引數資料 * @param endDate 定時任務生命週期結束時間 * @throws ParseException */ public static void saveJobCron(String jobName, Class<? extends Job> jobClass, String time, JobDataMap data, Date endDate) throws Exception { saveJobCron(jobName, JOB_GROUP_NAME, jobName, TRIGGER_GROUP_NAME, jobClass, time, data, endDate); } /** * 新增一個定時任務,使用預設的任務組名,觸發器名,觸發器組名 * * @param jobName 任務名 * @param jobClass 任務類名 * @param time 時間設定,參考quartz說明文件 * @throws ParseException */ public static void saveJobCron(String jobName, Class<? extends Job> jobClass, String time) throws Exception { saveJobCron(jobName, JOB_GROUP_NAME, jobName, TRIGGER_GROUP_NAME, jobClass, time); } /** */ /** * 新增一個定時任務,使用預設的任務組名,觸發器名,觸發器組名 * * @param jobName 任務名 * @param jobClass 任務類名 * @param time 時間間隔 每隔多少時間執行一次 單位毫秒 如 1000*60*60 = 1小時 * @throws ParseException */ public static void saveJobSimple(String jobName, Class<? extends Job> jobClass, Integer time) throws Exception { saveJobSimple(jobName, JOB_GROUP_NAME, jobName, TRIGGER_GROUP_NAME, jobClass, time, true); } public static void saveJobSimple(String jobName, Class<? extends Job> jobClass, Integer time, boolean firstRun) throws Exception { saveJobSimple(jobName, JOB_GROUP_NAME, jobName, TRIGGER_GROUP_NAME, jobClass, time, firstRun); } /** */ /** * 新增一個定時任務 * * @param jobName 任務名 * @param jobGroupName 任務組名 * @param triggerName 觸發器名 * @param triggerGroupName 觸發器組名 * @param jobClass 任務類名 * @param time 時間間隔 每隔多少時間執行一次 單位秒 如 1000*60*60 = 1小時 * @throws SchedulerException * @throws ParseException * @throws ParseException */ public static void saveJobSimple(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class<? extends Job> jobClass, Integer time, boolean firstRun) throws Exception { Scheduler scheduler = sf.getScheduler(); scheduler.setJobFactory(jobFactory); TriggerKey triggerKey = TriggerKey.triggerKey(jobName, triggerGroupName); SimpleTrigger trigger = (SimpleTrigger) scheduler.getTrigger(triggerKey); //不存在,建立一個 if (null == trigger) { JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build(); //按新的cronExpression表示式構建一個新的trigger TriggerBuilder s = TriggerBuilder.newTrigger().withIdentity(triggerName, triggerGroupName); if (!firstRun) { s.startAt(DateUtil.addSecond(new Date(), time)); } trigger = (SimpleTrigger) s.withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(time).repeatForever()).build(); scheduler.scheduleJob(jobDetail, trigger); //啟動 if (!scheduler.isShutdown()) scheduler.start(); } else { // Trigger已存在,那麼更新相應的定時設定 //按新的cronExpression表示式重新構建trigger trigger = trigger.getTriggerBuilder().withIdentity(triggerKey) .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(time).repeatForever()).build(); //按新的trigger重新設定job執行 scheduler.rescheduleJob(triggerKey, trigger); } } /** * 新增一個定時任務 * * @param jobName 任務名 * @param jobGroupName 任務組名 * @param triggerName 觸發器名 * @param triggerGroupName 觸發器組名 * @param jobClass 任務類名 * @param time 時間設定,參考quartz說明文件 * @param data 對應定時認為中所涉及的資料 * @param endDate 定時任務週期結束時間 * @throws SchedulerException * @throws ParseException * @throws ParseException */ public static void saveJobCron(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class<? extends Job> jobClass, String time, JobDataMap data, Date endDate) throws Exception { Scheduler scheduler = sf.getScheduler(); scheduler.setJobFactory(jobFactory); TriggerKey triggerKey = TriggerKey.triggerKey(jobName, triggerGroupName); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); //不存在,建立一個 if (null == trigger) { JobDetail jobDetail = JobBuilder.newJob(jobClass) .withIdentity(jobName, jobGroupName) .setJobData(data) .build(); //表示式排程構建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time); //按新的cronExpression表示式構建一個新的trigger trigger = TriggerBuilder.newTrigger() .withIdentity(triggerName, triggerGroupName) .withSchedule(scheduleBuilder) .endAt(endDate) .build(); scheduler.scheduleJob(jobDetail, trigger); //啟動 if (!scheduler.isShutdown()) scheduler.start(); } else { // Trigger已存在,那麼更新相應的定時設定 //表示式排程構建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time); //按新的cronExpression表示式重新構建trigger trigger = trigger.getTriggerBuilder() .withIdentity(triggerKey) .withSchedule(scheduleBuilder) .startAt(new Date()) .endAt(endDate).build(); //按新的trigger重新設定job執行 scheduler.rescheduleJob(triggerKey, trigger); } } /** * 新增一個定時任務 * * @param jobName 任務名 * @param jobGroupName 任務組名 * @param triggerName 觸發器名 * @param triggerGroupName 觸發器組名 * @param jobClass 任務類名 * @param time 時間設定,參考quartz說明文件 * @throws SchedulerException * @throws ParseException * @throws ParseException */ public static void saveJobCron(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class<? extends Job> jobClass, String time) throws Exception { Scheduler scheduler = sf.getScheduler(); scheduler.setJobFactory(jobFactory); TriggerKey triggerKey = TriggerKey.triggerKey(jobName, triggerGroupName); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); //不存在,建立一個 if (null == trigger) { JobDetail jobDetail = JobBuilder.newJob(jobClass) .withIdentity(jobName, jobGroupName) .build(); //表示式排程構建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time); //按新的cronExpression表示式構建一個新的trigger trigger = TriggerBuilder.newTrigger() .withIdentity(triggerName, triggerGroupName) .withSchedule(scheduleBuilder) .build(); scheduler.scheduleJob(jobDetail, trigger); //啟動 if (!scheduler.isShutdown()) scheduler.start(); } else { // Trigger已存在,那麼更新相應的定時設定 //表示式排程構建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time); //按新的cronExpression表示式重新構建trigger trigger = trigger.getTriggerBuilder().withIdentity(triggerKey) .withSchedule(scheduleBuilder).build(); //按新的trigger重新設定job執行 scheduler.rescheduleJob(triggerKey, trigger); } } /** */ /** * 移除一個任務(使用預設的任務組名,觸發器名,觸發器組名) * * @param jobName * @throws SchedulerException */ public static void removeJob(String jobName) throws Exception { removeJob(jobName, JOB_GROUP_NAME, jobName, TRIGGER_GROUP_NAME); } /** */ /** * 移除一個任務 * * @param jobName * @param jobGroupName * @param triggerName * @param triggerGroupName * @throws SchedulerException */ public static void removeJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName) throws Exception { Scheduler scheduler = sf.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName); scheduler.pauseTrigger(triggerKey);// 停止觸發器 scheduler.unscheduleJob(triggerKey);// 移除觸發器 scheduler.deleteJob(JobKey.jobKey(jobName, jobGroupName));// 刪除任務 } public static void shutdownJobs() throws Exception { Scheduler scheduler = sf.getScheduler(); try { if (!scheduler.isShutdown()) { scheduler.shutdown(); } } catch (Exception e) { throw new RuntimeException(e); } } /** * 查詢所有的job */ public static void getAllJobs(){ try { Scheduler scheduler = sf.getScheduler(); for (String groupName : scheduler.getJobGroupNames()) { for (JobKey jobKey : scheduler.getJobKeys(GroupMatcher.jobGroupEquals(groupName))) { String jobName = jobKey.getName(); String jobGroup = jobKey.getGroup(); //get job's trigger List<Trigger> triggers = (List<Trigger>) scheduler.getTriggersOfJob(jobKey); Date nextFireTime = triggers.get(0).getNextFireTime(); System.out.println("[jobName] : " + jobName + " [groupName] : " + jobGroup + " - " + nextFireTime); } } } catch (Exception e) { e.printStackTrace(); } } }