SpringBoot2taskscheduler定時任務調度器四種方式

使用@EnableScheduling方式

專注于為中小企業(yè)提供成都網站建設、做網站服務,電腦端+手機端+微信端的三站合一,更高效的管理,為中小企業(yè)義馬免費做網站提供優(yōu)質的服務。我們立足成都，凝聚了一批互聯網行業(yè)人才，有力地推動了成百上千企業(yè)的穩(wěn)健成長，幫助中小企業(yè)通過網站建設實現規(guī)模擴充和轉變。

@Component
@Configurable
@EnableScheduling
public class Task1 {
  private static Log logger = LogFactory.getLog(Task1.class);
  @Scheduled(cron = "0/2 * * * * * ")
  public void execute() {
    logger.info("Task1>>" + new Date());
  }
}

xml配置方式

application 啟動加入讀取 xml 文件

@SpringBootApplication
@ImportResource(value = { "classpath:applicationContext*.xml" })
public class Springboot2TaskApplication {

  public static void main(String[] args) {
    SpringApplication.run(Springboot2TaskApplication.class, args);
  }
}

@Service
public class Task2 {
  private static Log logger = LogFactory.getLog(Task2.class);
  public void method2() {
    logger.info("Task2----method2>>>>" + new Date());
  }
}

bean創(chuàng)建工廠方式

使用到的 jar 包


  org.springframework
  spring-context-support


  org.springframework
  spring-tx


  org.quartz-scheduler
  quartz
  2.3.0

新建 SchedledConfiguration.java 文件

@Configuration
public class SchedledConfiguration {

  /**
   * attention:
   * Details：配置定時任務
   */
  @Bean(name = "jobDetail")
  public MethodInvokingJobDetailFactoryBean detailFactoryBean(Task3 task) {// TestTask為需要執(zhí)行的任務
    MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
    /*
     * 是否并發(fā)執(zhí)行
     * 例如每5s執(zhí)行一次任務，但是當前任務還沒有執(zhí)行完，就已經過了5s了，
     * 如果此處為true，則下一個任務會執(zhí)行，如果此處為false，則下一個任務會等待上一個任務執(zhí)行完后，再開始執(zhí)行
     */
    jobDetail.setConcurrent(false);

    // 設置任務的名字
    jobDetail.setName("jobDetailName");

    // 設置任務的分組，這些屬性都可以存儲在數據庫中，在多任務的時候使用
    jobDetail.setGroup("jobDetailGroup");

    /*
     * 為需要執(zhí)行的實體類對應的對象
     */
    jobDetail.setTargetObject(task);

    /*
     * 通過這幾個配置，告訴JobDetailFactoryBean我們需要執(zhí)行定時執(zhí)行ScheduleTask類中的task方法
     */
    jobDetail.setTargetMethod("task");
    return jobDetail;
  }

  /**
   * Details：配置定時任務的觸發(fā)器，也就是什么時候觸發(fā)執(zhí)行定時任務
   */
  @Bean(name = "jobTrigger")
  public CronTriggerFactoryBean cronJobTrigger(JobDetail jobDetail) {
    CronTriggerFactoryBean tigger = new CronTriggerFactoryBean();
    tigger.setJobDetail(jobDetail);
    // 初始時的cron表達式，可以改成從數據庫中獲取
    tigger.setCronExpression("0/2 * * * * ?");
    // trigger的name
    tigger.setName("tiggerName");
    return tigger;

  }

  /**
   * Details：定義quartz調度工廠
   */
  @Bean(name = "scheduler")
  public SchedulerFactoryBean schedulerFactory(Trigger trigger) {
    SchedulerFactoryBean bean = new SchedulerFactoryBean();
    // 用于quartz集群,QuartzScheduler 啟動時更新己存在的Job
    bean.setOverwriteExistingJobs(true);
    // 延時啟動，應用啟動1秒后
    bean.setStartupDelay(1);
    // 注冊觸發(fā)器
    bean.setTriggers(trigger);
    return bean;
  }
}

新建Task任務

@Service
public class Task3 {

  @Resource(name = "jobTrigger")
  private CronTrigger cronTrigger;

  @Resource(name = "scheduler")
  private Scheduler scheduler;

  private static Log logger = LogFactory.getLog(Task3.class);

  public void task() {
    logger.info("Task3---------" + new Date());
  }

  /**
   * 設置cron并重啟定時器
   * @param cron cron值
   */
  public void setCron(String cron) {
    try {
      // 表達式調度構建器
      CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cron);
      // 按新的cronExpression表達式重新構建trigger
      CronTrigger trigger = (CronTrigger) scheduler.getTrigger(cronTrigger.getKey());
      trigger = trigger.getTriggerBuilder().withIdentity(cronTrigger.getKey())
          .withSchedule(scheduleBuilder).build();
      // 按新的trigger重新設置job執(zhí)行
      scheduler.rescheduleJob(cronTrigger.getKey(), trigger);
    } catch (SchedulerException e) {
      logger.info("cron表達式錯誤");
    }
  }
}

其中 setCron 方法可以進行重新設定任務調度時間

ThreadPoolTaskScheduler Runnable方式

public class Task4 implements Runnable {

  private ThreadPoolTaskScheduler threadPoolTaskScheduler;

  private static Log logger = LogFactory.getLog(Task4.class);

  @Override
  public void run() {
    logger.info("Task4================" + new Date());
  }

  /**
   * 設置cron并啟動
   * @param cronExp cron值
   */
  public void reStart(String cronExp) {
    if (null != this.threadPoolTaskScheduler) {
      ScheduledExecutorService scheduledExecutorService = this.threadPoolTaskScheduler.getScheduledExecutor();
      if (!scheduledExecutorService.isShutdown()) {
        scheduledExecutorService.shutdownNow();
      }

      this.threadPoolTaskScheduler.destroy();
    }

    if (null != cronExp && cronExp.trim().length() > 0) {
      this.threadPoolTaskScheduler = new ThreadPoolTaskScheduler();
      this.threadPoolTaskScheduler.setThreadNamePrefix("task4");
      this.threadPoolTaskScheduler.initialize();
      this.threadPoolTaskScheduler.schedule(this, new CronTrigger(cronExp));
    }
  }
}

其中reStart可以進行任務啟動和重新設置任務調度時間,調用方式如下所示

/**
   * 初始化task4
   * 這里的代碼不應該寫在rest層上， 應該寫在service層上
   */
  @PostConstruct
  private void initTask4() {
    //初始化task4任務調度器cron，可以從數據庫中查詢到cron值
    setTask4Cron("0/3 * * * * ?");
  }

  /**
   * 改變task4的cron
   * @param cron cron值
   * @return 成功標志
   */
  @RequestMapping(value = { "/setTask4Cron" }, method = RequestMethod.GET)
  @ResponseBody
  public String setTask4Cron(String cron) {
    if (null == task4) {
      task4 = new Task4();
    }

    task4.reStart(cron);
    return "success";
  }

initTask4 方法加了 @PostConstruct '注解,可以在項目啟動時自動根據cron來啟動任務, setTask4Cron 方法可以重新調置任務時間

四個任務的效果如下:

SpringBoot2 task scheduler 定時任務調度器四種方式

以上就是本文的全部內容，希望對大家的學習有所幫助，也希望大家多多支持創(chuàng)新互聯。

網站名稱：SpringBoot2taskscheduler定時任務調度器四種方式
網頁URL：http://www.xueling.net.cn/article/ihsphi.html

老熟女激烈的高潮_日韩一级黄色录像_亚洲1区2区3区视频_精品少妇一区二区三区在线播放_国产欧美日产久久_午夜福利精品导航凹凸

重慶分公司，新征程啟航

SpringBoot2taskscheduler定時任務調度器四種方式

其他資訊