Spring利用Quartz实现一个动态定时任务

  
    org.springframework
    spring-core
    ${spring.version}
  
  
    org.springframework
    spring-context
    ${spring.version}
  
  
    org.springframework
    spring-web
    ${spring.version}
  
  
    org.springframework
    spring-tx
    ${spring.version}
  
  
    org.springframework
    spring-jdbc
    ${spring.version}
  
  
    org.mybatis
    mybatis
    ${mybatis.version}
  
  
    org.aspectj
    aspectjweaver
    1.7.4
  
  
    org.mybatis
    mybatis-spring
    ${mybatis.spring.version}
  
  
    org.slf4j
    slf4j-log4j12
    ${slf4j.version}
  
  
    commons-lang
    commons-lang
    ${commons.lang.version}
  
  
    commons-dbcp
    commons-dbcp
    ${commons.dbcp.version}
  
  
    com.oracle
    ojdbc14
    ${ojdbc.version}
  
  
    org.springframework
    spring-context-support
    ${spring.version}
  
  
    org.quartz-scheduler
    quartz
    ${quartz.version}
  

  
  
  
  
  
    
  
  
    run
  




  
  
  
    
  
  
    0/5 * * * * ?
  




  
    
      
    
  

//@Component
public class DataConversionTask{

  /** 日志对象 */
  private static final Logger LOG = LoggerFactory.getLogger(DataConversionTask.class);

  public void run() {

    if (LOG.isInfoEnabled()) {
      LOG.info("数据转换任务线程开始执行");
    }
  }
}

"0 0 12 * * ?"       每天中午12点触发
"0 15 10 ? * *"       每天上午10:15触发
"0 15 10 * * ?"       每天上午10:15触发
"0 15 10 * * ? *"      每天上午10:15触发
"0 15 10 * * ? 2005"    2005年的每天上午10:15触发
"0 * 14 * * ?"       在每天下午2点到下午2:59期间的每1分钟触发
"0 0/5 14 * * ?"      在每天下午2点到下午2:55期间的每5分钟触发
"0 0/5 14,18 * * ?"     在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
"0 0-5 14 * * ?"      在每天下午2点到下午2:05期间的每1分钟触发
"0 10,44 14 ? 3 WED"    每年三月的星期三的下午2:10和2:44触发
"0 15 10 ? * MON-FRI"    周一至周五的上午10:15触发
"0 15 10 15 * ?"      每月15日上午10:15触发
"0 15 10 L * ?"       每月最后一日的上午10:15触发
"0 15 10 ? * 6L"      每月的最后一个星期五上午10:15触发
"0 15 10 ? * 6L 2002-2005" 2002年至2005年的每月的最后一个星期五上午10:15触发
"0 15 10 ? * 6#3"      每月的第三个星期五上午10:15触发
0 6 * * *          每天早上6点
0 */2 * * *         每两个小时
0 23-7/2，8 * * *      晚上11点到早上8点之间每两个小时，早上八点
0 11 4 * 1-3        每个月的4号和每个礼拜的礼拜一到礼拜三的早上11点
0 4 1 1 *          1月1日早上4点

  
  
  
  
  
    
  
  
    execute
  




  
  
  
    
  
  
    0/5 * * * * ?
  




  
    
      
    
  

