快捷導(dǎo)航

spring boot整合quartz實現(xiàn)多個定時任務(wù)的方法

更新時間：2018年01月16日 11:33:24 作者：牛奮lch

這篇文章主要介紹了spring boot整合quartz實現(xiàn)多個定時任務(wù)的方法，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

最近收到了很多封郵件，都是想知道spring boot整合quartz如何實現(xiàn)多個定時任務(wù)的，由于本人生產(chǎn)上并沒有使用到多個定時任務(wù)，這里給個實現(xiàn)的思路。

1、新建兩個定時任務(wù)，如下：

public class ScheduledJob implements Job{  
  @Override 
  public void execute(JobExecutionContext context) throws JobExecutionException {  
    System.out.println("schedule job1 is running…………………………………… ");  
  } 
} 
public class ScheduledJob2 implements Job { 
 
  @Override 
  public void execute(JobExecutionContext context) throws JobExecutionException {  
    System.out.println("schedule job2 is running ……………………………………………………");  
  } 
}

2、配置以上兩個任務(wù)

@Component 
public class SchedulerAllJob { 
  @Autowired 
  private SchedulerFactoryBean schedulerFactoryBean;    
  /* 
   * 此處可以注入數(shù)據(jù)庫操作，查詢出所有的任務(wù)配置 
   */    
  /** 
   * 該方法用來啟動所有的定時任務(wù) 
   * @throws SchedulerException 
   */ 
  public void scheduleJobs() throws SchedulerException { 
    Scheduler scheduler = schedulerFactoryBean.getScheduler();      
    /** 
     *  
     */ 
    scheduleJob1(scheduler);  
    scheduleJob2(scheduler);  
  } 
   
  /** 
   * 配置Job1 
   * 此處的任務(wù)可以配置可以放到properties或者是放到數(shù)據(jù)庫中 
   * 如果此時需要做到動態(tài)的定時任務(wù)，請參考：http://blog.csdn.net/liuchuanhong1/article/details/60873295 
   * 博客中的ScheduleRefreshDatabase類 
   * @param scheduler 
   * @throws SchedulerException 
   */ 
  private void scheduleJob1(Scheduler scheduler) throws SchedulerException{ 
    /* 
     * 此處可以先通過任務(wù)名查詢數(shù)據(jù)庫，如果數(shù)據(jù)庫中存在該任務(wù)，則按照ScheduleRefreshDatabase類中的方法，更新任務(wù)的配置以及觸發(fā)器 
     * 如果此時數(shù)據(jù)庫中沒有查詢到該任務(wù)，則按照下面的步驟新建一個任務(wù)，并配置初始化的參數(shù)，并將配置存到數(shù)據(jù)庫中 
     */ 
    JobDetail jobDetail = JobBuilder.newJob(ScheduledJob.class) .withIdentity("job1", "group1").build();  
    // 每5s執(zhí)行一次 
    CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0/5 * * * * ?");  
    CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1") .withSchedule(scheduleBuilder).build();  
    scheduler.scheduleJob(jobDetail,cronTrigger);  
  }    
  /** 
   * 配置Job 
   * @param scheduler 
   * @throws SchedulerException 
   */ 
  private void scheduleJob2(Scheduler scheduler) throws SchedulerException{  
    JobDetail jobDetail = JobBuilder.newJob(ScheduledJob2.class) .withIdentity("job2", "group1").build(); 
    CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("0/10 * * * * ?");  
    // 每10s執(zhí)行一次 
    CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger2", "group1") .withSchedule(scheduleBuilder).build();  
    scheduler.scheduleJob(jobDetail,cronTrigger); 
  } 
}

3、啟動兩個任務(wù)

@Configuration 
@EnableScheduling 
@Component 
public class SchedulerListener {    
  @Autowired 
  public SchedulerAllJob myScheduler;    
  /** 
   * 啟動的時候執(zhí)行該方法，或者是使用ApplicationListener，在啟動的時候執(zhí)行該方法 
   * 具體使用見：http://blog.csdn.net/liuchuanhong1/article/details/77568187 
   * @throws SchedulerException 
   */ 
  @Scheduled(cron="0 08 18 ? * *") 
  public void schedule() throws SchedulerException {  
      myScheduler.scheduleJobs(); 
   }  
   
  @Bean 
  public SchedulerFactoryBean schedulerFactoryBean(){ 
    SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();  
    return schedulerFactoryBean;  
  } 
}

4、測試結(jié)果如下

schedule job1 is running……………………………………  
schedule job2 is running …………………………………………………… 
schedule job1 is running……………………………………  
schedule job1 is running……………………………………  
schedule job2 is running …………………………………………………… 
schedule job1 is running……………………………………  
schedule job1 is running……………………………………  
schedule job2 is running …………………………………………………… 
schedule job1 is running……………………………………

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: