SpringTask定时任务笔记

2024-08-26 01:28

本文主要是介绍SpringTask定时任务笔记,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

1 简介

Spring Task 是 Spring 框架中用于调度和管理定时任务的模块。它提供了简单、灵活且强大的任务调度功能,可以帮助开发者在应用程序中轻松实现任务的自动执行。
Spring Task 常用于以下场景:

  • 定时任务:如定时生成报告、清理临时文件、发送邮件提醒等。
  • 异步任务:可以在应用程序主线程之外执行一些异步任务,不会阻塞主线程。
  • 周期性任务:周期性地执行某些操作,如定期同步数据、监控系统状态等。

优点:

  • 易用性:通过简单的注解即可配置定时任务,无需编写复杂的代码。
  • 灵活性:支持多种任务调度方式,灵活满足不同需求。
  • 集成性:与 Spring 生态系统的其他组件紧密集成,如 Spring Boot、Spring Data 等,易于在现有项目中添加。

2 主要功能

2.1 @Scheduled注解

Spring Task 中最常用的功能,它允许开发者在方法上定义定时任务。通过配置不同的属性,可以实现多种调度方式。

Cron表达式

使用 Cron 表达式来指定任务的执行时间。Cron 表达式由 6 或 7 个字段组成,表示秒、分、小时、日、月、星期、年(可选)。例如:

@Scheduled(cron = "0 0 * * * ?")
public void hourlyTask() {// 每小时执行一次的任务
}

上述表达式表示每小时的整点执行任务。cron表达式其实就是一个字符串,通过cron表达式可以定义任务触发的时间。
**构成规则:**分为6或7个域,由空格分隔开,每个域代表一个含义,分别为:秒、分钟、小时、日、月、周、年(可选)
举例:2022年10月12日上午9点整 对应的cron表达式为:0 0 9 12 10 ? 2022
说明:一般
的值不同时设置,其中一个设置,另一个用 表示。
**比如:**描述2月份的最后一天,最后一天具体是几号呢?可能是28号,也有可能是29号,所以就不能写具体数字。为了描述这些信息,提供一些特殊的字符。这些具体的细节,我们就不用自己去手写,因为这个cron表达式,它其实有在线生成器:https://cron.qqe2.com/。可以直接在这个网站上面,只要根据自己的要求去生成corn表达式即可。

1)corn 表达式常用通配符
  1. * 表示所有值;
  2. ? 表示未说明的值,即不关心它为何值;
  3. - 表示一个指定的范围;
  4. , 表示附加一个可能值;
  5. / 符号前表示开始时间,符号后表示每次递增的值;
2)corn 表达式常用的案例
  1. */5 * * * * ? 每隔5秒执行一次
  2. 0 */1 * * * ? 每隔1分钟执行一次
  3. 0 0 5-15 * * ? 每天5-15点整点触发
  4. 0 0/3 * * * ? 每三分钟触发一次
  5. 0 0-5 14 * * ? 在每天下午2点到下午2:05期间的每1分钟触发
  6. 0 0/5 14 * * ? 在每天下午2点到下午2:55期间的每5分钟触发
  7. 0 0/5 14,18 * * ? 在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
  8. 0 0/30 9-17 * * ? 朝九晚五工作时间内每半小时
  9. 0 0 10,14,16 * * ? 每天上午10点,下午2点,4点

固定频率执行

fixedRate属性用于以固定的速率(单位:ms)执行任务, 任务之间的间隔时间是固定的,而不管任务本身的执行时间。

@Scheduled(fixedRate = 5000)
public void fixedRateTask() {// 每5秒执行一次的任务
}

固定延迟执行

fixedDelay属性表示在上一个任务完成后,经过固定的延迟时间再执行下一个任务。

@Scheduled(fixedDelay = 5000)
public void fixedDelayTask() {// 上一次任务完成后,延迟5秒再执行
}

初始延迟

initialDelay属性可以与fixedRatefixedDelay一起使用,表示任务启动时的初始延迟。

