【优化技术专题】「温故而知新」基于Quartz系列的任务调度框架的动态化任务实现分析

/**
 * 定时任务运行工厂类
 * 
 * User: liyd
 * Date: 14-1-3
 * Time: 上午10:11
 */
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() + "]");
    } 
}
复制代码

/**
* 定时任务运行工厂类
* <p/>
* User: liyd
* Date: 14-1-3
* Time: 上午10:11
*/
@DisallowConcurrentExecution
public class QuartzJobFactory implements Job {...}
复制代码

/**
 * 计划任务信息
 * User: liyd
 * Date: 14-1-3
 * Time: 上午10:24
 */
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<String, ScheduleJob> jobMap = new HashMap<String, ScheduleJob>();
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);
}
复制代码

Scheduler scheduler = schedulerFactoryBean.getScheduler();
//这里获取任务信息数据
List<ScheduleJob> jobList = DataWorkContext.getAllJob();
for (ScheduleJob job : jobList) {
    TriggerKey T = 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);
    }
}
复制代码

ScheduleJob scheduleJob = (ScheduleJob)context.getMergedJobDataMap().get("scheduleJob");
复制代码

Scheduler scheduler = schedulerFactoryBean.getScheduler(); 
  GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup(); 
  Set<JobKey> jobKeys = scheduler.getJobKeys(matcher); 
  List<ScheduleJob> jobList = new ArrayList<ScheduleJob>(); 
  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<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs(); 
List<ScheduleJob> jobList = new ArrayList<ScheduleJob>(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);  
复制代码