动态改变Spring定时任务执行频率

简介: 动态改变Spring定时任务执行频率http://www.bieryun.com/1661.html 一.引入 由于公司门户系统需要定时推送数据进国家平台,所以首先想到的是利用spring的定时任务进行定时推送,当然对于这种需求比较简单,如下操作即可: 1.

动态改变Spring定时任务执行频率

一.引入

由于公司门户系统需要定时推送数据进国家平台,所以首先想到的是利用spring的定时任务进行定时推送,当然对于这种需求比较简单,如下操作即可:

1.打开任务调度使用,在applicationContext.xml中添加  <task:annotation-driven />,即配置打开了任务调度

当然注意了:头文件上需要加上

[html] view plain copy

  1. <beans xmlns="http://www.springframework.org/schema/beans"
  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.     xmlns:task="http://www.springframework.org/schema/task"
  4.     xmlns:context="http://www.springframework.org/schema/context"
  5.     xsi:schemaLocation="
  6.         http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  7.         http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task.xsd
  8.         http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd ">

 

2.自定义一个 任务调度的类,这里我写为了:MyScheduler.java ,为了让spring能够管理到,加上了Component注解,然后方法上加上Scheduled注解,进行配置调度的频率(1000*60)-代表1分钟调用一次

[java] view plain copy

  1.   @Component("scheduledTaskManager")
  2.   public class MyScheduler {
  3.    @Scheduled(fixedRate = 1000*60)
  4.    public void heartbeat() {
  5. //任务逻辑
  6.      }
  7.  }

 

这样配置就结束了,很简单明了。

二.动态修改调度频率

通过上述的配置,已经实现了简单的定时任务调度,但是这中写法不适宜动态修改,至少我还没有按照上述的写法动态修改频率成功过,于是,这里写一下另外一种写法:

定义一个任务类:updateCronTask.java,这个类实现SchedulingConfigurer接口的configureTasks方法

[java] view plain copy

  1.     @Component
  2.     @EnableScheduling
  3.     public class updateCronTask implements SchedulingConfigurer {
  4.         public static String cron = "0/2 * * * * ?";
  5.         int i=0;
  6.         @Override
  7.         public void configureTasks(ScheduledTaskRegistrar taskRegistrar) {
  8.             taskRegistrar.addTriggerTask(new Runnable() {
  9.             @Override
  10.             public void run(){
  11.             i++;
  12.                 // 任务逻辑  
  13.             System.out.println("第"+(i)+"次开始执行操作... " +"时间:【" + new SimpleDateFormat("yyyy-MM-dd hh:mm:ss.SSS").format(new Date()) + "】");
  14.             }
  15.         }, new Trigger(){
  16.             @Override
  17.             public Date nextExecutionTime(TriggerContext triggerContext) {
  18.                 //任务触发,可修改任务的执行周期 
  19.                 CronTrigger trigger = new CronTrigger(cron);
  20.                 Date nextExec = trigger.nextExecutionTime(triggerContext);
  21.                 return nextExec;
  22.             }
  23.         });
  24.     }
  25. }

 

项目启动后,只要触发改变cron的参数即可实现动态 修改任务调度频率,如:测试在controller层中,当访问了 某个url后,触发改变了cron 的参数,达到了预期的效果。

开始默认的频率是2s /次,后来通过controller层进行修改成了10s /次,

如果你有更好的方法,记得分享出来。

相关文章
|
3月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
定时任务在企业应用中至关重要,常用于异步数据处理、自动化运维等场景。在单体应用中,利用Java的`java.util.Timer`或Spring的`@Scheduled`即可轻松实现。然而,进入微服务架构后,任务可能因多节点并发执行而重复。Spring Cloud Alibaba为此发布了Scheduling模块,提供轻量级、高可用的分布式定时任务解决方案,支持防重复执行、分片运行等功能,并可通过`spring-cloud-starter-alibaba-schedulerx`快速集成。用户可选择基于阿里云SchedulerX托管服务或采用本地开源方案(如ShedLock)
106 1
|
6月前
|
安全 数据安全/隐私保护
Springboot+Spring security +jwt认证+动态授权
Springboot+Spring security +jwt认证+动态授权
202 0
|
16天前
|
Java BI 调度
Java Spring的定时任务的配置和使用
遵循上述步骤,你就可以在Spring应用中轻松地配置和使用定时任务,满足各种定时处理需求。
101 1
|
25天前
|
存储 Java API
简单两步,Spring Boot 写死的定时任务也能动态设置:技术干货分享
【10月更文挑战第4天】在Spring Boot开发中,定时任务通常通过@Scheduled注解来实现,这种方式简单直接,但存在一个显著的限制:任务的执行时间或频率在编译时就已经确定,无法在运行时动态调整。然而,在实际工作中,我们往往需要根据业务需求或外部条件的变化来动态调整定时任务的执行计划。本文将分享一个简单两步的解决方案,让你的Spring Boot应用中的定时任务也能动态设置,从而满足更灵活的业务需求。
59 4
|
4月前
|
资源调度 Java 调度
Spring Cloud Alibaba 集成分布式定时任务调度功能
Spring Cloud Alibaba 发布了 Scheduling 任务调度模块 [#3732]提供了一套开源、轻量级、高可用的定时任务解决方案,帮助您快速开发微服务体系下的分布式定时任务。
14848 28
|
3月前
|
Java 开发者 Spring
Spring Boot实战宝典:揭秘定时任务的幕后英雄,让业务处理如流水般顺畅,轻松驾驭时间管理艺术!
【8月更文挑战第29天】在现代应用开发中,定时任务如数据备份、报告生成等至关重要。Spring Boot作为流行的Java框架,凭借其强大的集成能力和简洁的配置方式,为开发者提供了高效的定时任务解决方案。本文详细介绍了如何在Spring Boot项目中启用定时任务支持、编写定时任务方法,并通过实战案例展示了其在业务场景中的应用,同时提供了注意事项以确保任务的正确执行。
46 0
|
3月前
|
Dubbo Java 调度
揭秘!Spring Cloud Alibaba的超级力量——如何轻松驾驭分布式定时任务调度?
【8月更文挑战第20天】在现代微服务架构中,Spring Cloud Alibaba通过集成分布式定时任务调度功能解决了一致性和可靠性挑战。它利用TimerX实现任务的分布式编排与调度,并通过`@SchedulerLock`确保任务不被重复执行。示例代码展示了如何配置定时任务及其分布式锁,以实现每5秒仅由一个节点执行任务,适合构建高可用的微服务系统。
63 0
|
4月前
|
SQL Java 调度
实时计算 Flink版产品使用问题之使用Spring Boot启动Flink处理任务时,使用Spring Boot的@Scheduled注解进行定时任务调度,出现内存占用过高,该怎么办
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
4月前
|
开发框架 自然语言处理 Java
如何在Spring Boot中实现动态多语言支持
如何在Spring Boot中实现动态多语言支持
|
4月前
|
XML Java Linux
Spring Task 定时任务没有定时执行是为什么?
Spring Task 定时任务没有定时执行是为什么?
63 2