在 Spring Boot 中实现定时任务,通过 Spring Task Scheduling 来完成

Spring Boot 中实现定时任务,可以通过 Spring Task Scheduling 来轻松完成。Spring 提供了多种方法来调度任务,其中使用 @Scheduled 注解是最常见且简单的方式。

步骤:在 Spring Boot 中实现定时任务

1. 启用定时任务

首先,确保在 Spring Boot 应用的主类或配置类中启用定时任务功能:

import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableScheduling  // 启用定时任务
public class Application {
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
}

2. 创建定时任务

使用 @Scheduled 注解来定义定时任务。在类中编写一个方法并使用 @Scheduled 注解,指定任务的执行频率。

2.1 使用固定频率执行

例如,每隔 5 秒执行一次任务:

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

@Component
public class ScheduledTask {

    @Scheduled(fixedRate = 5000)  // 每隔 5 秒执行一次
    public void performTask() {
        System.out.println("执行定时任务: " + System.currentTimeMillis());
    }
}
2.2 使用固定延迟执行

如果希望任务在上一个任务结束后延迟一段时间再执行:

@Scheduled(fixedDelay = 5000)  // 上次执行完后延迟 5 秒
public void performDelayedTask() {
    System.out.println("执行定时任务: " + System.currentTimeMillis());
}
2.3 使用 Cron 表达式

Cron 表达式可以更加灵活地控制任务的执行时间。例如,每天凌晨 1 点执行任务:

@Scheduled(cron = "0 0 1 * * ?")  // 每天凌晨1点执行
public void performCronTask() {
    System.out.println("执行 Cron 定时任务:" + System.currentTimeMillis());
}

3. 配置线程池(可选)

为了避免多个任务同时执行时占用过多的资源,可以配置线程池来管理定时任务。

java复制代码
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;

@Configuration
public class TaskSchedulerConfig {

    @Bean
    public ThreadPoolTaskScheduler taskScheduler() {
        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
        scheduler.setPoolSize(5);  // 设置线程池大小
        scheduler.setThreadNamePrefix("scheduled-task-");
        scheduler.setDaemon(true);  // 守护线程
        return scheduler;
    }
}

4. 配置任务执行日志(可选)

你可以使用 @Scheduled 注解的 zone 属性来指定执行任务时的时区,并利用日志记录任务执行的时间和状态。例如:

@Scheduled(cron = "0 0 1 * * ?", zone = "GMT+8")
public void logTaskExecution() {
    System.out.println("任务执行时间:" + System.currentTimeMillis());
}

5. 常见属性解释

  • fixedRate: 任务执行的间隔时间(单位:毫秒),任务开始时刻计算。
  • fixedDelay: 上一个任务完成后再延迟指定时间执行。
  • cron: 使用 Cron 表达式来指定任务的执行时间。Cron 表达式允许设置具体的执行时间(例如每天、每小时等)。
  • zone: 设置任务的时区,默认为系统时区。

通过以上步骤,你可以轻松在 Spring Boot 中实现定时任务。无论是简单的定时任务,还是复杂的 Cron 表达式调度,Spring Boot 都提供了灵活的方式来满足需求。如果有其他需求,例如异步执行任务或任务失败重试等,可以进一步扩展和配置。

发布者:myrgd,转载请注明出处:https://www.object-c.cn/4581

Like (0)
Previous 2024年11月26日 下午12:09
Next 2024年11月26日 下午12:16