public interface JobDetail extends Serializable, Cloneable {…｝ 

/**
 * This implementation applies the passed-in job data map as bean property
 * values, and delegates to executeInternal afterwards.
 * @see #executeInternal
 */
public final void execute(JobExecutionContext context) throws JobExecutionException {
  try {
    // Reflectively adapting to differences between Quartz 1.x and Quartz 2.0...
    Scheduler scheduler = (Scheduler) ReflectionUtils.invokeMethod(getSchedulerMethod, context);
    Map mergedJobDataMap = (Map) ReflectionUtils.invokeMethod(getMergedJobDataMapMethod, context);

    BeanWrapper bw = PropertyAccessorFactory.forBeanPropertyAccess(this);
    MutablePropertyValues pvs = new MutablePropertyValues();
    pvs.addPropertyValues(scheduler.getContext());
    pvs.addPropertyValues(mergedJobDataMap);
    bw.setPropertyValues(pvs, true);
  }
  catch (SchedulerException ex) {
    throw new JobExecutionException(ex);
  }
  executeInternal(context);
}

/**
 * Execute the actual job. The job data map will already have been
 * applied as bean property values by execute. The contract is
 * exactly the same as for the standard Quartz execute method.
 * @see #execute
 */
protected abstract void executeInternal(JobExecutionContext context) throws JobExecutionException;
//还有MethodInvokingJobDetailFactoryBean中的代码：

public void afterPropertiesSet() throws ClassNotFoundException, NoSuchMethodException {
  prepare();

  // Use specific name if given, else fall back to bean name.
  String name = (this.name != null ? this.name : this.beanName);

  // Consider the concurrent flag to choose between stateful and stateless job.
  Class jobClass = (this.concurrent ? MethodInvokingJob.class : StatefulMethodInvokingJob.class);

  // Build JobDetail instance.
  if (jobDetailImplClass != null) {
    // Using Quartz 2.0 JobDetailImpl class...
    this.jobDetail = (JobDetail) BeanUtils.instantiate(jobDetailImplClass);
    BeanWrapper bw = PropertyAccessorFactory.forBeanPropertyAccess(this.jobDetail);
    bw.setPropertyValue("name", name);
    bw.setPropertyValue("group", this.group);
    bw.setPropertyValue("jobClass", jobClass);
    bw.setPropertyValue("durability", true);
    ((JobDataMap) bw.getPropertyValue("jobDataMap")).put("methodInvoker", this);
  }
  else {
    // Using Quartz 1.x JobDetail class...
    this.jobDetail = new JobDetail(name, this.group, jobClass);
    this.jobDetail.setVolatility(true);
    this.jobDetail.setDurability(true);
    this.jobDetail.getJobDataMap().put("methodInvoker", this);
  }

  // Register job listener names.
  if (this.jobListenerNames != null) {
    for (String jobListenerName : this.jobListenerNames) {
      if (jobDetailImplClass != null) {
        throw new IllegalStateException("Non-global JobListeners not supported on Quartz 2 - " +
            "manually register a Matcher against the Quartz ListenerManager instead");
      }
      this.jobDetail.addJobListener(jobListenerName);
    }
  }

  postProcessJobDetail(this.jobDetail);
}

/**
 * 定时任务运行工厂类
 * 
 * @author tq
 * @date 2016/5/1
 */
public class QuartzJobFactory implements Job {

  @Override
  public void execute(JobExecutionContext context) throws JobExecutionException {
    System.out.println("任务成功运行");
    ScheduleJob scheduleJob = (ScheduleJob)context.getMergedJobDataMap().get("scheduleJob");
    System.out.println("任务名称 = [" + scheduleJob.getJobName() + "]");
  }
}

/**
* 定时任务运行工厂类
 * @author tq
 * @date 2016/5/1
*/
@DisallowConcurrentExecution
public class QuartzJobFactory implements Job {...}

/**
 * 计划任务信息
 * 
 * @author tq
 * @date 2016/5/1
 */
public class ScheduleJob {
  /** 任务id */
  private String jobId;
  /** 任务名称 */
  private String jobName;
  /** 任务分组 */
  private String jobGroup;
  /** 任务状态 0禁用 1启用 2删除*/
  private String jobStatus;
  /** 任务运行时间表达式 */
  private String cronExpression;
  /** 任务描述 */
  private String desc;
  getter and setter ....
}

/** 计划任务map */
private static Map jobMap = new HashMap();

static {
  for (int i = 0; i < 5; i++) {
    ScheduleJob job = new ScheduleJob();
    job.setJobId("10001" + i);
    job.setJobName("data_import" + i);
    job.setJobGroup("dataWork");
    job.setJobStatus("1");
    job.setCronExpression("0/5 * * * * ?");
    job.setDesc("数据导入任务");
    addJob(job);
  }
}

/**
 * 添加任务
 * @param scheduleJob
 */
public static void addJob(ScheduleJob scheduleJob) {
  jobMap.put(scheduleJob.getJobGroup() + "_" + scheduleJob.getJobName(), scheduleJob);
}

//schedulerFactoryBean 由spring创建注入
Scheduler scheduler = schedulerFactoryBean.getScheduler();

//这里获取任务信息数据
List jobList = DataWorkContext.getAllJob();

for (ScheduleJob job : jobList) {

  TriggerKey triggerKey = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());

  //获取trigger，即在spring配置文件中定义的 bean id="myTrigger"
  CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);

  //不存在，创建一个
  if (null == trigger) {
    JobDetail jobDetail = JobBuilder.newJob(QuartzJobFactory.class)
      .withIdentity(job.getJobName(), job.getJobGroup()).build();
    jobDetail.getJobDataMap().put("scheduleJob", job);

    //表达式调度构建器
    CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job
      .getCronExpression());

    //按新的cronExpression表达式构建一个新的trigger
    trigger = TriggerBuilder.newTrigger().withIdentity(job.getJobName(), job.getJobGroup()).withSchedule(scheduleBuilder).build();

    scheduler.scheduleJob(jobDetail, trigger);
  } else {
    // Trigger已存在，那么更新相应的定时设置
    //表达式调度构建器
    CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job
      .getCronExpression());

    //按新的cronExpression表达式重新构建trigger
    trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)
      .withSchedule(scheduleBuilder).build();

    //按新的trigger重新设置job执行
    scheduler.rescheduleJob(triggerKey, trigger);
  }
}

Scheduler scheduler = schedulerFactoryBean.getScheduler();
GroupMatcher matcher = GroupMatcher.anyJobGroup();
Set jobKeys = scheduler.getJobKeys(matcher);
List jobList = new ArrayList();
for (JobKey jobKey : jobKeys) {
  List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
  for (Trigger trigger : triggers) {
    ScheduleJob job = new ScheduleJob();
    job.setJobName(jobKey.getName());
    job.setJobGroup(jobKey.getGroup());
    job.setDesc("触发器:" + trigger.getKey());
    Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
    job.setJobStatus(triggerState.name());
    if (trigger instanceof CronTrigger) {
      CronTrigger cronTrigger = (CronTrigger) trigger;
      String cronExpression = cronTrigger.getCronExpression();
      job.setCronExpression(cronExpression);
    }
    jobList.add(job);
  }
}

Scheduler scheduler = schedulerFactoryBean.getScheduler();
List executingJobs = scheduler.getCurrentlyExecutingJobs();
List jobList = new ArrayList(executingJobs.size());
for (JobExecutionContext executingJob : executingJobs) {
  ScheduleJob job = new ScheduleJob();
  JobDetail jobDetail = executingJob.getJobDetail();
  JobKey jobKey = jobDetail.getKey();
  Trigger trigger = executingJob.getTrigger();
  job.setJobName(jobKey.getName());
  job.setJobGroup(jobKey.getGroup());
  job.setDesc("触发器:" + trigger.getKey());
  Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
  job.setJobStatus(triggerState.name());
  if (trigger instanceof CronTrigger) {
    CronTrigger cronTrigger = (CronTrigger) trigger;
    String cronExpression = cronTrigger.getCronExpression();
    job.setCronExpression(cronExpression);
  }
  jobList.add(job);
}

Scheduler scheduler = schedulerFactoryBean.getScheduler();
JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
scheduler.pauseJob(jobKey);

Scheduler scheduler = schedulerFactoryBean.getScheduler();
JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
scheduler.resumeJob(jobKey);

Scheduler scheduler = schedulerFactoryBean.getScheduler();
JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
scheduler.deleteJob(jobKey);

Scheduler scheduler = schedulerFactoryBean.getScheduler();
JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
scheduler.triggerJob(jobKey);

Scheduler scheduler = schedulerFactoryBean.getScheduler();

TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(),
  scheduleJob.getJobGroup());

//获取trigger，即在spring配置文件中定义的 bean id="myTrigger"
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);

//表达式调度构建器
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob
  .getCronExpression());

//按新的cronExpression表达式重新构建trigger
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)
  .withSchedule(scheduleBuilder).build();

//按新的trigger重新设置job执行
scheduler.rescheduleJob(triggerKey, trigger);