SpringBoot2 task scheduler 定时任务调度器四种方式

 更新时间:2019年03月18日 08:32:09   作者:cnJun  
这篇文章主要介绍了SpringBoot2 task scheduler 定时任务调度器四种方式,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

使用@EnableScheduling方式

@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);
  }
}

<context:component-scan base-package="com.chenyingjun.task.schedual"></context:component-scan>
<task:scheduler id="appScheduler" pool-size="2" /> 
<!-- 调整定时任务 -->
<task:scheduled-tasks>  
  <task:scheduled ref="task2" method="method2" cron="0/10 * * * * ?"/>
</task:scheduled-tasks>
@Service
public class Task2 {
  private static Log logger = LogFactory.getLog(Task2.class);
  public void method2() {
    logger.info("Task2----method2>>>>" + new Date());
  }
}

bean创建工厂方式

使用到的 jar 包

<dependency>
  <groupId>org.springframework</groupId>
  <artifactId>spring-context-support</artifactId>
</dependency>
<dependency>
  <groupId>org.springframework</groupId>
  <artifactId>spring-tx</artifactId>
</dependency>
<dependency>
  <groupId>org.quartz-scheduler</groupId>
  <artifactId>quartz</artifactId>
  <version>2.3.0</version>
</dependency>

新建 SchedledConfiguration.java 文件

@Configuration
public class SchedledConfiguration {

  /**
   * attention:
   * Details:配置定时任务
   */
  @Bean(name = "jobDetail")
  public MethodInvokingJobDetailFactoryBean detailFactoryBean(Task3 task) {// TestTask为需要执行的任务
    MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
    /*
     * 是否并发执行
     * 例如每5s执行一次任务,但是当前任务还没有执行完,就已经过了5s了,
     * 如果此处为true,则下一个任务会执行,如果此处为false,则下一个任务会等待上一个任务执行完后,再开始执行
     */
    jobDetail.setConcurrent(false);

    // 设置任务的名字
    jobDetail.setName("jobDetailName");

    // 设置任务的分组,这些属性都可以存储在数据库中,在多任务的时候使用
    jobDetail.setGroup("jobDetailGroup");

    /*
     * 为需要执行的实体类对应的对象
     */
    jobDetail.setTargetObject(task);

    /*
     * 通过这几个配置,告诉JobDetailFactoryBean我们需要执行定时执行ScheduleTask类中的task方法
     */
    jobDetail.setTargetMethod("task");
    return jobDetail;
  }

  /**
   * Details:配置定时任务的触发器,也就是什么时候触发执行定时任务
   */
  @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);
    // 注册触发器
    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执行
      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 方法可以重新调置任务时间

四个任务的效果如下:

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

相关文章

  • Spring Cloud之服务监控turbine的示例

    Spring Cloud之服务监控turbine的示例

    这篇文章主要介绍了Spring Cloud之服务监控turbine的示例,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2018-05-05
  • Springboot MultipartFile文件上传与下载的实现示例

    Springboot MultipartFile文件上传与下载的实现示例

    在Spring Boot项目中,可以使用MultipartFile类来处理文件上传和下载操作,本文就详细介绍了如何使用,具有一定的参考价值,感兴趣的可以了解一下
    2023-08-08
  • 详解Eclipse Validating缓慢的优化

    详解Eclipse Validating缓慢的优化

    这篇文章主要介绍了详解Eclipse Validating缓慢的优化,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-03-03
  • RabbitMQ消息单独与批量的TTL详细介绍

    RabbitMQ消息单独与批量的TTL详细介绍

    这篇文章主要介绍了RabbitMQ消息单独与批量的TTL,TTL全名是Time To Live存活时间,表示当消息由生产端存入MQ当中的存活时间,当时间到达的时候还未被消息就会被自动清除,感兴趣的同学可以参考下文
    2023-05-05
  • java swing编程入门代码编写(java编程入门)

    java swing编程入门代码编写(java编程入门)

    Swing是一个为Java设计的GUI工具包,是用来做UI界面的,大家看了下面的介绍就要吧自己做java界面了
    2013-12-12
  • JavaWeb学习过程之MVC查询模式详解

    JavaWeb学习过程之MVC查询模式详解

    这篇文章主要介绍了JavaWeb学习过程之MVC查询模式详解的相关资料,非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2016-09-09
  • maven依赖传递和依赖冲突原理

    maven依赖传递和依赖冲突原理

    这篇文章主要介绍了maven依赖传递和依赖冲突原理详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2023-05-05
  • 阿里资深技术专家:在各阶段中3年经验的java程序员应该具备哪些技术能力

    阿里资深技术专家:在各阶段中3年经验的java程序员应该具备哪些技术能力

    这篇文章主要介绍了阿里资深技术专家:在各阶段中3年经验的java程序员应该具备哪些技术能力,本文给大家列举了一些内容,大家可以根据自己需要有方法的掌握,感兴趣的朋友跟随小编一起看看吧
    2020-07-07
  • Java钩子方法概念原理详解

    Java钩子方法概念原理详解

    这篇文章主要介绍了Java钩子方法概念原理详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-02-02
  • java、spring、springboot中整合Redis的详细讲解

    java、spring、springboot中整合Redis的详细讲解

    这篇文章主要介绍了java、spring、springboot中整合Redis的详细讲解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2021-04-04

最新评论