Node.js中基于node-schedule实现定时任务之详解

文章目录

      • 一、定时任务
      • 二、node-schedule、
        • 1、安装
        • 2、引入
        • 3、基于Cron表达式的规则
        • 4、基于Date的规则
        • 5、基于RecurrenceRule的规则
        • 6、API
        • 7、状态监听

一、定时任务

实际工作中,可能会遇到定时清除某个文件夹内容,定时发送消息或发送邮件给指定用户,定时导出某些数据等。借助setTimeout和setInterval来实现的化太过麻烦,node-schedule是一个非常不错的npm包,可以帮助我们快速的创建和管理定时任务。

定时任务是指在预定的时间点或时间间隔内执行的任务或操作。它们是自动化执行特定逻辑的一种方式,可用于执行重复性的、周期性的或计划性的任务。

定时任务通常用于以下情况:

  • 数据管理与备份:定时任务可以用于定期备份数据库中的数据,确保数据的安全性和可靠性。此外,还可以用于多个数据源之间的数据同步,保证数据的一致性。

  • 系统监控与维护:定时任务可以用于监控系统中的各种指标和状态,如服务器负载、数据库连接池的使用情况等,及时发现并解决潜在的问题。同时,也可以用于定期刷新缓存,保证缓存数据的及时性和准确性。

  • 执行定时任务:定时器可以用于在预定的时间间隔内执行特定的任务或代码块,例如数据备份、日志清理、缓存刷新等操作。

  • 定时提醒和通知:定时器可以用于实现定时提醒和通知功能,如闹钟、定时器应用等,通过设置定时器,在指定的时间点触发提醒或通知,帮助用户记住重要事件或完成特定任务。

  • 自动保存和自动提交:定时器可以用于自动保存或自动提交表单数据,通过设置定时器,在一定的时间间隔内自动将用户输入的数据保存到服务器或数据库,避免数据丢失或用户忘记保存的情况。

  • 定时刷新页面内容:定时器可以用于定时刷新页面的特定部分或整个页面,通过设置定时器,在一定的时间间隔内更新页面内容,如实时展示新闻、股票行情等。

  • 会话管理与心跳检测:在Web应用中,定时器可以用来检查并清理长时间未活动的用户会话,以及客户端和服务端之间利用定时器发送心跳包来维持长连接,及时发现连接异常。

  • 延迟执行与调度任务:定时器可以用于延迟发送消息或在非高峰时段执行批处理作业,减轻服务器负载。

二、node-schedule、

1、安装
npm install node-schedule
2、引入

CommonJS:

const schedule = require('node-schedule');

ES模块

import schedule from 'node-schedule'
3、基于Cron表达式的规则

Cron表达式是一种用于指定定时任务执行时间的字符串表示形式。它由6个字段组成,每个字段表示任务执行的时间单位和范围。

*    *    *    *    *    *
┬    ┬    ┬    ┬    ┬    ┬
│    │    │    │    │    │
│    │    │    │    │    └ 星期几(0 - 7) (0相对于周日) 
│    │    │    │    └───── 月 (1 - 12)
│    │    │    └────────── 日 (1 - 31)
│    │    └─────────────── 时 (0 - 23)
│    └──────────────────── 分 (0 - 59)
└───────────────────────── 秒 (0 - 59)

每个字段可以接受特定的数值、范围、通配符和特殊字符来指定任务的执行时间:

  • 数值:表示具体的时间单位,如1、2、10等。
  • 范围:使用-连接起始和结束的数值,表示一个范围内的所有值,如1-5表示1到5的所有数值。
  • 通配符:使用表示匹配该字段的所有可能值,如表示每分钟、每小时、每天等。
  • 逗号分隔:使用逗号分隔多个数值或范围,表示匹配其中任意一个值,如1,3表示1或3。
  • 步长:使用/表示步长,用于指定间隔的数值,如*/5表示每隔5个单位执行一次。
  • 特殊字符:Cron表达式还支持一些特殊字符来表示特定的含义,如?用于替代日和星期字段中的任意值,L表示最后一天,W表示最近的工作日等。

使用cron字符串作为rule时,建议写完整,可读性比较好。

以下是一些常见的Cron表达式示例:

* * * * * *     :每秒执行

*/5 * * * * *   :每5秒执行

* 30 * * * *    :每30分钟执行

*/10 30 * * * * :每30分钟的10秒执行

2,4,6 * * * * * :每个2秒,4秒和6秒执行

0 0 0 ? * 1     :每周一早上的零点执行

* * * 20 * ?    :每月的20日触发

4、基于Date的规则

当你需要在具体的时间执行一次,可以使用new Date来定义一个时间。

假设您非常希望在一个精确到某一个时间点上的秒数的仅触发一次的计划。

