Nacos实现动态加载定时任务时间

 更新时间:2026年06月12日 09:31:14   作者:重逢是最好的邂逅  
这段文章介绍了如何在SpringBoot项目中动态配置cron表达式,融合了`@Scheduled`注解、`SchedulingConfigurer`接口和Lambda表达式三个关键词,详细解释了实现动态定时任务的方法,适合有经验的技术人员参考

前言

需要实现一个动态改变cron表达式的定时器任务。

我们知道Spring Boot要使用定时任务,就要在启动类上加上@EnableScheduling注解,并且在某个方法上加上@Scheduled(cron = “0 0 1 * * ?”)

这种普通的方式,注解中的cron是没办法改变的,不能自定义动态的。即使当你强行去定义一个cron变量时,也会提醒你需要用final static修饰。

但Spring提供了一个接口:SchedulingConfigurer,实现接口重写方法就可以动态配置cron。

配置类

package com.xxx.xxx.config;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.context.annotation.Configuration;
@Configuration
@RefreshScope
@ConfigurationProperties(prefix = "xxx",ignoreInvalidFields = true)
public class Config {
    private Mm mm;
    public static class Mm{
        String cron;
        public String getCron() {
            return cron;
        }
        public void setCron(String cron) {
            this.cron = cron;
        }
}
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;
//定时任务类
@Component
public class DynamicCronSchedule implements SchedulingConfigurer {
     public void A() {
       // 逻辑方法
    }
    //cron从nacos中获取
    @Autowired
    private Config config;
    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        scheduledTaskRegistrar.addTriggerTask(new Runnable() {
            @Override
            public void run() {
                // 定时器要做的功能,比如统计等等
                A();
            }
        }, new Trigger() {
            @Override
            public Date nextExecutionTime(TriggerContext triggerContext) {
                // 我这里放在了配置文件里,模拟动态配置,也可以放在数据库中,动态修改
                return new CronTrigger(config.getCron()).nextExecutionTime(triggerContext);
            }
        });
    }
}

configureTasks方法

在java 8下可用Lamda表达式简化成

    @Override
    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {
        scheduledTaskRegistrar.addTriggerTask(() -> {
            A();
        }, triggerContext -> new CronTrigger(config.getCron()).nextExecutionTime(triggerContext));
    }

在Springboot项目初始化时会执行A方法,并将B方法得到的cron表达式作为执行的时间点。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Java实战之基于swing的QQ邮件收发功能实现

    Java实战之基于swing的QQ邮件收发功能实现

    这篇文章主要介绍了Java实战之基于swing的QQ邮件收发功能实现,文中有非常详细的代码示例,对正在学习java的小伙伴们有非常好的帮助,需要的朋友可以参考下
    2021-04-04
  • SpringBoot框架底层原理解析

    SpringBoot框架底层原理解析

    这篇文章主要介绍了SpringBoot底层原理,包括配置优先级的配置方式给大家讲解的非常详细,需要的朋友可以参考下
    2024-03-03
  • Springboot中RedisTemplate设置String、Hash、List过期时间

    Springboot中RedisTemplate设置String、Hash、List过期时间

    本文主要介绍了Springboot中RedisTemplate设置String、Hash、List过期时间,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2024-05-05
  • SpringFactoriesLoader类作用详解

    SpringFactoriesLoader类作用详解

    SpringFactoriesLoader可以加载jar包下META-INF下的spring.factories,把相关接口的实现按照key,value的形式加载到内存,一个接口的多个实现可以按照","进行分割
    2022-10-10
  • Java实现读取超过内存大小的文件

    Java实现读取超过内存大小的文件

    在一些场景下,我们需要处理的文件可能比我们机器所拥有的内存要大,如果遇到这种情况该如何解决呢,本文就来和大家讲讲如何使用Java实现读取超过内存大小的文件吧
    2024-03-03
  • Java代码里如何拼接SQL语句到mybatis的xml

    Java代码里如何拼接SQL语句到mybatis的xml

    这篇文章主要介绍了Java代码里拼接SQL语句到mybatis的xml操作,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-06-06
  • Java实现二叉搜索树的插入、删除功能

    Java实现二叉搜索树的插入、删除功能

    这篇文章主要介绍了Java实现二叉搜索树的插入、删除,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2022-01-01
  • Spring bean配置单例或多例模式方式

    Spring bean配置单例或多例模式方式

    这篇文章主要介绍了Spring bean配置单例或多例模式方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-01-01
  • Spring Security 基于URL的权限判断源码解析

    Spring Security 基于URL的权限判断源码解析

    这篇文章主要介绍了Spring Security 基于URL的权限判断问题,我们想要实现自己的基于请求Url的授权只需自定义一个 AccessDecisionManager即可,接下来跟随小编一起看看实现代码吧
    2021-12-12
  • Java中的clone()和Cloneable接口实例

    Java中的clone()和Cloneable接口实例

    这篇文章主要介绍了Java中的clone()和Cloneable接口实例,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2021-11-11

最新评论