Spring Boot 创建定时任务

在现代应用程序开发中,定时任务是一个常见的需求。Spring Boot作为一个强大的框架,提供了简单易用的定时任务调度功能。本文将详细介绍如何在Spring Boot中创建和管理定时任务,并提供完整的代码示例。

1. 什么是定时任务

定时任务是指在预定的时间间隔或特定的时间点自动执行的任务。它们常用于执行周期性的数据备份、发送通知、数据清理等操作。

常见的定时任务使用场景

  • 数据备份

  • 日志清理

  • 发送定时通知

  • 定时数据同步

  • 定期生成报表

2. Spring Boot中定时任务的基础知识

Spring Boot通过Spring Framework提供的@Scheduled注解,简化了定时任务的创建和管理。@Scheduled注解可以应用于任何无参方法,并支持多种类型的时间表达式。

@Scheduled注解的常用属性

  • fixedRate: 以固定的时间间隔执行任务,单位为毫秒。

  • fixedDelay: 在任务完成后的固定时间间隔执行下一次任务,单位为毫秒。

  • cron: 使用Cron表达式指定任务的执行时间。

3. 使用Spring Boot创建简单的定时任务

在Spring Boot中创建定时任务非常简单,只需以下几个步骤:

  1. 添加Spring Boot Starter依赖。

  2. 启用定时任务支持。

  3. 编写定时任务方法并使用@Scheduled注解。

1. 添加Spring Boot Starter依赖

在pom.xml文件中添加spring-boot-starter依赖:

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId>
</dependency>

2. 启用定时任务支持

在主应用程序类上添加@EnableScheduling注解,以启用定时任务的支持:

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.scheduling.annotation.EnableScheduling;@SpringBootApplication
@EnableScheduling
public class ScheduledTasksApplication {public static void main(String[] args) {SpringApplication.run(ScheduledTasksApplication.class, args);}
}

3. 编写定时任务方法并使用@Scheduled注解

创建一个新的服务类,在其中编写定时任务方法,并使用@Scheduled注解指定任务的执行时间:

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class ScheduledTasks {@Scheduled(fixedRate = 5000)public void reportCurrentTime() {System.out.println("Current Time: " + System.currentTimeMillis());}
}

 上面的代码示例中,reportCurrentTime方法每隔5秒执行一次。

4. 定时任务示例代码

下面是一个更完整的定时任务代码示例,包括不同类型的定时任务:

示例1:使用固定间隔执行任务

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class FixedRateTask {@Scheduled(fixedRate = 10000)public void performTask() {System.out.println("Fixed rate task executed at " + System.currentTimeMillis());}
}

示例2:使用固定延迟执行任务

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class FixedDelayTask {@Scheduled(fixedDelay = 15000)public void performDelayedTask() {System.out.println("Fixed delay task executed at " + System.currentTimeMillis());}
}

示例3:使用Cron表达式执行任务

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;@Component
public class CronTask {@Scheduled(cron = "0 0/2 * * * ?")public void performCronTask() {System.out.println("Cron task executed at " + System.currentTimeMillis());}
}

上述代码示例中,performCronTask方法每两分钟执行一次。

5. 高级定时任务管理

在实际应用中,我们可能需要更复杂的定时任务管理功能,例如动态修改任务的执行时间、任务状态监控等。为此,我们可以借助Spring的TaskScheduler接口和ScheduledFuture对象。

动态修改任务执行时间

以下是一个示例,演示如何动态修改定时任务的执行时间:


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;
import java.util.concurrent.ScheduledFuture;@Component
public class DynamicScheduledTask {@Autowiredprivate TaskScheduler taskScheduler;private ScheduledFuture<?> scheduledFuture;@PostConstructpublic void scheduleTask() {scheduledFuture = taskScheduler.scheduleAtFixedRate(this::performTask, 5000);}public void changeTaskInterval(long interval) {if (scheduledFuture != null) {scheduledFuture.cancel(false);}scheduledFuture = taskScheduler.scheduleAtFixedRate(this::performTask, interval);}private void performTask() {System.out.println("Dynamic scheduled task executed at " + System.currentTimeMillis());}
}

任务状态监控

我们可以通过ScheduledFuture对象来监控任务的状态,例如取消任务、检查任务是否完成等。