const schedule = require('node-schedule');
//2024年,6月,1日,6时,1分,0秒
//month 范围是 0~11 而非1~12
const date = new Date(2024, 5, 1, 6, 1, 0);
const job = schedule.scheduleJob(date, ()=>{
  console.log('Happy Children’s Day !');
});
5、基于RecurrenceRule的规则

如果你的任务是定时重复执行的,并且你希望有比cron更高的可读性,你可以尝试使用RecurrenceRule对象作为rule。

function Recurrence(year, month, date, dayOfWeek, hour, minute, second, tz)

dayOfWeek 范围是 0~6
month 范围是 0~11 而非1~12
如果是连续的值,node-schedule提供了一个Range函数用于创建连续的元素

  • 每分钟的15、30、45秒执行
const rule = new schedule.RecurrenceRule();
//每个15、30、45秒执行
rule.second = [15, 30, 45];
const job = schedule.scheduleJob(rule, () => {
    console.log(`每次计划执行的时间:${new Date().toLocaleString()}`);
});

在这里插入图片描述

  • 每分钟的第10秒
rule.second = 10;

在这里插入图片描述

  • 每小时的第10分钟
rule.minute = 10;
  • 每周四,周五,周六,周天的17点
rule.dayOfWeek = [0, new schedule.Range(4, 6)];
rule.hour = 17;
rule.minute = 0;
6、API
  • 开启定时任务

需要用到scheduleJob函数,会返回一个Job实例对象:

function scheduleJob(name: string, rule: ..., callback: function): schedule.Job

参数

参数名参数类型参数描述
name任务名,当你没有指定时,它将以时间戳作为名字。
rule任务调度的规则,支持多种形式的rule:
string - Cron表达式
number
schedule.RecurrenceRule
Date
callback创建任务时的回调函数

可以通过scheduleJob(name, rule, callback)或者scheduleJob(rule, callback)创建计划。

const rule = '* * * * * *';
const job = schedule.scheduleJob(rule,()=>{});
  • 取消定时任务
schedule.cancelJob(id)
7、状态监听
import schedule from 'node-schedule';

//设置规则
const rule = "*/10 * * * * *"

//设置任务
const job = schedule.scheduleJob(rule, () => {
    console.log('2、每次计划执行中的事件。');
});


job.on("scheduled", () => {
    console.log("1、每次计划执行前的事件。");
});


job.on("run", () => {
    console.log("3、每次计划执行后的事件。");
});


job.on("success", () => {
    console.log(`4、每次计划执行成功事件。`);
});


job.on("error", (err) => {
    console.log(`[error][${new Date().toLocaleString()}]${err.message}`);
});


job.on("canceled", () => {
    console.log("计划取消!");
})

在这里插入图片描述

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Codepen Three.js环境依赖配置

Codepen Three.js环境依赖配置 前言 如果想在CodePen环境写Three.js依赖的项目,环境搭建可以参考该Codepen项目: Chill the lion 详细 打开设置可以看到以下配置 更多项目参考 1. Chill the Lion Chill the Lion 是一个基于 ThreeJS 制作的 WebGL 示例。它由…

FreeRTOS学习 -- 时间管理

在使用 FreeRTOS 的过程中通常会在一个任务函数中使用延时函数对这个任务延时,当执行延时函数的时候会进行任务切换,并且此任务就会进入阻塞态,直到延时完成,任务重新进入就绪态。 FreeRTOS 延时函数 1、函数 vTaskDelay() 在F…

【全开源】沃德会务会议管理系统(FastAdmin+ThinkPHP+Uniapp)

沃德会务会议管理系统一款基于FastAdminThinkPHPUniapp开发的会议管理系统,对会议流程、开支、数量、标准、供应商提供一种标准化的管理方法。以达到量化成本节约,风险缓解和服务质量提升的目的。适用于大型论坛、峰会、学术会议、政府大会、合作伙伴大会…

简单了解MyBatis