相关推荐

  • 解决 WordPress 后台无法登录的常见问题

    WordPress 后台无法登录是一个常见问题,可能由多种原因引起,包括插件冲突、主题问题、数据库错误或用户账户问题。以下是详细的排查和解决步骤: 1. 检查登录页面 URL 确保您访问的是正确的 WordPress 登录页面: 2. 清除浏览器缓存和Cookie 3. 重置密码 用新密码尝试登录。 4. 禁用插件 某些插件可能会导致登录问题。尝试通过以下方…

    2024年12月9日
    00
  • 实现 Qwen2.5-7B-Instruct 模型在本地部署并结合 vLLM 推理加速和 Gradio 搭建前端界面

    要实现 Qwen2.5-7B-Instruct 模型在本地部署并结合 vLLM 推理加速和 Gradio 搭建前端界面,以下是详细步骤: 1. 环境准备 2. 模型加载与配置 通过 Hugging Face Transformers 加载 Qwen2.5-7B-Instruct 模型: 3. 推理加速 4. 前端界面部署 通过 Gradio 创建简洁的用户界…

    2024年11月26日
    00
  • Solving the Makefile Missing Separator Stop Error in VSCode ……

    在 VSCode 中处理 Makefile 的 missing separator. Stop 错误,通常是因为 Makefile 中的命令行前没有用Tab 键缩进,而使用了空格。Makefile 规定,配方(recipe)中的每个命令行必须以Tab 键开头,而不是空格。 解决方法1. 检查 Makefile 的缩进打开报错的 Makefile 文件。找到出…

    2024年12月2日
    00
  • C++ STL vector 类:动态数组的高效应用

    vector 是 C++ 标准库(STL)中最常用的容器之一,它提供了一个动态数组的实现,能够根据需要自动扩展或收缩。vector 是一个线性数据结构,具有高效的随机访问能力和动态扩展能力,广泛应用于需要频繁增删元素且对随机访问要求较高的场景。 1. vector 类简介 vector 是 C++ 标准模板库(STL)中提供的一种容器类,它类似于动态数组(d…

    2024年11月25日
    00
  • 在使用 VS Code 和 Keil 协同开发 STM32 程序

    在使用 VS Code 和 Keil 协同开发 STM32 程序时,可以利用 Keil 强大的编译器 和 VS Code 的高效代码编辑功能,结合起来提高开发效率。以下是实现协同开发的详细步骤: 前置准备安装 Keil确保已安装 Keil MDK-ARM,并配置好开发环境。Keil 下载地址:Keil 官方网站安装 VS Code下载并安装最新版本的 VS …

    2024年12月1日
    00
  • Docker快速部署Nginx、Redis、MySQL、Tomcat以及制作镜像方法

    使用 Docker 快速部署 Nginx、Redis、MySQL、Tomcat 以及制作镜像 通过 Docker,开发者可以快速部署和管理各种服务。本文介绍如何快速使用 Docker 部署 Nginx、Redis、MySQL 和 Tomcat,以及如何制作自定义镜像。 1. Docker 基础准备 安装 Docker 如果还未安装 Docker,可按照以下步…

    2024年11月26日
    00
  • java算法— 动态规划之斐波那契数列模型

    斐波那契数列是动态规划中一个经典的模型,其递推关系简单易懂,非常适合作为入门练习。斐波那契数列的定义如下: 在 Java 中,可以通过递归、带记忆化的递归、迭代和优化空间复杂度的方式实现斐波那契数列。 1. 递归实现 最直观的实现,但存在大量重复计算,时间复杂度为 O(2n)。 2. 带记忆化的递归 通过一个数组存储已计算的值,避免重复计算,时间复杂度降为 …

    2024年11月21日
    00
  • 高性能 TongRDS 是一种分布式内存数据缓存中间件

    TongRDS 是一种分布式内存数据缓存中间件,旨在为高性能、高并发的应用场景提供快速的数据访问解决方案。类似于 Redis 或 Memcached,TongRDS 的核心功能围绕内存数据存储和分布式特性展开,同时可能具备特定的优化或扩展能力。 以下是 TongRDS 的可能特性和应用场景总结: 1. 核心特性 分布式缓存架构 高性能存储 灵活的数据模型 扩…

    2024年12月3日
    00
  • Python 的 json模块序列化数据从文件里读取出来或存入文件

    Python 的 json 模块用于处理 JSON 格式的数据,可以将 JSON 数据与 Python 数据结构之间相互转换。以下是具体用法,包括从文件读取 JSON 数据以及将数据写入文件: 1. 将 JSON 数据从文件中读取到 Python 数据结构 代码示例: 解析过程: 2. 将 Python 数据结构写入到文件中(序列化为 JSON) 代码示例:…

    2024年11月26日
    00
  • 在 .NET 8 框架中使用 Web API 项目并通过引用 SqlSugar ORM 来操作数据库

    在 .NET 8 框架中使用 Web API 项目并通过引用 SqlSugar ORM 来操作数据库,可以遵循以下步骤: 1. 准备工作确保已安装 .NET 8 SDK 和 SqlSugar NuGet 包。创建或打开现有的 Web Core API 项目。安装 SqlSugar NuGet 包: 2. 配置 SqlSugar在 Web API 项目中配置 …

    2024年11月27日
    00
  • 浏览器跨域请求中携带 Cookie需要同时在前端和后端进行配置

    浏览器跨域请求中,要让请求携带 Cookie,需要同时在前端和后端进行配置。以下是实现的方法: 前端配置 在前端代码中使用 fetch 或 Axios 发起请求时,需要设置 credentials 属性: 1. Fetch 示例 2. Axios 示例 后端配置 在后端需要允许跨域请求,并确保 Cookie 能够正常传递。 1. 设置 Access-Cont…

    2024年12月9日
    00
  • VMware Workstation 17 Pro 中安装 macOS 虚拟机

    在 VMware Workstation 17 Pro 中安装 macOS 虚拟机需要一些额外的步骤,因为 VMware 默认不支持直接安装 macOS 系统。以下是完整的教程,帮助你在 VMware 中成功安装 macOS。 一、准备工作 1. 所需资源 二、安装 VMware 并解锁 macOS 支持 1. 安装 VMware Workstation 2…

    2024年11月23日
    00
  • 在使用 PHP 抓取 HTTPS 资源时,会遇到一些常见问题

    在使用 PHP 抓取 HTTPS 资源时,可能会遇到一些常见问题。这些问题通常与 SSL 配置、证书验证或 PHP 设置相关。以下是常见问题及其解决方法的汇总: 1. SSL 证书验证失败问题描述当使用 file_get_contents、cURL 等方法访问 HTTPS 资源时,可能会遇到类似以下错误: 解决方法更新 cacert.pem 文件下载最新的根…

    2024年12月2日
    00
  • 在使用 Kettle 9.1 连接 MySQL 时,遇到错误提示 Connection failed. Verify all connection parameters and confirm that the appropriate driver is installed.

    在使用 Kettle 9.1 连接 MySQL 时,遇到错误提示 Connection failed. Verify all connection parameters and confirm that the appropriate driver is installed. 通常是由于以下几个原因导致的: 1. MySQL 驱动未正确配置Kettle 需要…

    2024年11月27日
    00
  • 在 Apache Kafka 中消息的消费和传递通过消费者与 Kafka 的分布式系统协作完成

    在 Apache Kafka 中,消息的消费和传递是通过消费者(Consumer)与 Kafka 的分布式系统协作完成的。以下是消息传递的主要流程: 1. Producer 生产消息到 Kafka 2. Consumer 消费消息 Kafka 中消费者的消息消费流程如下: 2.1 订阅主题 消费者通过 Kafka 客户端订阅一个或多个主题。它可以: 2.2 …

    2024年12月9日
    00

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

联系我们

在线咨询: QQ交谈

邮件:723923060@qq.com

关注微信