import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.TaskScheduler;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
import org.springframework.stereotype.Component;import javax.annotation.PostConstruct;
import java.util.concurrent.ScheduledFuture;@Component
public class MonitoredScheduledTask {@Autowiredprivate TaskScheduler taskScheduler;private ScheduledFuture<?> scheduledFuture;@PostConstructpublic void scheduleTask() {scheduledFuture = taskScheduler.scheduleAtFixedRate(this::performTask, 10000);}public void cancelTask() {if (scheduledFuture != null) {scheduledFuture.cancel(false);}}private void performTask() {System.out.println("Monitored scheduled task executed at " + System.currentTimeMillis());}
}

6. 总结

通过本文的介绍和示例代码,我们了解了如何在Spring Boot中创建和管理定时任务。Spring Boot的@Scheduled注解和TaskScheduler接口为定时任务提供了强大的支持,使得开发者能够轻松实现各种定时任务的需求。无论是简单的固定间隔任务,还是复杂的Cron表达式任务,Spring Boot都能提供简洁优雅的解决方案。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/40944.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

排序查询------- ORDER BY(一)

一.关键字 ORDER BY 二.语法 SELECT 字段列表 FROM 表名 ORDER BY 字段1 排列方式1 ,字段2 排列方式2; 三.排序方式 ASC&#xff1a;升序(默认值) DESC&#xff1a;降序 注意:如果是多字段排序,当第一个字段值相同时,才会根据第二个字段进行排序。 四.根据年龄对公司的员…

RabbitMQ 详解:概念、结构、使用场景与常用命令

引言 在分布式系统和微服务架构中&#xff0c;消息队列是一种重要的中间件&#xff0c;用于实现异步通信、解耦和负载均衡。RabbitMQ作为一种开源的消息队列中间件&#xff0c;以其可靠性、高可用性和灵活性&#xff0c;广泛应用于各类系统中。本文将深入探讨RabbitMQ的定义、架…

【BUUCTF-PWN】6-jarvisoj_level0

64位&#xff0c;开启了NX保护 运行效果如下&#xff1a; main函数&#xff1a; vulnerable_function()函数 buf变量长度为128&#xff0c;但是read可以读入0x200长度的字符&#xff0c;存在栈溢出&#xff0c;需要覆盖的长度为0x808 寻找后门函数 这里可以直接用栈…

计算机的错误计算(二十一)

摘要 两个不相等数相减&#xff0c;差为0&#xff1a; ? 在计算机的错误计算&#xff08;十九&#xff09;中&#xff0c;高中生小明发现本应为0的算式结果不为0. 今天他又发现对本不为0的算式&#xff0c;计算机的输出为0. 在 Python 中计算 &#xff1a; 则输出为0. 若用 C…

Android-卷积神经网络(Convolutional Neural Network, CNN)

一个复杂且在Android开发中常见的算法是图像处理中的卷积神经网络(Convolutional Neural Network, CNN)。CNN被广泛用于图像识别、物体检测和图像分割等任务,其复杂性在于需要处理大量的图像数据、复杂的神经网络结构和高效的计算。 1. 卷积操作(Convolution) 数学原理:…

R 绘图 - 饼图

R 绘图 - 饼图 饼图是一种常用的数据可视化工具&#xff0c;用于展示数据集中各个类别的相对比例。在R语言中&#xff0c;饼图可以通过多种方式绘制&#xff0c;其中最常用的是pie()函数。本文将详细介绍如何在R中创建和定制饼图&#xff0c;包括基本饼图的绘制、添加标签、调…

CSS学习(三大特性 盒子模型)

目录 Emmet语法 1.快速生成HTML结构语法 2.快速生成CSS样式语法 CSS的复合选择器 后代选择器 子选择器 并集选择器 伪类选择器 链接伪类选择器 focus伪类选择器 CSS的三大特性 层叠性 继承性 优先级 CSS盒子模型 组成 边框 边框 内边距 外边距 块级盒子水…

sharepoint api 没有这个文件所属site的权限的情况下访问指定文件

通过 SharePoint API 访问特定文件时&#xff0c;通常需要具备访问该文件所属网站 (site) 的权限。然而&#xff0c;有一些方法可以绕过这个限制&#xff0c;主要包括使用具有较高权限的应用程序权限或共享链接。这些方法的具体实现步骤如下&#xff1a; 1. 使用应用程序权限 …

7_1_SVPWM概述

1、SPWM 正弦脉宽调制法&#xff08;SPWM&#xff09;是将每一正弦周期内的多个脉冲作自然或规则的宽度调制&#xff0c;使其依次调制出相当于正弦函数值的相位角和面积等效于正弦波的脉冲序列&#xff0c;形成等幅不等宽的正弦化电流输出。 通过调整占空比使等效电流近似为正弦…

