开源框架Quartz动态加入、改动和删除定时任务 (二)
2024-09-04 14:37:08
貌似每次回过头去看之前写的一些东西，总感觉不是非常完美~~虽说不做完美人。但也要做完美事！这次主要是针对Quartz的动态维护和Spring集成。简单粗暴一点，直接上代码，有什么不了解留言交流
先来一个定时任务相关准备工作
package com.hupu.timertask; /**
* 任务调度类
* @author Joyce.Luo
* @date 2015-3-31 下午03:32:04
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
public class QuartzJob {
/**
* 任务ID
*/
private Integer jobId; /**
* 任务名称
*/
private String jobName; /**
* 任务分组
*/
private String jobGroup; /**
* 任务状态 0禁用 1启用 2删除
*/
private Integer jobStatus; /**
* 任务执行时间表达式
*/
private String cronExpression; /**
* @return the jobId
*/
public Integer getJobId() {
return jobId;
} /**
* @param jobId
* the jobId to set
*/
public void setJobId(Integer jobId) {
this.jobId = jobId;
} /**
* @return the jobName
*/
public String getJobName() {
return jobName;
} /**
* @param jobName
* the jobName to set
*/
public void setJobName(String jobName) {
this.jobName = jobName;
} /**
* @return the jobGroup
*/
public String getJobGroup() {
return jobGroup;
} /**
* @param jobGroup
* the jobGroup to set
*/
public void setJobGroup(String jobGroup) {
this.jobGroup = jobGroup;
} /**
* @return the jobStatus
*/
public Integer getJobStatus() {
return jobStatus;
} /**
* @param jobStatus
* the jobStatus to set
*/
public void setJobStatus(Integer jobStatus) {
this.jobStatus = jobStatus;
} /**
* @return the cronExpression
*/
public String getCronExpression() {
return cronExpression;
} /**
* @param cronExpression
* the cronExpression to set
*/
public void setCronExpression(String cronExpression) {
this.cronExpression = cronExpression;
}
}
定时任务
package com.hupu.timertask; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.quartz.impl.StdScheduler; /**
* 任务调度管理类
* @author Joyce.Luo
* @date 2015-3-31 下午03:42:30
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
public class QuartzManager {
private static final Logger logger = LogManager.getLogger(QuartzManager.class.getName());
private StdScheduler scheduler; /**
* @param scheduler the scheduler to set
*/
public void setScheduler(StdScheduler scheduler) {
this.scheduler = scheduler;
} /**
* 初始化任务调度
* @author Joyce.Luo
* @date 2015-3-31 下午03:48:55
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
@SuppressWarnings("unchecked")
public void initJob(QuartzJob job, Class cls){
logger.info("初始化任务调度");
try {
TriggerKey triggerKey = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
if (null == trigger) {
addQuartzJob(job, trigger, cls);
}
} catch (Exception e) {
logger.error("初始化任务调度异常！" + e.getMessage(), e);
}
} /**
* 向任务调度中加入定时任务
* @param job 定时任务信息
* @param trigger 定时调度触发器
* @author Joyce.Luo
* @date 2015-3-31 下午04:04:58
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
@SuppressWarnings("unchecked")
private void addQuartzJob(QuartzJob job, CronTrigger trigger, Class cls){
logger.info("向任务调度中加入定时任务");
try {
JobDetail jobDetail = JobBuilder.newJob(cls)
.withIdentity(job.getJobName(), job.getJobGroup()).build();
jobDetail.getJobDataMap().put(job.getJobName(), job);
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());
trigger = TriggerBuilder.newTrigger().withIdentity(job.getJobName(), job.getJobGroup())
.withSchedule(scheduleBuilder).build();
scheduler.scheduleJob(jobDetail, trigger);
} catch (Exception e) {
logger.error("向任务调度中加入定时任务异常。" + e.getMessage(), e);
}
} /**
* 马上执行定时任务
* @param job 定时任务信息
* @author Joyce.Luo
* @date 2015-4-20 下午02:08:41
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
void runJob(QuartzJob job){
logger.info("马上执行任务调度中的定时任务");
try {
if (null == job) {
logger.info("定时任务信息为空，无法马上执行");
return;
}
JobKey jobKey = JobKey.jobKey(job.getJobName(), job.getJobGroup());
if(null == jobKey){
logger.info("任务调度中不存在[" + job.getJobName() + "]定时任务。不予马上执行！ ");
return;
}
scheduler.triggerJob(jobKey);
} catch (Exception e) {
logger.error("马上执行任务调度中的定时任务异常。" + e.getMessage(), e);
}
} /**
* 改动任务调度中的定时任务
* @param job 定时任务信息
* @param triggerKey 定时调度触发键
* @param trigger 定时调度触发器
* @author Joyce.Luo
* @date 2015-3-31 下午04:16:54
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
void updateQuartzJob(QuartzJob job, TriggerKey triggerKey, CronTrigger trigger){
logger.info("改动任务调度中的定时任务");
try {
if (null == job || null == triggerKey || null == trigger) {
logger.info("改动调度任务參数不正常！ ");
return;
}
logger.info("原始任务表达式:" + trigger.getCronExpression()
+ "，如今任务表达式:" + job.getCronExpression());
if (trigger.getCronExpression().equals(job.getCronExpression())) {
logger.info("任务调度表达式一致，不予进行改动！");
return;
}
logger.info("任务调度表达式不一致。进行改动");
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCronExpression());
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
scheduler.rescheduleJob(triggerKey, trigger);
} catch (Exception e) {
logger.error("改动任务调度中的定时任务异常！" + e.getMessage(), e);
}
} /**
* 暂停任务调度中的定时任务
* @param job 定时任务信息
* @author Joyce.Luo
* @date 2015-4-20 下午02:22:53
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
void pauseJob(QuartzJob job){
logger.info("暂停任务调度中的定时任务");
try {
if (null == job) {
logger.info("暂停调度任务參数不正常！");
return;
}
JobKey jobKey = JobKey.jobKey(job.getJobName(), job.getJobGroup());
if(null == jobKey){
logger.info("任务调度中不存在[" + job.getJobName() + "]定时任务，不予进行暂停。");
return;
}
scheduler.pauseJob(jobKey);
} catch (Exception e) {
logger.error("暂停任务调度中的定时任务异常。" + e.getMessage(), e);
}
} /**
* 恢复任务调度中的定时任务
* @param job 定时任务信息
* @author Joyce.Luo
* @date 2015-4-20 下午02:26:08
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
void resumeJob(QuartzJob job){
logger.info("恢复任务调度中的定时任务");
try {
if (null == job) {
logger.info("恢复调度任务參数不正常！");
return;
}
JobKey jobKey = JobKey.jobKey(job.getJobName(), job.getJobGroup());
if(null == jobKey){
logger.info("任务调度中不存在[" + job.getJobName() + "]定时任务。不予进行恢复！");
return;
}
scheduler.resumeJob(jobKey);
} catch (Exception e) {
logger.error("恢复任务调度中的定时任务异常！ " + e.getMessage(), e);
}
} /**
* 删除任务调度中的定时任务
* @param job 定时任务信息
* @author Joyce.Luo
* @date 2015-3-31 下午04:30:03
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
void deleteJob(QuartzJob job){
logger.info("删除任务调度中的定时任务");
try {
if (null == job) {
logger.info("删除调度任务參数不正常！");
return;
}
JobKey jobKey = JobKey.jobKey(job.getJobName(), job.getJobGroup());
if(null == jobKey){
logger.info("任务调度中不存在[" + job.getJobName() + "]定时任务，不予进行删除！");
return;
}
scheduler.deleteJob(jobKey);
} catch (Exception e) {
logger.error("删除任务调度中的定时任务异常！ " + e.getMessage(), e);
}
} /**
* 删除任务调度定时器
* @param triggerKey
* @author Joyce.Luo
* @date 2015-3-31 下午04:35:33
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
void deleteJob(TriggerKey triggerKey){
logger.info("删除任务调度定时器");
try {
if(null == triggerKey){
logger.info("停止任务定时器參数不正常，不予进行停止！ ");
return;
}
logger.info("停止任务定时器");
scheduler.pauseTrigger(triggerKey);
scheduler.unscheduleJob(triggerKey);
} catch (Exception e) {
logger.info("删除任务调度定时器异常。" + e.getMessage() ,e);
}
}
}
任务调度工厂
package com.hupu.timertask; import java.util.Date; import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; import com.hupu.util.FormatUtil; /**
* 任务调度工厂类
* @author Joyce.Luo
* @date 2015-3-31 下午03:38:35
* @version V3.0
* @since Tomcat6.0,Jdk1.6
* @copyright Copyright (c) 2015
*/
public class QuartzJobFactory implements Job {
private static final Logger logger = LogManager.getLogger(QuartzJobFactory.class.getName()); @Override
public void execute(JobExecutionContext context) throws JobExecutionException {
QuartzJob scheduleJob = (QuartzJob)context.getMergedJobDataMap().get("backup_job");
logger.info("定时任务開始执行，任务名称[" + scheduleJob.getJobName() + "]");
Date previousFireTime = context.getPreviousFireTime();
if(null != previousFireTime){
logger.info("定时任务上次调度时间：" + FormatUtil.formatDate(previousFireTime));
}
logger.info("定时任务下次调度时间：" + FormatUtil.formatDate(context.getNextFireTime()));
// 执行业务逻辑
}
}
到这里代码基本结束，至于Spring的配置，这个就不用多讲了哈~~~
得嘞。简单的说到这里吧
最新文章
- 翻译：使用 ASP.NET MVC 4, EF, Knockoutjs and Bootstrap 设计和开发站点 - 1
- FunDA（0）－ Functional Data Access accessible to all
- Repeater分页代码
- [转]jQuery: how to get which button was clicked upon form submission?
- Android开发学习笔记--给一个按钮定义事件
- UESTC 30 最短路，floyd，水
- 用include来处理模板的问题
- 20个2014年最优秀的PHP框架
- Update与Mysql、Sqlsever中的随机数
- 浅谈Jquery的使用下篇
- struts2+ajax实现异步验证实现
- MySql入门(1)
- Linux 获得机器的IP和网卡信息
- JavaScript 将两个数组合并，且删除重复的值
- C#调用Windows(8/10)自带的虚拟键盘
- 转:Eclipse中web项目部署至Tomcat步骤
- SeaJS：一个适用于 Web 浏览器端的模块加载器
- Matlab:线性热传导（抛物线方程）问题
- js基础系列之【作用域】
- 【ATcoder】Xor Sum 2