• Babel 插件通关秘籍
  • Git 原理详解及实用指南
  • Nest 通关秘籍
  • React 通关秘籍
  • TypeScript 全面进阶指南
  • TypeScript 类型体操通关秘籍
  • 现代CSS
  • Babel 插件通关秘籍
  • Git 原理详解及实用指南
  • Nest 通关秘籍
  • React 通关秘籍
  • TypeScript 全面进阶指南
  • TypeScript 类型体操通关秘籍
  • 现代CSS
  • Nest 通关秘籍

    • 1.开篇词
    • 2.给你 5 个学习 Nest 的理由,你会心动么
    • 3.Nest 基础概念扫盲
    • 4.快速掌握 Nest CLI
    • 5.五种HTTP数据传输方式
    • 6.IoC 解决了什么痛点问题?
    • 7.如何调试 Nest 项目
    • 8.使用多种 Provider,灵活注入对象
    • 9.全局模块和生命周期
    • 10.AOP 架构有什么好处?
    • 11.一网打尽 Nest 全部装饰器
    • 12.Nest 如何自定义装饰器
    • 13.Metadata 和 Reflector
    • 14.ExecutionContext:切换不同上下文
    • 15.Module 和 Provider 的循环依赖怎么处理?
    • 16.如何创建动态模块
    • 17.Nest 和 Express 的关系,如何切到 fastify
    • 18.Nest 的 Middleware
    • 19.RxJS 和 Interceptor
    • 20.内置 Pipe 和自定义 Pipe
    • 21.如何使用 ValidationPipe 验证 post 请求参数
    • 22.如何自定义 Exception Filter
    • 23.图解串一串 Nest 核心概念
    • 24.接口如何实现多版本共存
    • 25.Express 如何使用 multer 实现文件上传
    • 26.Nest 如何使用 multer 实现文件上传
    • 27.图书管理系统:需求分析和原型图
    • 28.图书管理系统:用户模块后端开发
    • 29.图书管理系统:图书模块后端开发
    • 30.图书管理系统:用户模块前端开发
    • 31.图书管理系统:图书模块前端开发--图书搜索
    • 32.图书管理系统:图书模块前端开发--图书增删改
    • 33.图书管理系统:项目总结
    • 34.大文件分片上传
    • 35.最完美的 OSS 上传方案
    • 36.Nest 里如何打印日志?
    • 37.为什么 Node 里要用 Winston 打印日志?
    • 38.Nest 集成日志框架 Winston
    • 39.通过 Desktop 学 Docker 也太简单了
    • 40.你的第一个 Dockerfile
    • 41.Nest 项目如何编写 Dockerfile
    • 42.提升 Dockerfile 水平的 5 个技巧
    • 43.Docker 是怎么实现的?
    • 44.为什么 Node 应用要用 PM2 来跑?
    • 45.快速入门 MySQL
    • 46.SQL 查询语句的所有语法和函数
    • 47.一对一、join 查询、级联方式
    • 48.一对多、多对多关系的表设计
    • 49.子查询和 EXISTS
    • 50.SQL 综合练习
    • 51.MySQL 的事务和隔离级别
    • 52.MySQL 的视图、存储过程和函数
    • 53.使用 Node 操作 MySQL 的两种方式
    • 54.快速掌握 TypeORM
    • 55.TypeORM 一对一的映射和关联 CRUD
    • 56.TypeORM 一对多的映射和关联 CRUD
    • 57.TypeORM 多对多的映射和关联 CRUD
    • 58.在 Nest 里集成 TypeORM
    • 59.TypeORM 如何保存任意层级的关系?
    • 60.为什么生产环境要用 TypeORM 的 migration 迁移功能?
    • 61.Nest 项目里如何使用 TypeORM 迁移
    • 62.如何动态读取不同环境的配置?
    • 63.快速入门 Redis
    • 64.在 Nest 里操作 Redis
    • 65.为什么不用 cache-manager 操作 Redis?
    • 66.两种登录状态保存方式:JWT、Session
    • 67.Nest 里实现 Session 和 JWT
    • 68.MySQL + TypeORM + JWT 实现登录注册
    • 69.基于 ACL 实现权限控制
    • 70.基于 RBAC 实现权限控制
    • 71.基于 access_token 和 refresh_token 实现登录状态无感刷新
    • 72.单 token 无限续期,实现登录状态无感刷新
    • 73.使用 passport 做身份认证
    • 74.passport 实现 GitHub 三方账号登录
    • 75.passport 实现 Google 三方账号登录
    • 76.为什么要使用 Docker Compose ?
    • 77.Docker 容器通信的最简单方式:桥接网络
    • 78.Docker 支持重启策略,是否还需要 PM2
    • 79.快速掌握 Nginx 的 2 大核心用法
    • 80.基于 Nginx 实现灰度系统
    • 81.基于 Redis 实现分布式 session
    • 82.Redis + 高德地图,实现附近的充电宝
    • 83.用 Swagger 自动生成 api 文档
    • 84.如何灵活创建 DTO
    • 85.class-validator 的内置装饰器,如何自定义装饰器
    • 86.序列化 Entity,你不需要 VO 对象
    • 87.手写序列化 Entity 的拦截器
    • 88.使用 compodoc 生成文档
    • 89.Node 如何发邮件?
    • 90.实现基于邮箱验证码的登录
    • 91.定时任务 + Redis 实现阅读量计数
    • 92.Nest 的 3 种定时任务
    • 93.Nest 里如何实现事件通信?
    • 94.HttpModule + pinyin 实现天气预报查询服务
    • 95.如何记录请求日志
    • 96.短链服务?自己写一个
    • 97.Nest 实现 Server Sent Event 数据推送
    • 98.用 minio 自己搭一个 OSS 服务
    • 99.前端如何直传文件到 Minio
    • 100.基于 sharp 实现 gif 压缩工具
    • 101.大文件如何实现流式下载?
    • 102.Puppeteer 实现爬虫,爬取 BOSS 直聘全部前端岗位
    • 103.实现扫二维码登录
    • 104.Nest 的 REPL 模式
    • 105.实现 Excel 导入导出
    • 106.如何用代码动态生成 PPT
    • 107.如何拿到服务器 CPU、内存、磁盘状态
    • 108.Nest 如何实现国际化?
    • 109.会议室预订系统:需求分析和原型图
    • 110.会议室预订系统:技术方案和数据库设计
    • 111.会议室预订系统:用户管理模块-用户注册
    • 112.会议室预订系统:用户管理模块-配置抽离、登录认证鉴权
    • 113.会议室预订系统:用户管理模块-interceptor、修改信息接口
    • 114.会议室预订系统:用户管理模块-用户列表和分页查询
    • 115.会议室预订系统:用户管理模块-swagger 接口文档
    • 116.会议室预订系统:用户管理模块-用户端登录注册页面
    • 117.会议室预订系统:用户管理模块-用户端信息修改页面
    • 118.会议室预订系统:用户管理模块-头像上传
    • 119.会议室预订系统:用户管理模块-管理端用户列表页面
    • 120.会议室预订系统:用户管理模块-管理端信息修改页面
    • 121.会议室预订系统:会议室管理模块-后端开发
    • 122.会议室预订系统:会议室管理模块-管理端前端开发
    • 123.会议室预订系统:会议室管理模块-用户端前端开发
    • 124.会议室预订系统:预定管理模块-后端开发
    • 125.会议室预订系统:预定管理模块-管理端前端开发
    • 126.会议室预订系统:预定管理模块-用户端前端开发
    • 127.会议室预订系统:统计管理模块-后端开发
    • 128.会议室预订系统:统计管理模块-前端开发
    • 129.会议室预订系统:后端项目部署到阿里云
    • 130.会议室预订系统:前端项目部署到阿里云
    • 131.会议室预定系统:用 migration 初始化表和数据
    • 132.会议室预定系统:文件上传 OSS
    • 133.会议室预定系统:Google 账号登录后端开发
    • 134.会议室预定系统:Google 账号登录前端开发
    • 135.会议室预定系统:后端代码优化
    • 136.会议室预定系统:集成日志框架 winston
    • 137.会议室预定系统:前端代码优化
    • 138.会议室预定系统:全部功能测试
    • 139.会议室预定系统:项目总结
    • 140.Nest 如何创建微服务?
    • 141.Nest 的 Monorepo 和 Library
    • 142.用 Etcd 实现微服务配置中心和注册中心
    • 143.Nest 集成 Etcd 做注册中心、配置中心
    • 144.用 Nacos 实现微服务配置中心和注册中心
    • 145.基于 gRPC 实现跨语言的微服务通信
    • 146.快速入门 ORM 框架 Prisma
    • 147.Prisma 的全部命令
    • 148.Prisma 的全部 schema 语法
    • 149.Primsa Client 单表 CRUD 的全部 api
    • 150.Prisma Client 多表 CRUD 的全部 api
    • 151.在 Nest 里集成 Prisma
    • 152.为什么前端监控系统要用 RabbitMQ?
    • 153.基于 Redis 实现关注关系
    • 154.基于 Redis 实现各种排行榜(周榜、月榜、年榜)
    • 155.考试系统:需求分析
    • 156.考试系统:技术方案和数据库设计
    • 157.考试系统:微服务、Lib 拆分
    • 158.考试系统;用户注册
    • 159.考试系统:用户登录、修改密码
    • 160.考试系统:考试微服务
    • 161.考试系统:登录、注册页面
    • 162.考试系统:修改密码、试卷列表页面
    • 163.考试系统:新增试卷、回收站
    • 164.考试系统:试卷编辑器
    • 165.考试系统:试卷回显、预览、保存
    • 166.考试系统:答卷微服务
    • 167.考试系统:答题页面
    • 168.考试系统:自动判卷
    • 169.考试系统:分析微服务、排行榜页面
    • 170.考试系统:整体测试
    • 171.考试系统:项目总结
    • 172.用 Node.js 手写 WebSocket 协议
    • 173.Nest 开发 WebSocket 服务
    • 174.基于 Socket.io 的 room 实现群聊
    • 175.聊天室:需求分析和原型图
    • 176.聊天室:技术选型和数据库设计
    • 177.聊天室:用户注册
    • 178.聊天室:用户登录
    • 179.聊天室:修改密码、修改信息
    • 180.聊天室:好友列表、发送好友申请
    • 181.聊天室:创建聊天室、加入群聊
    • 182.聊天室:登录、注册页面开发
    • 183.聊天室:修改密码、信息页面开发
    • 184.聊天室:头像上传
    • 185.聊天室:好友∕群聊列表页面
    • 186.聊天室:添加好友弹窗、通知页面
    • 187.聊天室:聊天功能后端开发
    • 188.聊天室:聊天功能前端开发
    • 189.聊天室:一对一聊天
    • 190.聊天室:创建群聊、进入群聊
    • 191.聊天室:发送表情、图片、文件
    • 192.聊天室:收藏
    • 193.聊天室:全部功能测试
    • 194.聊天室:项目总结
    • 195.MongoDB 快速入门
    • 196.使用 mongoose 操作 MongoDB 数据库
    • 197.GraphQL 快速入门
    • 198.Nest 开发 GraphQL 服务:实现 CRUD
    • 199.GraphQL + Primsa + React 实现 TodoList
    • 200.如何调试 Nest 源码?

