文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

如何使用spring-task定时任务动态配置修改执行时间

2023-06-25 12:06

关注

小编给大家分享一下如何使用spring-task定时任务动态配置修改执行时间,希望大家阅读完这篇文章之后都有所收获,下面让我们一起去探讨吧!

spring-task定时任务动态配置修改执行时间

因项目需要,几个定时任务需要人为动态设置执行时间,于是乎吧,就查阅相关资料,是可以动态设置的,废话不多说,直接上代码,一目了然。

package com.seckill.quartz;import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;import java.util.Date; @Component@EnableSchedulingpublic class DynamicScheduledTask implements SchedulingConfigurer {    //时间表达式  每2秒执行一次    private String cron = "0/2 * * * * ?";    private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");     @Override    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {        scheduledTaskRegistrar.addTriggerTask(new Runnable() {            @Override            public void run() {                //任务逻辑                System.out.println("---------------start-------------------");                System.out.println("动态修改定时任务参数,时间表达式cron为:" + cron);                System.out.println("当前时间为:" + sdf.format(new Date()));                System.out.println("----------------end--------------------");            }        }, new Trigger() {            @Override            public Date nextExecutionTime(TriggerContext triggerContext) {                CronTrigger cronTrigger = new CronTrigger(cron);                Date nextExecDate = cronTrigger.nextExecutionTime(triggerContext);                return nextExecDate;            }        });    }     public void setCron(String cron) {        this.cron = cron;    }}

这个是定时任务调度执行器,采用的是注解的方式。首先要动态配置,要设置为@EnableScheduling,这是确保能够动态,然后实现SchedulingConfigurer,重写configureTasks方法,接下来就是这个的相关spring配置文件,要引入下面这个task,不然识别不了啊,配置文件就是这么简单

http://www.springframework.org/schema/task

<?xml version="1.0" encoding="UTF-8"?><beans xmlns="http://www.springframework.org/schema/beans"       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"       xmlns:task="http://www.springframework.org/schema/task"       xmlns:context="http://www.springframework.org/schema/context"       xsi:schemaLocation="http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans.xsd        http://www.springframework.org/schema/task        http://www.springframework.org/schema/task/spring-task.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">     <context:component-scan base-package="com.seckill.quartz"/>     <task:annotation-driven /> </beans>

接下来就是写测试类,测试可不可行啊

package com.seckill.quartz;import org.junit.Test;import org.junit.runner.RunWith;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.test.context.ContextConfiguration;import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;import java.io.IOException; @RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration({"classpath*:/conf/spring-quartz.xml"})public class QuartzTest {     @Autowired    private DynamicScheduledTask dynamicScheduledTask;     @Test    public void test1(){        try {            Thread.sleep(10000);        } catch (InterruptedException e) {            e.printStackTrace();        }        dynamicScheduledTask.setCron("0/10 * * * * ?");        try {            System.in.read();        } catch (IOException e) {            e.printStackTrace();        }    }}

运行测试类,查看结果,达到效果,亲测可用

spring schedule 动态配置执行时间

之前saas平台实现动态修改定时任务的时间,都是通过xx-job这样的框架来实现,这样我们可以单独一个服务来管理我们整个saas平台的定时任务,但是最近给银行做的一个小项目,需要本地化部署,所以我不想弄很多的服务,并且他们并没有要求修改以后即时生效,所以我直接采用了 spring schedule结合mysql动态配置执行时间。

之前我们用的schedule通过注解的方式,只能用静态的corn表达式,如果想实现动态的需要实现SchedulingConfigurer,并且通过注解@EnableScheduling。如下:

package com.zqf.marketing.task;  import com.zqf.db.marketingrobot.sys.model.RobotSysSwitch;import com.zqf.marketing.sys.service.SwitchService;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.context.annotation.Lazy;import org.springframework.scheduling.Trigger;import org.springframework.scheduling.TriggerContext;import org.springframework.scheduling.annotation.EnableScheduling;import org.springframework.scheduling.annotation.SchedulingConfigurer;import org.springframework.scheduling.config.ScheduledTaskRegistrar;import org.springframework.scheduling.support.CronTrigger;import org.springframework.stereotype.Service; import java.util.Date;  @Lazy(false)@Service@EnableSchedulingpublic class TestTaskService implements SchedulingConfigurer {     private static Logger log = LoggerFactory.getLogger(TestTaskService.class);    @Autowired    private SwitchService switchService;      private String SpringDynamicCronTask() {        String cron = "0/5 * * * * ?";        //从数据库获得配置的corn表达式        RobotSysSwitch switchById = switchService.getSwitchById(5L);        cron = switchById.getSwitchFlag();        log.info(cron);        return cron;    }      @Override    public void configureTasks(ScheduledTaskRegistrar scheduledTaskRegistrar) {        scheduledTaskRegistrar.addTriggerTask(new Runnable() {            @Override            public void run() {                // 任务逻辑                log.info("task_task_tak");            }        }, new Trigger() {            @Override            public Date nextExecutionTime(TriggerContext triggerContext) {                String s = SpringDynamicCronTask();                // 任务触发,可修改任务的执行周期                CronTrigger trigger = new CronTrigger(s);                Date nextExec = trigger.nextExecutionTime(triggerContext);                return nextExec;            }        });      }}

看完了这篇文章,相信你对“如何使用spring-task定时任务动态配置修改执行时间”有了一定的了解,如果想了解更多相关知识,欢迎关注编程网行业资讯频道,感谢各位的阅读!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