對於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();
}
}
}