@Scheduled(initialDelay = 10000, fixedRate = 5000)
public void initialDelayTask() {// 在应用启动10秒后开始,每5秒执行一次
}

2.2 TaskScheduler接口

TaskScheduler 接口是 Spring Task 提供的底层调度接口,它允许开发者更灵活地管理任务调度。TaskScheduler 的实现类能够处理多种调度任务,并且可以通过编程的方式进行复杂的调度配置。

常用的实现类

ThreadPoolTaskScheduler:这个实现类可以使用线程池来处理并发任务。它可以同时执行多个任务,并且可以根据需求配置线程池的大小。

@Bean
public TaskScheduler taskScheduler() {ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();scheduler.setPoolSize(10);scheduler.setThreadNamePrefix("scheduled-task-");return scheduler;
}

ConcurrentTaskScheduler:这个实现类可以将任务委派给 java.util.concurrent.ScheduledExecutorService,适用于简单的并发任务调度。

编程方式调度任务

可以使用 TaskScheduler 进行编程式调度。例如,调度一个任务在指定的时间点执行:

@Autowired
private TaskScheduler taskScheduler;public void scheduleTaskWithFixedRate() {taskScheduler.scheduleAtFixedRate(() -> {// 任务执行逻辑}, 5000);
}

2.3 TaskExecutor 接口

TaskExecutor 是 Spring 框架提供的一个通用接口,用于处理异步任务。它与 TaskScheduler 不同,TaskExecutor 侧重于任务的异步执行而非调度。

常用实现类

SimpleAsyncTaskExecutor:这个实现类不使用实际的线程池,每次调用时都会启动一个新的线程。适用于轻量级的任务。
ThreadPoolTaskExecutor:这个实现类基于 Java 的 ThreadPoolExecutor,可以管理一个线程池并处理并发任务。通常用于需要处理大量并发任务的场景。

@Bean
public TaskExecutor taskExecutor() {ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();executor.setCorePoolSize(5);executor.setMaxPoolSize(10);executor.setQueueCapacity(25);executor.setThreadNamePrefix("async-task-");executor.initialize();return executor;
}

异步任务执行

在需要异步执行的任务上添加 @Async 注解,并且配置好 TaskExecutor 即可。例如:

@Async
public void asyncMethod() {// 这是一个异步执行的方法
}

2.4 @EnableScheduling 注解

@EnableScheduling 是一个简单但至关重要的注解,用于启用 Spring 的调度任务功能。只需在 Spring 配置类上添加此注解,即可扫描并自动启用所有使用 @Scheduled 注解的任务。

@Configuration
@EnableScheduling
public class AppConfig {// 其他 Bean 配置
}

通过上述的 @Scheduled 注解、TaskScheduler 接口、TaskExecutor 接口和 @EnableScheduling 注解,Spring Task 提供了一个非常灵活和强大的定时任务调度框架。可以根据具体需求选择合适的工具和配置方式来实现定时任务和异步任务的管理。

3 定时任务简单示例

3.1 效果展示

image.png

3.2 基本步骤

1)创建 SpringBoot 项目

image.png

2)启动类上添加开启定时任务的注解

image.png

3)模拟一个在线时长统计类开始定时任务

使用日志配合控制台输出,查看结果,每隔 5 秒就会输出一条日志。见上图。

@Component
@Slf4j
public class TimeTaskDemo {private static int onlineTime = 0; // 模拟在线时长的累加 静态变量@Scheduled(cron = "0/5 * * * * ?")public void increaseOnlineDay() {onlineTime++;log.info("定时任务开始,累加上线时长————{}", onlineTime);}
}

这篇关于SpringTask定时任务笔记的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1107154

相关文章

Spring Boot 整合 ShedLock 处理定时任务重复执行的问题小结

《SpringBoot整合ShedLock处理定时任务重复执行的问题小结》ShedLock是解决分布式系统中定时任务重复执行问题的Java库,通过在数据库中加锁,确保只有一个节点在指定时间执行... 目录前言什么是 ShedLock?ShedLock 的工作原理:定时任务重复执行China编程的问题使用 Shed

