SpringBoot实现动态定时任务的示例代码
作者:野生java研究僧 发布时间:2022-06-22 19:27:39
标签:SpringBoot,动态,定时,任务
前言
之前在SpringBoot项目中简单使用定时任务,不过由于要借助cron表达式且都提前定义好放在配置文件里,不能在项目运行中动态修改任务执行时间,实在不太灵活。现在我们就来实现可以动态修改cron表达式的定时任务。
配置文件
application-task.yml,其余的配置 application.yml 等就按照springBoot正常配置即可
task:
cron: 0/10 * * * * ?
timer: 10
定时任务核心类
import cn.hutool.core.date.DateUtil;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.SchedulingConfigurer;
import org.springframework.scheduling.config.ScheduledTaskRegistrar;
import org.springframework.scheduling.support.PeriodicTrigger;
import java.util.Date;
@Data
@Slf4j
@Configuration
@EnableScheduling
@ConfigurationProperties(prefix = "task")
public class WorkScheduleTask implements SchedulingConfigurer {
private String cron;
private Long timer;
@Override
public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
// 动态使用cron表达式设置循环间隔
taskRegistrar.addTriggerTask(() -> {
String dateTime = DateUtil.formatDateTime(new Date());
String threadName = Thread.currentThread().getName();
log.info("定时任务开始[configureTasks] :{},线程:{}", dateTime, threadName);
}, triggerContext -> {
// 使用CronTrigger触发器,可动态修改cron表达式来操作循环规则
// 只能定义小于等于间隔59秒
// CronTrigger cronTrigger = new CronTrigger(cron);
// return cronTrigger.nextExecutionTime(triggerContext);
// 能定义大于等于间隔59秒
// 使用不同的触发器,为设置循环时间的关键,区别于CronTrigger触发器,
// 该触发器可随意设置循环间隔时间,单位为毫秒
long seconds = timer * 1000; // 毫秒转秒
PeriodicTrigger periodicTrigger = new PeriodicTrigger(seconds);
return periodicTrigger.nextExecutionTime(triggerContext);
});
}
}
提供修改cron表达式的controller
@Slf4j
@CrossOrigin
@RestController
@RequestMapping("/updateTask")
public class UpdateTaskController {
@Resource
private WorkScheduleTask workScheduleTask;
@PostMapping("/updateCron")
public String updateCron(String cron) {
log.info("new cron :{}", cron);
workScheduleTask.setCron(cron);
return "ok";
}
@PostMapping("/updateTimer")
public String updateTimer(Long timer) {
log.info("new timer :{}", timer);
workScheduleTask.setTimer(timer);
return "ok";
}
}
一开始定时任务的执行时机和周期都是配置文件指定的,但是我们如果对于执行的周期不满意,我们可以调用接口进行修改定时任务,但是需要注意的是,这种外暴露的接最好做一下安全校验,不是谁都可以调用,否则被别人扫描到这个接口,然后随意修改,会影响我们正常的业务流程,严重可能会造成严重损失。
来源:https://blog.csdn.net/m0_46188681/article/details/127495568
0
投稿
猜你喜欢
- Quartz与Spring集成方式:1.MethodInvokeJobDetailFactoryBean2.JobDetailBean下面分
- 概念尽量使用合成/聚合,而不是使用继承实现复用。所谓的合成/聚合是指一个对象里持有另外一个类的对象,通过调用这些对象的方法得到复用已有功能的
- Spring AOP底层原理代理模式一、什么是 AOPAOP 就是面向切面编程,是 OOP(面向对象编程)的延续。利用 AOP 可以对业务逻
- java修改JFrame默认字体修改默认字体的方法很简单。首先我们随便写一个按钮出来:import javax.swing.*; publi
- SpringBoot线程池和Java线程池的用法和实现原理使用默认的线程池方式一:通过@Async注解调用public class Asyn
- @ModelAttribute与@RequestBody的区别最近在写代码的过程中,发现之前项目都是使用的@ModelAttribute注解
- 根据不同系统动态获取换行符和盘分割符1、获取盘分割符File.separator2、获取换行符windows系统为\r\n,Linux系统为
- 本文实例讲述了java实现单词搜索迷宫游戏。分享给大家供大家参考。具体分析如下:我们在杂志上,经常能够看到找单词的小游戏,在一个二维表格中,
- Mybatis的Dao层实现传统开发方式编写UserDao接口public interface UserDao {  
- 这篇文章主要介绍了设计模式在Spring框架中的应用汇总,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的
- 上帝之火本系列讲述的是开源实时监控告警解决方案Prometheus,这个单词很牛逼。每次我都能联想到带来上帝之火的希腊之神,普罗米修斯。而这
- 什么是Spring BootSpring Boot 是由 Pivotal 团队提供的全新框架,其设计目的是用来简化新 Spring 应用的初
- ArrayList集合的创建非泛型创建ArrayList集合对象,可以添加任意Object子类元素至集合//非泛型创建的ArrayList集
- Lambda表达式的进化之路为什么要使用Lambda表达式可以简洁代码,提高代码的可读性可以避免匿名内部类定义过多导致逻辑紊乱在原先实现接口
- 一、项目简述功能: 前后用户的登录注册,婚纱照片分类,查看,摄影师预 订,后台订单管理,图片管理等等。二、项目运行环境配置: Jdk1.8
- 前言工作中使用mybatis时我们需要根据数据表字段创建pojo类、mapper文件以及dao类,并且需要配置它们之间的依赖关系,这样的工作
- mapper文件使用in("str1","str2")mybatis的xxxMapper.xml文件
- 说点对这几个容易混淆的词的理解:1、c++中的virtual方法的 virtual关键字主要是防止继承中重复继承父类的同一个方法而设置的标识
- 前言基本语法首先我们要知道java的基础语法。1.由26个英文字母大小写,0-9,_或$组成2.数字不可以开头3.不可以使用关键字和保留字,
- 本文实例讲述了spring mvc 实现获取后端传递的值。分享给大家供大家参考,具体如下:jsp页面怎么获取从后端传递过来的值?JSTL 方