定时任务,顾名思义就是你可以设定个时间,任务会在设定的时间自动执行。

比如上节我们在 redis 里存取数据,然后通过定时任务在凌晨 4 点刷入数据库。

这节我们就更全面的学下定时任务吧。

新建个 nest 项目:

nest new schedule-task

然后安装定时任务的包:

npm install --save @nestjs/schedule

在 AppModule 里引入:

然后就可以创建定时任务了。

我们创建个 service:

nest g service task --flat --no-spec

通过 @Cron 声明任务执行时间:

import { Injectable, Logger } from "@nestjs/common";
import { Cron, CronExpression } from "@nestjs/schedule";

@Injectable()
export class TaskService {
    @Cron(CronExpression.EVERY_5_SECONDS)
    handleCron() {
        console.log("task execute");
    }
}

把服务跑起来试下:

npm run start:dev

可以看到,任务每 5s 都会执行。

当然,也可以注入其他模块的 service。

我们创建个 aaa 模块:

nest g resource aaa

把 AaaService 导出:

然后在 TaskService 注入:

import { Inject, Injectable, Logger } from "@nestjs/common";
import { Cron, CronExpression } from "@nestjs/schedule";
import { AaaService } from "./aaa/aaa.service";

@Injectable()
export class TaskService {
    @Inject(AaaService)
    private aaaService: AaaService;

