zoukankan      html  css  js  c++  java
  • Spring Boot 系列教程14-动态修改定时任务cron参数

    动态修改定时任务cron参数

    • 不需要重启应用就可以动态的改变Cron表达式的值
    • 不能使用@Scheduled(cron = “${jobs.cron}”)实现

    DynamicScheduledTask.java

    package com.jege.spring.boot.task;
    
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.scheduling.Trigger;
    import org.springframework.scheduling.TriggerContext;
    import org.springframework.scheduling.annotation.SchedulingConfigurer;
    import org.springframework.scheduling.config.ScheduledTaskRegistrar;
    import org.springframework.scheduling.support.CronTrigger;
    import org.springframework.stereotype.Component;
    
    import com.jege.spring.boot.data.jpa.entity.User;
    import com.jege.spring.boot.data.jpa.repository.UserRepository;
    
    /**
     * @author JE哥
     * @email 1272434821@qq.com
     * @description:动态修改定时任务cron参数
     */
    @Component
    public class DynamicScheduledTask implements SchedulingConfigurer {
      private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");
    
      private static final String DEFAULT_CRON = "0/5 * * * * ?";
      private String cron = DEFAULT_CRON;
    
      @Autowired
      private UserRepository userRepository;
    
      @Override
      public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
        taskRegistrar.addTriggerTask(new Runnable() {
          @Override
          public void run() {
        if (!cron.equals(DEFAULT_CRON)) {
          User user = new User("je_ge", 20);
          userRepository.save(user);
        }
        // 定时任务的业务逻辑
        System.out.println("动态修改定时任务cron参数,当前时间:" + dateFormat.format(new Date()));
          }
        }, new Trigger() {
          @Override
          public Date nextExecutionTime(TriggerContext triggerContext) {
        // 定时任务触发,可修改定时任务的执行周期
        CronTrigger trigger = new CronTrigger(cron);
        Date nextExecDate = trigger.nextExecutionTime(triggerContext);
        return nextExecDate;
          }
        });
      }
    
      public void setCron(String cron) {
        this.cron = cron;
      }
    }
    

    Application.java

    @EnableScheduling

    UserController.java

    @Autowired
    DynamicScheduledTask dynamicScheduledTask;
    
    // 更新动态任务时间
    @RequestMapping("/updateDynamicScheduledTask")
    @ResponseBody
    public AjaxResult updateDynamicScheduledTask() {
      dynamicScheduledTask.setCron("0/10 * * * * ?");
      return new AjaxResult().success();
    }

    user.jsp

    updateDynamicScheduledTask : function() {//动态修改定时任务
        $.get("/user/updateDynamicScheduledTask", function(data) {
            if (data.meta.success) {//动态修改定时任务成功
                $.messager.alert('成功提示', "请重新刷新数据,有插入新的数据", 'info');
            } else {
                $.messager.alert('错误提示', data.meta.message, 'error');
            }
        }, 'json');
    }
    
    <a href="javascript:void(0)" class="easyui-linkbutton c8" iconCls="icon-search" data-url="updateDynamicScheduledTask">动态修改定时任务</a>

    其他关联项目

    源码地址

    https://github.com/je-ge/spring-boot

    如果觉得我的文章对您有帮助,请打赏支持。您的支持将鼓励我继续创作!谢谢!
    微信打赏
    支付宝打赏

  • 相关阅读:
    SpringMVC集成Swagger插件以及Swagger注解的简单使用
    Java后台直接生成二维码介绍
    Java条形码生成技术-Barcode4j
    对Java Serializable(序列化)的理解和总结(一)
    java下划线与驼峰命名互转
    Mybatis实战之TypeHandler高级进阶
    迪卡侬女主(视频) 第一集
    MySQL优化(五)
    PDO连接mysql和pgsql数据库
    MySQL的FIND_IN_SET()函数
  • 原文地址:https://www.cnblogs.com/je-ge/p/6129667.html
Copyright © 2011-2022 走看看