MyBatis 1、快速入门 MyBatis中文手册官网MyBatis中文网 1.1、创建数据表添加数据 create table user(id int auto_increment primary key comment 主键id,name varchar(20) comment 姓名,age int comment 年龄,gender char(1) comment 性别(1:男, 2…

为什么我在 PostgreSQL 中 Commit 很慢?

有时,我们的一位客户会查看数据库中最耗时的语句(使用pg_stat_statements或pgBadger),并发现COMMIT排名靠前。通常,COMMIT这是 PostgreSQL 中非常快的语句,因此值得研究。在本文中,我将探讨速度…

四川赤橙宏海商务信息咨询有限公司可信吗?

在数字化浪潮席卷全球的今天,电商行业正以前所未有的速度蓬勃发展。作为这一领域的佼佼者,四川赤橙宏海商务信息咨询有限公司凭借其在抖音电商服务领域的深厚积累和卓越表现,成为了引领行业创新发展的重要力量。 四川赤橙宏海商务信息咨询有…

华为设备telnet 远程访问配置实验简述

一、实验需求: 1、AR1模拟电脑telnet 访问AR2路由器。 二、实验步骤: 1、AR1和AR2接口配置IP,实现链路通信。 2、AR2配置AAA模式 配置用户及密码 配置用户访问级别 配置用户telnet 访问服务 AR2配置远程服务数量 配置用户远程访问模式为AAA 配置允许登录…

如何使用DeadFinder寻找失效链接

关于DeadFinder DeadFinder是一款功能强大的链接分析工具,该工具可以帮助广大研究人员快速地寻找目标页面中的无效链接(死链)。所谓死链,即一个页面中存在的无法被连接的一条链接。这些链接如果一直保留在页面中的话,…

【2024.6.21】今日科技时事:科技前沿大事件

人不走空 🌈个人主页:人不走空 💖系列专栏:算法专题 ⏰诗词歌赋:斯是陋室,惟吾德馨 目录 🌈个人主页:人不走空 💖系列专栏:算法专题 ⏰诗词歌…

[STM32]万年历

[STM32]万年历 需要资料的请在文章末尾获取~ ​​ 01描述 使用原件:stm32f103c8t6最小系统板x1,0.96寸OLED显示屏四角x1,4x4矩阵按键x1; 键位对应图: 1, 2, 3, 4------------- 切换页面 设置…

干货分享|如何将前端代理服务器(BFF)接入身份认证(1)

本篇文章将通过实例来详细讲解如何将前端代理服务器(BFF)接入身份认证。我们将使用一个示例应用来演示 BFF 与身份认证的集成过程。 通过这些实例讲解,你将掌握 BFF 与身份认证的集成技巧,为你的前端应用提供安全可靠的认证机制。…

APP IOS

APP IOS苹果源生应用程序 APP Android-CSDN博客

【Sa-Token|3】Sa-Token集成到现有微服务详细介绍

一、系统架构调整 用户中心:保持现有的用户登录、注册接口不变。多个项目:前后端分离,保持现有逻辑不变。网关服务:新增或配置网关服务,处理所有请求并进行 Token 校验和转发。统一 Token 管理:通过 Sa-Tok…

肇庆具有资质等保机构有几家?在哪里?

在近期揭晓的“中国百强城市排行榜”中,广东省共有12个城市入选,其中包括肇庆。肇庆-山水之城,文化之韵,端砚之乡,岭南瑰宝,是一个非常有发展的城市,企业多多。这不不少肇庆企业在问&#xff0c…

嵌入式PID算法总结

参考 CMSIS-DSP PID 控制 学习历程 最开始,根据公式自己写PID算法;后面找资料时,发现wiki上介绍PID时,提供了伪代码,直接照着翻译一下就可用了;然后想要实现一个自己的PID库(能够实现多级PID…

10条提升大模型任务微调效果的tricks

在大型语言模型(LLMs)的研究和应用中,如何通过微调来适应特定任务是一个关键问题。尽管提示工程(PE)在提升LLMs的零样本学习和上下文内学习方面取得了显著成效,但关于如何设计有效的微调样本以进一步提升LL…

Elasticsearch中的Term_Filter过滤器技术

文章目录 一、引言二、Term Filter的工作原理与内部机制三、Term Filter的多样化使用场景3.1 精确匹配3.2 过滤分类与标签3.3 数据范围筛选3.4 复杂查询的构建 四、Term Filter的最佳实践与应用建议4.1 避免使用分析器4.2 优化索引映射4.3 充分利用缓存4.4 持续监控性能 五、结…

Redis 7.x 系列【2】单机部署

有道无术,术尚可求,有术无道,止于术。 本系列Redis 版本 7.2.5 源码地址:https://gitee.com/pearl-organization/study-redis-demo 文章目录 1. Windows2. Linux 1. Windows Redis作为一个高性能的内存数据库,和Linu…

查询mysql库表的几个语句

1、查询某个数据库的所有表 SELECTtable_name FROMinformation_schema.TABLES WHEREtable_schema database_namedatabase_name替换成你需要查询的数据库名称 2、查询某张表的所有字段名称 SELECTCOLUMN_NAME,column_comment FROMinformation_schema.COLUMNS WHEREtable…

功能测试 之 单模块测试----购物车模块

1.需求分析 (1)购物车显示 1.若未登录,提示登录,提示文案“购物车内暂时没有商品,登录后将显示您之前加入的商品” 2.若已登录,购物车没有商品,提示去购物。 未登录状态 已登录状态 3.购物车有…