    @Cron(CronExpression.EVERY_5_SECONDS)
    handleCron() {
        console.log("task execute:", this.aaaService.findAll());
    }
}

这样就可以定时执行 AaaService 的方法:

上节我们定时把 redis 数据刷入数据库就是这样做的。

我们设置的每 5s 执行一次,其实是一个 cron 表达式:

cron 表达式有这 7 个字段:

其中年是可选的,所以一般都是 6 个。

每个字段都可以写 _ ,比如秒写 _ 就代表每秒都会触发,日期写 * 就代表每天都会触发。

但当你指定了具体的日期的时候,星期得写 ?

比如表达式是

7 12 13 10 * ?

就是每月 10 号的 13:12:07 执行这个定时任务。

但这时候你不知道是星期几,如果写 * 代表不管哪天都会执行,这时候就要写 ?,代表忽略星期。

同样,你指定了星期的时候,日期也可能和它冲突,这时候也要指定 ?

但只有日期和星期可以指定 ?,因为只有这俩字段是相互影响的。

除了指定一个值外,还可以指定范围,比如分钟指定 20-30,

0 20-30 * * * *

这个表达式就是从 20 到 30 的每分钟每个第 0 秒都会执行。

当然也可以指定枚举值,通过 , 分隔

比如每小时的第 5 和 第 10 分钟的第 0 秒执行定时任务:

0 5,10 * * * *

而且还可以通过 / 指定每隔多少时间触发一次。

比如从第 5 分钟开始,每隔 10 分钟触发一次:

0 5/10 * * * *

此外,日期和星期还支持几个特殊字符:

L 是 last,L 用在星期的位置就是星期六:

* * * ? * L

L 用在日期的位置就是每月最后一天:

* * * L * ?

W 代表工作日 workday,只能用在日期位置,代表从周一到周五

* * * W * ?

当你指定 2W 的时候,代表每月的第而个工作日:

* * * 2W * ?

LW 可以在指定日期时连用,代表每月最后一个工作日:

* * * LW * ?

星期的位置还可以用 4#3 表示每个月第 3 周的星期三:

* * * ? * 4#3

同理,每个月的第二周的星期天就是这样:

* * * ? * 1#2

此外,星期几除了可以用从 1(星期天) 到 7(星期六) 的数字外,还可以用单词的前三个字母:SUN, MON, TUE, WED, THU, FRI, SAT

我们来看几个例子:

每隔 5 秒执行一次:

*/5 * * * * ?

每天 5-15 点整点触发:

0 0 5-15 * * ?

每天 10 点、14 点、16 点触发:

0 0 10,14,16 * * ?

每个星期三中午12点:

0 0 12 ? * WED

每周二、四、六下午五点:

0 0 17 ? * TUES,THUR,SAT

每月最后一天 22 点执行一次:

0 0 22 L * ?

2023 年至 2025 年的每月的最后一个星期五上午 9:30 触发

0 30 9 ? * 6L 2023-2025

每月的第三个星期五上午 10:15 触发:

0 15 10 ? * 6#3

基本就这些语法。

但自己写这样的 cron 表达式还是挺麻烦的,所以 Nest 提供了一些常量可以直接用:

这个 @Cron 装饰器还有第二个参数,可以指定定时任务的名字,还有时区:

时区的名字可以在这里查:

除了 @Cron 之外,你还可以用 @Interval 指定任务的执行间隔,参数是毫秒值:

@Interval('task2', 500)
task2() {
    console.log('task2');
}

还可以用 @Timeout 指定多长时间后执行一次:

@Timeout('task3', 3000)
task3() {
    console.log('task3');
}

综上,我们可以通过 @Cron、@Interval、@Timeout 创建 3 种定时任务。

我们知道了怎么声明定时任务,那能不能管理定时任务,也就是对它做增删改呢?

当然是可以的。

我们在 AppModule 里注入 SchedulerRegistry,然后在 onApplicationBootstrap 的声明周期里拿到所有的 cronJobs 打印下:

