如何对quartz定时任务设置结束时间
更新时间：2023年12月14日 09:12:08 作者：不喜欢吃猫的鱼
这篇文章主要介绍了如何对quartz定时任务设置结束时间问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
quartz定时任务设置结束时间
在使用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();
}
}
}
总结
以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。
相关文章
SpringBoot 是由Pivotal团队提供的全新框架，其设计目的是用来简化Spring应用的初始搭建以及开发过程，这篇文章主要介绍了SpringBoot简介、官网构建、快速启动,需要的朋友可以参考下2022-07-07
数据脱敏主要应用在客户安全数据或商业性敏感数据的情况,本文主要介绍了SpringBoot数据脱敏的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2024-05-05
spring mvc中的@ModelAttribute注解示例介绍
在Spring mvc中，注解@ModelAttribute是一个非常常用的注解，下面这篇文章主要给大家介绍了关于spring mvc中@ModelAttribute注解的相关资料，文中通过示例代码介绍的非常详细，需要的朋友可以参考下。2017-09-09
这篇文章主要介绍了Java常用流程控制语句实现原理解析,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下2020-08-08
这篇文章主要介绍了Docker容器中的SSH免密登录详解,在日常的开发和测试环境中经常需要创建和管理Docker容器,有时,出于调试或管理的目的,可能需要SSH到容器内部,本文将介绍如何创建一个Docker容器,它在启动时自动运行SSH服务,并支持免密登录,需要的朋友可以参考下2023-08-08
GC（Garbage Collection）称之为垃圾回收，是对内存中的垃圾对象,采用一定的算法进行内存回收的一个动作，这篇文章主要介绍了JVM中的GC初识,需要的朋友可以参考下2022-05-05
解决idea中svn提交时performing vcs refresh时间很长的问题
这篇文章主要介绍了解决idea中svn提交时performing vcs refresh时间很长的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2020-09-09
这篇文章主要介绍了多线程的常见案例，线程池(重点）、单例模式、阻塞队列，本文通过图文实例相结合给大家介绍的非常详细,需要的朋友可以参考下2022-05-05
聊聊Spring循环依赖三级缓存是否可以减少为二级缓存的情况
这篇文章主要介绍了聊聊Spring循环依赖三级缓存是否可以减少为二级缓存的情况，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧2021-02-02
潜艇大战游戏相信大家都玩过，是一款非常有趣的小游戏，那么基于代码是如何实现的呢？今天小编给大家带来一篇教程帮助大家学习java实现潜艇大战游戏，感谢的朋友一起看看吧2021-06-06
最新评论