springboot整合quartz實(shí)現(xiàn)多個(gè)定時(shí)任務(wù)的方法

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

成都創(chuàng)新互聯(lián)主營(yíng)江源網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營(yíng)網(wǎng)站建設(shè)方案,重慶APP開發(fā)公司,江源h5微信小程序開發(fā)搭建,江源網(wǎng)站營(yíng)銷推廣歡迎江源等地區(qū)企業(yè)咨詢

1、新建兩個(gè)定時(shí)任務(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、配置以上兩個(gè)任務(wù)

@Component 
public class SchedulerAllJob { 
  @Autowired 
  private SchedulerFactoryBean schedulerFactoryBean;    
  /* 
   * 此處可以注入數(shù)據(jù)庫操作,查詢出所有的任務(wù)配置 
   */    
  /** 
   * 該方法用來啟動(dòng)所有的定時(shí)任務(wù) 
   * @throws SchedulerException 
   */ 
  public void scheduleJobs() throws SchedulerException { 
    Scheduler scheduler = schedulerFactoryBean.getScheduler();      
    /** 
     *  
     */ 
    scheduleJob1(scheduler);  
    scheduleJob2(scheduler);  
  } 
   
  /** 
   * 配置Job1 
   * 此處的任務(wù)可以配置可以放到properties或者是放到數(shù)據(jù)庫中 
   * 如果此時(shí)需要做到動(dòng)態(tài)的定時(shí)任務(wù),請(qǐng)參考: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í)數(shù)據(jù)庫中沒有查詢到該任務(wù),則按照下面的步驟新建一個(gè)任務(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、啟動(dòng)兩個(gè)任務(wù)

@Configuration 
@EnableScheduling 
@Component 
public class SchedulerListener {    
  @Autowired 
  public SchedulerAllJob myScheduler;    
  /** 
   * 啟動(dòng)的時(shí)候執(zhí)行該方法,或者是使用ApplicationListener,在啟動(dòng)的時(shí)候執(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、測(cè)試結(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……………………………………  

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持創(chuàng)新互聯(lián)。

網(wǎng)站標(biāo)題:springboot整合quartz實(shí)現(xiàn)多個(gè)定時(shí)任務(wù)的方法
網(wǎng)頁網(wǎng)址:http://bm7419.com/article10/pciedo.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供品牌網(wǎng)站建設(shè)、企業(yè)網(wǎng)站制作、品牌網(wǎng)站制作、營(yíng)銷型網(wǎng)站建設(shè)、App開發(fā)

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

成都網(wǎng)站建設(shè)