/** * 任务调度类 * @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;}}
import org.apache.log4j.Logger;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;import com.hupu.nac.biz.IAuthPolicyClientBiz;/** * 客户端长连接断开任务调度工厂类 * @author Joyce.Luo * @date 2015-3-31 下午03:38:35 * @version V3.0 * @since Tomcat6.0,Jdk1.6 * @copyright Copyright (c) 2015 */public class LinkDisconnectQuartzJobFactory implements Job {private static final Logger logger = Logger.getLogger(LinkDisconnectQuartzJobFactory.class);@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {QuartzJob scheduleJob = (QuartzJob)context.getMergedJobDataMap().get("linkDisconnectJob");logger.info("客户端长连接断开定时任务开始执行，，任务名称[" + scheduleJob.getJobName() + "]");}}
import org.apache.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 LinkDisconnectQuartzManager {private static final Logger logger = Logger.getLogger(LinkDisconnectQuartzManager.class);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*/public void initJob(){logger.info("初始化客户端长连接断开任务调度");QuartzJob job = new QuartzJob();job.setJobName("link_disconnect_job");job.setJobGroup("link_disconnect_group");job.setJobStatus(1);job.setCronExpression("0 0/1 * * * ?");try {TriggerKey triggerKey = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);if (null == trigger) {addQuartzJob(job, trigger);}} 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*/private void addQuartzJob(QuartzJob job, CronTrigger trigger){logger.info("向任务调度中添加定时任务");try {JobDetail jobDetail = JobBuilder.newJob(LinkDisconnectQuartzJobFactory.class).withIdentity(job.getJobName(), job.getJobGroup()).build();jobDetail.getJobDataMap().put("linkDisconnectJob", 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 定时任务信息* @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-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.resumeJob(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.resumeTrigger(triggerKey);} catch (Exception e) {logger.info("删除任务调度定时器异常！" + e.getMessage() ,e);}}}
所有的胜利，与征服自己的胜利比起来，都是微不足道