@Inject(SchedulerRegistry)
private schedulerRegistry: SchedulerRegistry;

onApplicationBootstrap() {
    const jobs = this.schedulerRegistry.getCronJobs();
    console.log(jobs);
}

可以看到,拿到了我们声明的 task1 的定时任务:

这样看不方便,我们加一下调试配置:

{
    "type": "node",
    "request": "launch",
    "name": "debug nest",
    "runtimeExecutable": "npm",
    "args": ["run", "start:dev"],
    "skipFiles": ["<node_internals>/**"],
    "console": "integratedTerminal"
}

打个断点:

把之前的服务停掉,点击 debug 启动:

代码会在断点处断住:

这样就方便多了。

切换到 debug console 就可以动态执行表达式:

比如拿到所有的 interval 定时任务的名字:

再根据名字拿到具体的 interval 定时任务:

this.schedulerRegistry.getIntervals();

this.schedulerRegistry.getInterval("task2");

timeout 和 cron 类型的定时任务也是同理:

this.schedulerRegistry.getTimeouts();

this.schedulerRegistry.getTimeout("task3");

this.schedulerRegistry.getCronJobs();

this.schedulerRegistry.getCronJob("task1");

当然,它还有增加和删除定时任务的 api:

我们来写个具体的案例:

把声明的 3 个 task 删掉,再动态添加 3 个:

自己创建定时任务,需要安装 cron 的包:

npm install --save cron

然后实现下删除定时任务的逻辑:

onApplicationBootstrap() {
    const crons = this.schedulerRegistry.getCronJobs();

    crons.forEach((item, key) => {
      item.stop();
      this.schedulerRegistry.deleteCronJob(key);
    });

    const intervals = this.schedulerRegistry.getIntervals();
    intervals.forEach(item => {
      const interval = this.schedulerRegistry.getInterval(item);
      clearInterval(interval);

      this.schedulerRegistry.deleteInterval(item);
    });

    const timeouts = this.schedulerRegistry.getTimeouts();
    timeouts.forEach(item => {
      const timeout = this.schedulerRegistry.getTimeout(item);
      clearTimeout(timeout);

      this.schedulerRegistry.deleteTimeout(item);
    });

    console.log(this.schedulerRegistry.getCronJobs());
    console.log(this.schedulerRegistry.getIntervals());
    console.log(this.schedulerRegistry.getTimeouts());
  }

为什么停掉 CronJob 用 job.stop 而停掉 timeout 和 interval 用 clearTimeout 和 clearInterval 呢?

因为 timeout 和 interval 本来就是基于 setTimeout、setInterval 的原生 api 封装出来的啊!

而 CronJob 则是基于 cron 包。

跑起来试下:

npm run start:dev

确实没有定时任务执行了:

当然,还可以动态添加定时任务:

const job = new CronJob(`0/5 * * * * *`, () => {
    console.log("cron job");
});

this.schedulerRegistry.addCronJob("job1", job);
job.start();

const interval = setInterval(() => {
    console.log("interval job");
}, 3000);
this.schedulerRegistry.addInterval("job2", interval);

const timeout = setTimeout(() => {
    console.log("timeout job");
}, 5000);
this.schedulerRegistry.addTimeout("job3", timeout);

这里也可以看出来 CronJob 是基于 cron 包封装的,而 interval 和 timeout 就是用的原生 api。

跑起来可以看到,定时任务确实都添加成功了。

也就是说,我们可以注入 SchedulerRegistry 来动态增删定时任务。

案例代码上传了小册仓库。

总结

这节我们学习了定时任务,用到 @nestjs/scheduler 这个包。

主要有 cron、timeout、interval 这 3 种任务。

其中 cron 是依赖 cron 包实现的,而后两种则是对原生 api 的封装。

我们学习了 cron 表达式,还是挺复杂的,当然,你也可以直接用 CronExpression 的一些常量。

此外,你还可以注入 SchedulerRegistery 来对定时任务做增删改查。

定时任务里可以注入 service,来定时执行一些逻辑,在特定业务场景下是很有用的。

上次更新: 6/21/25, 9:42 AM
贡献者: YNight
Prev
91.定时任务 + Redis 实现阅读量计数
Next
93.Nest 里如何实现事件通信?