一个简单的quartz动态定时示例演示

package com.telek.framework.quartz; import org.quartz.CronTrigger; import org.quartz.JobDataMap; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.Trigger; import org.quartz.impl.StdScheduler; import org.springframework.context.ApplicationContext; import org.springframework.context.support.ClassPathXmlApplicationContext; /** * Description:任务管理器封装类，对任务的统一管理功能，有增，删，查 * QuartzManager.java Create on 2012-11-23 上午9:19:15 * @author 张景 * @version 1.0 * Copyright (c) 2012 telek. All Rights Reserved. */ public class QuartzManager { private static Scheduler scheduler; static { ApplicationContext context = new ClassPathXmlApplicationContext( "applicationContext-quartz.xml"); scheduler = (StdScheduler) context.getBean("schedulerFactory"); } /** * Description:启动一个自定义的job * Date:2012-11-23 * @author 张景 * @param @param schedulingJob * @param @param paramsMap * @param @param isStateFull * @param @return * @return boolean */ public static boolean enableCronSchedule(CustomJob schedulingJob, JobDataMap paramsMap, boolean isStateFull) { if (schedulingJob == null) { return false; } try { CronTrigger trigger = (CronTrigger) scheduler .getTrigger(schedulingJob.getTriggerName(), schedulingJob.getJobGroup()); if (null == trigger) {// 如果不存在该trigger则创建一个 JobDetail jobDetail = null; if (isStateFull) { jobDetail = new JobDetail(schedulingJob.getJobId(), schedulingJob.getJobGroup(), schedulingJob.getStateFulljobExecuteClass()); } else { jobDetail = new JobDetail(schedulingJob.getJobId(), schedulingJob.getJobGroup(), schedulingJob.getJobExecuteClass()); } jobDetail.setJobDataMap(paramsMap); trigger = new CronTrigger(schedulingJob.getTriggerName(), schedulingJob.getJobGroup(), schedulingJob.getCronExpression()); scheduler.scheduleJob(jobDetail, trigger); } else {// Trigger已存在，那么更新相应的定时设置 trigger.setCronExpression(schedulingJob.getCronExpression()); scheduler.rescheduleJob(trigger.getName(), trigger.getGroup(), trigger); } } catch (Exception e) { e.printStackTrace(); return false; } return true; } /** * Description:禁用一个job * Date:2012-11-23 * @author 张景 * @param @param jobId * @param @param jobGroupId * @param @return * @return boolean */ public static boolean disableSchedule(String jobId, String jobGroupId) { if (jobId.equals("") || jobGroupId.equals("")) { return false; } try { Trigger trigger = getJobTrigger(jobId, jobGroupId); if (null != trigger) { scheduler.deleteJob(jobId, jobGroupId); } } catch (SchedulerException e) { e.printStackTrace(); return false; } return true; } /** * Description:得到job的详细信息 * Date:2012-11-23 * @author 张景 * @param @param jobId * @param @param jobGroupId * @param @return * @return JobDetail */ public static JobDetail getJobDetail(String jobId, String jobGroupId) { if (jobId.equals("") || jobGroupId.equals("") || null == jobId || jobGroupId == null) { return null; } try { return scheduler.getJobDetail(jobId, jobGroupId); } catch (SchedulerException e) { e.printStackTrace(); return null; } } /** * Description:得到job对应的Trigger * Date:2012-11-23 * @author 张景 * @param @param jobId * @param @param jobGroupId * @param @return * @return Trigger */ public static Trigger getJobTrigger(String jobId, String jobGroupId) { if (jobId.equals("") || jobGroupId.equals("") || null == jobId || jobGroupId == null) { return null; } try { return scheduler.getTrigger(jobId + "Trigger", jobGroupId); } catch (SchedulerException e) { e.printStackTrace(); return null; } } }