基于Python开发电脑定时关机工具

《基于Python开发电脑定时关机工具》这篇文章主要为大家详细介绍了如何基于Python开发一个电脑定时关机工具,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 简介2. 运行效果3. 相关源码1. 简介这个程序就像一个“忠实的管家”,帮你按时关掉电脑,而且全程不需要你多做

Python Invoke自动化任务库的使用

《PythonInvoke自动化任务库的使用》Invoke是一个强大的Python库,用于编写自动化脚本,本文就来介绍一下PythonInvoke自动化任务库的使用,具有一定的参考价值,感兴趣的可以... 目录什么是 Invoke?如何安装 Invoke?Invoke 基础1. 运行测试2. 构建文档3.

解决Cron定时任务中Pytest脚本无法发送邮件的问题

《解决Cron定时任务中Pytest脚本无法发送邮件的问题》文章探讨解决在Cron定时任务中运行Pytest脚本时邮件发送失败的问题,先优化环境变量,再检查Pytest邮件配置,接着配置文件确保SMT... 目录引言1. 环境变量优化:确保Cron任务可以正确执行解决方案:1.1. 创建一个脚本1.2. 修

Java实现任务管理器性能网络监控数据的方法详解

《Java实现任务管理器性能网络监控数据的方法详解》在现代操作系统中,任务管理器是一个非常重要的工具,用于监控和管理计算机的运行状态,包括CPU使用率、内存占用等,对于开发者和系统管理员来说,了解这些... 目录引言一、背景知识二、准备工作1. Maven依赖2. Gradle依赖三、代码实现四、代码详解五

如何使用celery进行异步处理和定时任务(django)

《如何使用celery进行异步处理和定时任务(django)》文章介绍了Celery的基本概念、安装方法、如何使用Celery进行异步任务处理以及如何设置定时任务,通过Celery,可以在Web应用中... 目录一、celery的作用二、安装celery三、使用celery 异步执行任务四、使用celery

什么是cron? Linux系统下Cron定时任务使用指南

《什么是cron?Linux系统下Cron定时任务使用指南》在日常的Linux系统管理和维护中,定时执行任务是非常常见的需求,你可能需要每天执行备份任务、清理系统日志或运行特定的脚本,而不想每天... 在管理 linux 服务器的过程中,总有一些任务需要我们定期或重复执行。就比如备份任务,通常会选在服务器资

让树莓派智能语音助手实现定时提醒功能

最初的时候是想直接在rasa 的chatbot上实现,因为rasa本身是带有remindschedule模块的。不过经过一番折腾后,忽然发现,chatbot上实现的定时,语音助手不一定会有响应。因为,我目前语音助手的代码设置了长时间无应答会结束对话,这样一来,chatbot定时提醒的触发就不会被语音助手获悉。那怎么让语音助手也具有定时提醒功能呢? 我最后选择的方法是用threading.Time

【学习笔记】 陈强-机器学习-Python-Ch15 人工神经网络(1)sklearn

系列文章目录 监督学习:参数方法 【学习笔记】 陈强-机器学习-Python-Ch4 线性回归 【学习笔记】 陈强-机器学习-Python-Ch5 逻辑回归 【课后题练习】 陈强-机器学习-Python-Ch5 逻辑回归(SAheart.csv) 【学习笔记】 陈强-机器学习-Python-Ch6 多项逻辑回归 【学习笔记 及 课后题练习】 陈强-机器学习-Python-Ch7 判别分析 【学

系统架构师考试学习笔记第三篇——架构设计高级知识(20)通信系统架构设计理论与实践

本章知识考点:         第20课时主要学习通信系统架构设计的理论和工作中的实践。根据新版考试大纲,本课时知识点会涉及案例分析题(25分),而在历年考试中,案例题对该部分内容的考查并不多,虽在综合知识选择题目中经常考查,但分值也不高。本课时内容侧重于对知识点的记忆和理解,按照以往的出题规律,通信系统架构设计基础知识点多来源于教材内的基础网络设备、网络架构和教材外最新时事热点技术。本课时知识