@Scheduled注解 定时任务讲解

news/2024/3/4 10:41:17

用于在Java Spring框架中定时执行特定任务的注解 @Scheduled,它能够指定方法在特定时间间隔或特定时间点执行。默认参数是cron,cron参数被用来定义一个Cron表达式,它代表了任务执行的时间规则在这里插入图片描述
参数如下
在这里插入图片描述

Cron

这是是一种时间表达式,用于表示定时任务的执行规则。在Spring中,@Scheduled注解的cron参数就是用来设置Cron表达式的。Cron表达式的基本格式为:

secdond minute hour dayOfMonth month dayOfWeek year

每个字段的含义如下:

  1. second:秒(0-59)
  2. minute:分钟(0-59)
  3. hour:小时(0-23)
  4. dayOfMonth:月份中的某一天(1-31)
  5. month:月份(1-12或者 JAN-DEC)
  6. dayOfWeek:星期中的某一天(1-7或者 SUN-SAT)
  7. year:年份(留空表示任何年份)

使用*表示匹配任意值,例如,在month字段中表示每个月,而在dayOfWeek字段中表示每一天。除了之外,你还可以使用一些其他符号,比如:

8.-:表示一个范围,比如 1-5 表示1到5。
9.,:表示一个列表,比如 1,3,5 表示1、3和5。
10./:表示间隔,比如 0/15 表示每隔15分钟。

例如,要设置每天上午10点执行任务,Cron表达式可以是 0 0 10 * * ?。 0 0/1 * * * ?,表示每隔一分钟执行一次任务。

示例:

@Scheduled(cron = “0 15 10 * * ?”) // 每天上午10:15执行

fixedRate

这个参数定义了方法调用之间的固定周期,单位为毫秒。不论前一次方法执行花费了多长时间,都会按照这个间隔执行。如果上一个任务堵塞不排除脏数据的风险
示例:

   @Scheduled(fixedRate = 1000) // 每1000毫秒执行一次

fixedDelay

这个参数定义了在上一次方法执行完毕后到下一次开始执行的间隔时间,单位也是毫秒。不同于 fixedRate,fixedDelay 会等待前一次方法执行完成后才开始计时。
示例:

@Scheduled(fixedDelay = 1000) // 完成后1000毫秒再次执行

initialDelay

:这个参数用来定义延迟首次执行任务的时间,单位为毫秒。它通常与 fixedRate 或 fixedDelay 结合使用,用来设置启动后延迟执行任务。
示例:

@Scheduled(fixedRate = 1000, initialDelay = 1000) // 启动后延迟1000毫秒,之后每1000毫秒执行一次

zone

:用于指定 cron 表达式的时区,默认是服务器的本地时区。
示例:

   @Scheduled(cron = "0 15 10 * * ?", zone = "America/New_York") // 指定时区为纽约

使用 @Scheduled 注解需要在 Spring 配置中启用定时任务(通过注解 @EnableScheduling)。这样,Spring 的任务调度器就会自动识别使用了 @Scheduled 注解的方法,并根据设定的规则执行这些方法。

最后在启动类上开启该方法@EnableScheduling

多个服务导致资源冲突问题