classin视频下载提取为mp4教程

最近在上classin网课&#xff0c;无奈网课视频要过期了&#xff0c;所以想保存下来&#xff01; 下面介绍提取的教程 我们可以绕过最开始的握手&#xff0c;就是先播放了一段时间后&#xff0c;再打开抓包&#xff0c;回到Classin播放后&#xff0c;就可以获得网课链接了 直接打…

软考-系统架构设计师[九年]上岸感想

2016年就开始参系统架构设计师的考试了&#xff0c;经历七次考试终于成功上岸&#xff0c;分享下自己这么多次考试失败的经验&#xff0c;希望大家可以少踩坑&#xff0c;一次通过考试 重点 如果你不想继续读下去&#xff0c;看完这段就行。 1.一定要知道最新的考试范围&…

Java通过GeoLite2-City.mmdb 进行IP信息查询地理定位和经纬度筛选。

引入依赖 <dependency><groupId>com.maxmind.geoip2</groupId><artifactId>geoip2</artifactId><version>4.2.0</version> </dependency>下载数据文件&#xff1a;https://download.lin2ur.cn/GeoLite2/ package com.cqclo…

【spring MVC的执行流程】

SpringMVC可以说是Servlet的封装&#xff0c;屏蔽了Servlet的很多细节&#xff0c;比如Servlet再获取参数的时候需要不停地getParameter,现在只要在SpringMVC方法定义对应的JavaBean&#xff0c;只要属性和参数名一致&#xff0c;SpringMVC就可以帮我们实现将参数封装到JavaBea…

【Linux】目录和文件的权限意义

现在我们知道了Linux系统内文件的三种身份&#xff08;拥有者、用户组与其他人&#xff09;&#xff0c;知道每种身份都有三种权限&#xff08;rwx&#xff09;&#xff0c;也知道能够使用chown、chgrp、chmod修改这些权限与属性&#xff0c;当然&#xff0c;利用IS-l去查看文件…

wordpress企业网站模板免费下载

大气上档次的wordpress企业模板&#xff0c;可以直接免费下载&#xff0c;连注册都不需要&#xff0c;网盘就可以直接下载&#xff0c;是不是嘎嘎给力呢 演示 https://www.jianzhanpress.com/?p5857 下载 链接: https://pan.baidu.com/s/1et7uMYd6--NJEWx-srMG1Q 提取码:…

【独家揭秘】三星HBM3e内存通过英伟达认证?官方辟谣背后真相何在?

7月初&#xff0c;业界一则震撼消息传来&#xff0c;据韩媒Newdaily报道&#xff0c;三星电子第五代高速存储器HBM3e已成功获得GPU巨头英伟达的质量认证&#xff0c;预示着三星即将步入HBM大规模量产的新阶段。报道援引半导体行业内部消息&#xff0c;称三星近期收到来自英伟达…

Air系列4G模块AT版本如何使用HTTP

HTTP应用的基本流程如下&#xff1a; 1、激活PDP 2、初始化HTTP服务 3、设置HTTP会话参数 4、如果要支持SSL&#xff0c;配置SSL参数 5、如果使用POST命令&#xff0c;输入POST数据 6、发起HTTP请求 7、收到HTTP应答&#xff0c;读取应答数据 8、终止HTTP服务 注意&#xff1a;…

web学习笔记(七十六)

目录 1.wxss和css的区别 2.wxss通过less来编写代码 3.小程序实现下拉刷新的操作 4.定义变量的技巧 5.小程序实现触底加载的操作 1.wxss和css的区别 在wxss中为了做适配我们引入了一个新的计量单位rpx,和vue的适配差不多&#xff0c;将整个屏幕分为750份&#xff0c;1r…

Matplotlib 线条的属性

属性名 描述 agg_filter 一个过滤器函数&#xff0c;它接受一个 (m, n, 3) 浮点数组和一个 dpi 值&#xff0c;并返回一个 (m, n, 3) 数组和距图像左下角的两个偏移量 alpha 标量或无 animated 布尔 antialiased或aa 布尔 clip_box Bbox clip_on 布尔 clip_path …

【Python】数据分析与可视化——文本数据分析

文本数据分析是指对文本数据进行收集、清理、加工和分析的过程&#xff0c;旨在从大量的文本信息中抽取有用的信息和知识 1. 数据收集 使用如Python中的BeautifulSoup库进行网络爬虫&#xff0c;寻找并下载网页上的文本内容 2. 数据清洗 在收集到文本数据后&#xff0c;通常…