当多个服务同时操作一个任务就会造成数据冲突,所以就需要分布式锁,redis的setnx,无状态,可共享,读取块就能成为很好的解决方案在这里插入图片描述
redisssesion实现分布式锁
也可以只有使用redis 上锁方法

  public String tryLock(String name, long expire) {name = name + "_lock";String token = UUID.randomUUID().toString();RedisConnectionFactory factory = stringRedisTemplate.getConnectionFactory();RedisConnection conn = factory.getConnection();try {//参考redis命令:在redis中存入数据 数据明 uuid token 为锁的名字
//            因为这个数据的名字都是name+_locak 所以每次调用加锁方法setnx 只有一个成功调用的才能才能成功的保存的一个锁数据,其他的只能无法设置//set key value [EX seconds] [PX milliseconds] [NX|XX]Boolean result = conn.set(name.getBytes(),token.getBytes(),Expiration.from(expire, TimeUnit.MILLISECONDS),RedisStringCommands.SetOption.SET_IF_ABSENT //NX);if (result != null && result)return token;} finally {RedisConnectionUtils.releaseConnection(conn, factory,false);}return null;}

方法调用
因为我的定时任务是每隔1minute 执行一次,所以每次上锁30s,让其他任务线程无法获取,这里是统一名字实际业务开发,一个数据的操作可以使用一个数据的主键+前后缀来作为锁名

@Scheduled(cron = "0 */1 * * * ?")public void refresh(){String token = cacheService.tryLock("FUTURE_TASK_SYNC", 1000 * 30);if(StringUtils.isNotBlank(token)){//。。。。。执行逻辑}}}

http://www.ppmy.cn/news/1234397.html

相关文章

ARM 汇编基础

我们在学习 STM32 的时候几乎没有用到过汇编,可能在学习 UCOS 、 FreeRTOS 等 RTOS 类操作系统移植的时候可能会接触到一点汇编。但是我们在进行嵌入式 Linux 开发的时候是绝 对要掌握基本的 ARM 汇编,因为 Cortex-A 芯片一上电 SP 指针还…

规划类3d全景线上云展馆帮助企业轻松拓展海外市场

科技3D线上云展馆作为一种基于VR虚拟现实和互联网技术的新一代展览平台。可以在线上虚拟空间中模拟真实的展馆,让观众无需亲自到场,即可获得沉浸式的参观体验。通过这个展馆,您可以充分、全面、立体展示您的产品、服务以及各种创意作品&#…

网络和Linux网络_4(应用层)序列化和反序列化(网络计算器)

目录 1. 重新理解协议 2. 网络版本计算器 2.1 前期封装 Log.hpp sock.hpp TcpServer.hpp 第一次测试(链接) 2.2 计算器实现 第二次测试(序列化和反序列化) 第三次测试(客户端字节流) CalServer.cc CalClient.cc 3. 守护进程 3.1 守护进程和前后台进程 3.1 变成…

转移表达式:<![CDATA[ ]]>

你是否遇到过&#xff1a;在mybatis 时我们sql是写在xml 映射文件中&#xff0c;如果写的sql中有一些特殊的字符的话&#xff0c;在解析xml文件的时候会被转义&#xff0c;但我们不希望他被转义&#xff0c;所以我们要使用<![CDATA[ ]]>来解决。 <![CDATA[ ]]> …

flink1.13.6版本的应用程序(maven版)

问题 想要一个指定flink版本的java计算任务hello world最简工程。 解决 mvn archetype:generate \-DarchetypeGroupIdorg.apache.flink \-DarchetypeArtifactIdflink-quickstart-java \-DarchetypeVersion1.13.6这里直接使用官方mave模版工程&#xff0c;指…

日志门面slf4j与常用的日志框架Log4j,Logback和Log4j2

slf4j 是众多日志框架接口的集合(俗称日志门面)&#xff0c;它不负责具体的日志实现&#xff0c;只在编译时负责寻找合适的日志框架进行绑定,各日志框架通过扩展jar包中的适配器与slf4j建立适配 SLF4J可以和Log4j、Logback、Log4j2、JUL等日志框架配合使用&#xff0c;这里主要…

微信小程序蓝牙连接 uniApp蓝牙连接设备

蓝牙列表期待效果 代码 <template><view class"bluetooth-list"><view class"align-items option" style"justify-content: space-between;" v-for"item in bluetoothList" :key"item.deviceId"><vie…

逸学java【初级菜鸟篇】9.4 泛型

hi&#xff0c;我是逸尘&#xff0c;一起学java吧 泛型概述 泛型是我们在定义某一个类型规格的时候使用的泛指&#xff0c;我们预先定义一个大方向&#xff0c;防止路线错误。 实质上是程序员定义的安全类型&#xff0c;Object是顶级父类&#xff0c;在没有泛型很多程序员为了…

java基础-集合

1、集合 在java中&#xff0c;集合&#xff08;Collection&#xff09;指的是一组数据容器&#xff0c;它可以存储多个对象&#xff0c;并且允许用户通过一些方法来访问与操作这些对象。j 集合的实现原理都基于数据结构和算法&#xff0c;如下&#xff1a; 数据结构&#xff1…

如何将设置为静态IP的VMware虚拟机进行克隆以便可以复刻相应的环境

一定要关闭需要克隆的虚拟机右键要选择克隆的虚拟机&#xff0c;选择管理->克隆&#xff0c;进入克隆虚拟机向导 设定克隆出来的虚拟机名称以及位置&#xff0c;选择完成 克隆完成之后将会生成虚拟机&#xff0c;示例中生成的虚拟机为ubuntu-dev2 因为原本的虚拟机为静态ip的…

设计模式——RBAC 模型详解

1.什么是 RBAC 呢&#xff1f; RBAC 即基于角色的权限访问控制&#xff08;Role-Based Access Control&#xff09;。这是一种通过角色关联权限&#xff0c;角色同时又关联用户的授权方式。 简单地说&#xff1a;一个用户可以拥有若干角色&#xff0c;每一个角色又可以被分配…

GO MySQL数据库操作封装

Go 语言操作数据库, 数据库连接封装&#xff1a; package Test_dbimport ("database/sql""fmt"_ "github.com/go-sql-driver/mysql""log""sync" )var (DB *sql.DBpoolOnce sync.Once )func NewConnection() (*sql.…

基于SpringBoot+Mybatis plus+React.js实现条件选择切换搜索功能

笔记/朱季谦 在写React前端逻辑时&#xff0c;经常遇到可以切换不同条件的列表查询功能&#xff0c;例如下边截图这样的&#xff0c;其实&#xff0c;这块代码基本都一个逻辑&#xff0c;可以一次性将实现过程记录下来&#xff0c;待以后再遇到时&#xff0c;直接根据笔记复用…

vr小鼠虚拟解剖实验教学平台减少了受感染风险

家畜解剖实验教学是培养畜牧兽医专业学生实际操作能力的专业教学活动中的核心手段。采取新型教学方式与手段&#xff0c;合理设置实验教学内容&#xff0c;有助于激发学生的操作积极性&#xff0c;促进实践教学的改革。 家畜解剖VR仿真教学是一种借助VR虚拟现实制作和web3d开发…

目标检测YOLO实战应用案例100讲-基于YOLO的小目标检测改进算法

目录 前言 国内外研究现状 常规尺寸目标检测算法 小目标的检测算法

webpack 配置

1、基础配置 // node js核心模塊 const path require(path) // 插件是需要引入使用的 const ESLintPlugin require(eslint-webpack-plugin) // 自动生成index.html const HtmlWebpackPlugin require(html-webpack-plugin); // 将css文件单独打包&#xff0c;在index.html中…

【产品安全平台】上海道宁与Cybellum将整个产品安全工作流程整合到一个专用平台中,保持构建的互联产品的网络安全和网络合规性

Cybellum将 整个产品安全工作流程 整合到一个专用平台中 使设备制造商能够 保持他们构建的互联产品的 网络安全和网络合规性 产品安全性对 每个人来说都不一样 每个行业的系统、工作流程和 法规都存在根本差异 因此&#xff0c;Cybellum量身定制了 Cybellum的平台和技…

广播组播、本地套接字通信、wireshark、以太网帧格式、三次握手四次挥手

广播&#xff08;使用 UDP 套接字&#xff09; 广播地址&#xff1a;主机号最大的地址。 广播&#xff1a;给所在局域网的所有主机发送数据报。&#xff08;之前的数据报发送方式是单播。&#xff09; 以下情况中使用广播&#xff1a; 局域网 搜索协议。 比如家中的智能产品&a…

【c++Leetcode】206. Reverse Linked List

问题入口 time complexity: O(n), space complexity:O(1) ListNode* reverseList(ListNode* head) {ListNode* prev nullptr;ListNode* curr head;while(curr){ListNode* forward curr->next;curr->next prev;prev curr;curr forward;}return prev; } time comp…

搭个网页应用,让ChatGPT帮我写SQL

大家好&#xff0c;我是凌览。 开门见山&#xff0c;我搭了一个网页应用名字叫sql-translate。访问链接挂在我的个人博客(https://linglan01.cn/about)导航栏&#xff0c;也可以访问https://www.linglan01.cn/c/sql-translate/直达sql-translate。 它的主要功能有&#xff1a;…
最新文章