尧图网站建设 
后端Web框架【免费下载链接】nestA progressive Node.js framework for building efficient, scalable, and enterprise-grade server-side applications with TypeScript/JavaScript 项目地址https://gitcode.com/GitHub_Trending/ne/nest点击查看免费下载本文以 NestJS 官方示例sample/26-queues为对象系统讲解如何在 NestJS 应用中引入 Redis 与 Bull 队列从全局队列配置、队列注册、生产者入队、消费者处理器编写到本地启动与单元/端到端测试验证的完整闭环。读完本文你将掌握BullModule.forRoot/BullModule.registerQueue/Processor/Process/InjectQueue等核心 API 的用法并能独立把示例跑起来、用测试确认任务入队与消费行为。示例概览这个示例在做什么sample/26-queues是 NestJS 官方示例中演示基于 Bull 的队列任务处理的标准项目。它的业务场景非常简单而典型通过 HTTP 接口提交一个音频转码任务任务被投递到名为audio的队列中由后台消费者异步执行示例中消费端仅以日志模拟转码过程。从源码结构看示例的核心文件如下队列全局配置与模块装配 ——BullModule.forRoot连接 Redis注册audio队列队列模块定义 —— 声明队列、控制器与处理器生产者控制器 —— 提供POST /audio/transcode接口入队消费者处理器 —— 通过Processor/Process消费任务应用入口 —— 标准NestFactory.create引导监听 3000 端口Redis 编排文件 —— 一键启动本地 Redis单元测试与 e2e 测试 与 e2e 目录 —— 验证入队与消费行为从 package.json 可以看到本示例锁定的技术栈版本依赖版本作用nestjs/bull12.0.0NestJS 官方 Bull 集成模块装饰器、模块、队列注入 Tokenbull4.16.5底层任务队列引擎基于 Redisnestjs/common/nestjs/core/nestjs/platform-express12.1.0NestJS 框架本体redis由 docker-compose 提供redis:alpine队列的持久化与消息中转后端vitest5.0.2单元测试与 e2e 测试运行器注意示例中package.json声明了type: module源码文件使用 ESM 风格导入例如import { AudioController } from ./audio.controller.js这是当前示例的运行前提。环境准备Redis 与依赖安装Bull 队列依赖 Redis 作为后端存储与消息通道因此运行本示例的第一步是准备一个可用的 Redis 实例。示例自带 docker-compose.yml内容如下version: 3 services: redis: image: redis:alpine ports: - 6379:6379启动 Redisdocker compose up -d随后安装依赖对应 README 的 Installation 步骤$ npm install依赖安装完成后即可进入队列配置与业务代码的研读环节。全局队列配置BullModule.forRoot 与 Redis 连接在 app.module.ts 中根模块通过BullModule.forRoot完成 Redis 连接配置这是整个队列体系的地基import { Module } from nestjs/common; import { BullModule } from nestjs/bull; import { AudioController } from ./audio/audio.controller.js; import { AudioProcessor } from ./audio/audio.processor.js; Module({ imports: [ BullModule.forRoot({ redis: { host: process.env.REDIS_HOST || localhost, port: parseInt(process.env.REDIS_PORT || 6379), }, }), BullModule.registerQueue({ name: audio, }), ], controllers: [AudioController], providers: [AudioProcessor], }) export class AppModule {}从源码可以提炼出两点实用配置信息连接地址通过环境变量注入host取REDIS_HOST默认localhostport取REDIS_PORT默认6379。这意味部署时无需改代码只需设置环境变量即可指向远端 Redis。BullModule.forRoot是全局配置它在根模块注册为整个应用范围内的所有 Bull 队列提供统一的 Redis 连接而BullModule.registerQueue则用于声明具体队列。注册队列并装配生产者与消费者audio.module业务模块 audio.module.ts 完成了队列 → 控制器 → 处理器的装配import { BullModule } from nestjs/bull; import { Module } from nestjs/common; import { AudioController } from ./audio.controller.js; import { AudioProcessor } from ./audio.processor.js; Module({ imports: [ BullModule.registerQueue({ name: audio, }), ], controllers: [AudioController], providers: [AudioProcessor], }) export class AudioModule {}这里BullModule.registerQueue({ name: audio })完成两件事一是向容器注册名为audio的 Bull 队列实例二是为其生成可注入的 Token。该 Token 由nestjs/bull提供的getQueueToken(audio)函数获得——这一点在 audio.controller.spec.ts 的测试替身mock中有直接印证providers: [ { provide: getQueueToken(audio), useValue: mockQueue, }, ],也就是说凡是需要注入audio队列的地方本质上都是按getQueueToken(audio)这个 Token 去容器里取实例。生产者InjectQueue 注入队列并投递任务audio.controller.ts 展示了标准的生产者写法——通过InjectQueue(audio)注入队列在路由处理器中调用queue.add(name, data)投递任务import { InjectQueue } from nestjs/bull; import { Controller, Post } from nestjs/common; import { Queue } from bull; Controller(audio) export class AudioController { constructor(InjectQueue(audio) private readonly audioQueue: Queue) {} Post(transcode) async transcode() { await this.audioQueue.add(transcode, { file: audio.mp3, }); } }关键点拆解InjectQueue(audio)注入参数化队列实例类型为 Bull 的Queue。queue.add(transcode, { file: audio.mp3 })第一个参数是任务名job name第二个参数是任务携带的数据负载。这里的任务名transcode必须与消费者端Process声明的任务名一致才能被正确路由消费。路由Controller(audio)Post(transcode)组合出POST /audio/transcode接口处理函数为async并await入队结果保证响应与入队完成同步。消费者Processor 与 Process 异步消费任务audio.processor.ts 是队列的消费者端import { Process, Processor } from nestjs/bull; import { Logger } from nestjs/common; import { Job } from bull; Processor(audio) export class AudioProcessor { private readonly logger new Logger(AudioProcessor.name); Process(transcode) handleTranscode(job: Job) { this.logger.debug(Start transcoding...); this.logger.debug(job.data); this.logger.debug(Transcoding completed); } }Processor(audio)类级装饰器声明该类是audio队列的消费者nestjs/bull会在应用启动时自动把该类实例挂载到对应队列上开始监听。Process(transcode)方法级装饰器将handleTranscode注册为transcode任务的处理器。处理器接收 Bull 的Job对象通过job.data读取入队时携带的数据本例为{ file: audio.mp3 }。若省略任务名即Process()则该方法会处理该队列中的全部任务。示例消费端仅用Logger.debug打印开始转码→任务数据→转码完成三段日志来模拟真实业务在实际项目中把这段日志替换为 ffmpeg 调用等重活即可处理完成即代表任务被成功消费。至此示例的完整调用链是POST /audio/transcode ↓ queue.add(transcode, { file: audio.mp3 }) Bull 队列Redis 中转 ↓ Process(transcode) 路由 AudioProcessor.handleTranscode(job) → 模拟转码日志运行应用三种启动模式Redis 就绪且依赖安装完成后即可按 README 的 Running the app 部分启动应用# development开发模式 $ npm run start # watch mode监听文件变更自动重启 $ npm run start:dev # production mode生产模式编译产物直启 $ npm run start:prod从 package.json 的 scripts 可以看到这三个命令的真实含义npm run start→nest startnpm run start:dev→nest start --watchnpm run start:prod→node dist/main即先构建、再以 Node 直接运行编译产物应用默认监听3000端口见 main.ts。启动后向POST http://localhost:3000/audio/transcode发送请求即可向队列投递一个转码任务随后在终端观察AudioProcessor打印的消费日志。也可在应用内配置REDIS_HOST/REDIS_PORT环境变量以连接非本机 Redis。测试验证单元测试与端到端测试示例为队列的生产端和消费端各提供了一套测试对应 README 的 Test 部分# unit tests单元测试 $ npm run test # e2e tests端到端测试 $ npm run test:e2e # test coverage覆盖率 $ npm run test:cov对应 scripts 分别为vitest run、vitest run --config ./vitest.config.e2e.mts与vitest run --coverage本示例当前使用 Vitest 而非 Jest仓库同时保留了 jest.json 供参考。生产者单元测试audio.controller.spec.ts通过getQueueToken(audio)注入 mock 队列验证transcode()方法以(transcode, { file: audio.mp3 })参数调用queue.add并校验调用次数与数据结构。消费者单元测试audio.processor.spec.ts以vi.spyOn(Logger.prototype, debug)监控日志输出传入伪造的Job对象验证处理器的三段日志顺序Start transcoding...→job.data→Transcoding completed以及连续处理多个任务时日志按任务数成倍增长。端到端测试audio.e2e-spec.ts基于supertest对真实 HTTP 服务发起请求验证POST /audio/transcode返回201任务成功入队连续 3 个并发请求均返回201队列可承受并发入队GET /audio/transcode返回404路由仅接受 POST 方法。这套测试既验证了入队接口的可用性也间接验证了队列模块在真实 NestJS 容器中的装配正确性。小结sample/26-queues是一个麻雀虽小、五脏俱全的队列集成范例用BullModule.forRoot建立 Redis 连接用BullModule.registerQueue声明队列用InjectQueue在生产端投递任务用Processor/Process在消费端异步处理并配套完整的单元测试与 e2e 测试。以此为基础你可以把示例中的日志模拟替换为真实的异步业务如转码、发信、数据清洗并进一步研究 Bull 的延迟任务、重试、优先级、并发与事件监听等进阶能力。赞分享后端Web框架【免费下载链接】nestA progressive Node.js framework for building efficient, scalable, and enterprise-grade server-side applications with TypeScript/JavaScript 项目地址https://gitcode.com/GitHub_Trending/ne/nest点击查看免费下载相关推荐探索 NestJS Bull强大的任务队列处理解决方案探索 NestJS Bull强大的任务队列处理解决方案 项目简介 是一个由 NestJS https://nestjs.com/ 提供支持的、基于 Bul消息队列后端Bull 队列完全指南基于 Redis 的 Node.js 分布式任务与消息队列实战Bull 队列完全指南基于 Redis 的 Node.js 分布式任务与消息队列实战 本文围绕开源仓库 bull一个基于 Redis 的 Node.js 任任务调度后端Bull 队列实战指南基于 Redis 的 Node.js 分布式任务队列核心机制与使用详解Bull 队列实战指南基于 Redis 的 Node.js 分布式任务队列核心机制与使用详解 Bull 是一个基于 Redis 的 Node.js 任务队列库任务调度后端上一篇SQLAlchemy MySQL 与 MariaDB 方言完全指南数据类型、全文检索、DML 构造与八大驱动下一篇UADK高级特性动态上下文管理与资源调度优化终极指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考 NestJS 队列实战指南：基于 Bull 与 @nestjs/bull 构建音频转码任务队列（sample/26-queues 全解析）
后端Web框架【免费下载链接】nestA progressive Node.js framework for building efficient, scalable, and enterprise-grade server-side applications with TypeScript/JavaScript 项目地址https://gitcode.com/GitHub_Trending/ne/nest点击查看免费下载本文以 NestJS 官方示例sample/26-queues为对象系统讲解如何在 NestJS 应用中引入 Redis 与 Bull 队列从全局队列配置、队列注册、生产者入队、消费者处理器编写到本地启动与单元/端到端测试验证的完整闭环。读完本文你将掌握BullModule.forRoot/BullModule.registerQueue/Processor/Process/InjectQueue等核心 API 的用法并能独立把示例跑起来、用测试确认任务入队与消费行为。示例概览这个示例在做什么sample/26-queues是 NestJS 官方示例中演示基于 Bull 的队列任务处理的标准项目。它的业务场景非常简单而典型通过 HTTP 接口提交一个音频转码任务任务被投递到名为audio的队列中由后台消费者异步执行示例中消费端仅以日志模拟转码过程。从源码结构看示例的核心文件如下队列全局配置与模块装配 ——BullModule.forRoot连接 Redis注册audio队列队列模块定义 —— 声明队列、控制器与处理器生产者控制器 —— 提供POST /audio/transcode接口入队消费者处理器 —— 通过Processor/Process消费任务应用入口 —— 标准NestFactory.create引导监听 3000 端口Redis 编排文件 —— 一键启动本地 Redis单元测试与 e2e 测试 与 e2e 目录 —— 验证入队与消费行为从 package.json 可以看到本示例锁定的技术栈版本依赖版本作用nestjs/bull12.0.0NestJS 官方 Bull 集成模块装饰器、模块、队列注入 Tokenbull4.16.5底层任务队列引擎基于 Redisnestjs/common/nestjs/core/nestjs/platform-express12.1.0NestJS 框架本体redis由 docker-compose 提供redis:alpine队列的持久化与消息中转后端vitest5.0.2单元测试与 e2e 测试运行器注意示例中package.json声明了type: module源码文件使用 ESM 风格导入例如import { AudioController } from ./audio.controller.js这是当前示例的运行前提。环境准备Redis 与依赖安装Bull 队列依赖 Redis 作为后端存储与消息通道因此运行本示例的第一步是准备一个可用的 Redis 实例。示例自带 docker-compose.yml内容如下version: 3 services: redis: image: redis:alpine ports: - 6379:6379启动 Redisdocker compose up -d随后安装依赖对应 README 的 Installation 步骤$ npm install依赖安装完成后即可进入队列配置与业务代码的研读环节。全局队列配置BullModule.forRoot 与 Redis 连接在 app.module.ts 中根模块通过BullModule.forRoot完成 Redis 连接配置这是整个队列体系的地基import { Module } from nestjs/common; import { BullModule } from nestjs/bull; import { AudioController } from ./audio/audio.controller.js; import { AudioProcessor } from ./audio/audio.processor.js; Module({ imports: [ BullModule.forRoot({ redis: { host: process.env.REDIS_HOST || localhost, port: parseInt(process.env.REDIS_PORT || 6379), }, }), BullModule.registerQueue({ name: audio, }), ], controllers: [AudioController], providers: [AudioProcessor], }) export class AppModule {}从源码可以提炼出两点实用配置信息连接地址通过环境变量注入host取REDIS_HOST默认localhostport取REDIS_PORT默认6379。这意味部署时无需改代码只需设置环境变量即可指向远端 Redis。BullModule.forRoot是全局配置它在根模块注册为整个应用范围内的所有 Bull 队列提供统一的 Redis 连接而BullModule.registerQueue则用于声明具体队列。注册队列并装配生产者与消费者audio.module业务模块 audio.module.ts 完成了队列 → 控制器 → 处理器的装配import { BullModule } from nestjs/bull; import { Module } from nestjs/common; import { AudioController } from ./audio.controller.js; import { AudioProcessor } from ./audio.processor.js; Module({ imports: [ BullModule.registerQueue({ name: audio, }), ], controllers: [AudioController], providers: [AudioProcessor], }) export class AudioModule {}这里BullModule.registerQueue({ name: audio })完成两件事一是向容器注册名为audio的 Bull 队列实例二是为其生成可注入的 Token。该 Token 由nestjs/bull提供的getQueueToken(audio)函数获得——这一点在 audio.controller.spec.ts 的测试替身mock中有直接印证providers: [ { provide: getQueueToken(audio), useValue: mockQueue, }, ],也就是说凡是需要注入audio队列的地方本质上都是按getQueueToken(audio)这个 Token 去容器里取实例。生产者InjectQueue 注入队列并投递任务audio.controller.ts 展示了标准的生产者写法——通过InjectQueue(audio)注入队列在路由处理器中调用queue.add(name, data)投递任务import { InjectQueue } from nestjs/bull; import { Controller, Post } from nestjs/common; import { Queue } from bull; Controller(audio) export class AudioController { constructor(InjectQueue(audio) private readonly audioQueue: Queue) {} Post(transcode) async transcode() { await this.audioQueue.add(transcode, { file: audio.mp3, }); } }关键点拆解InjectQueue(audio)注入参数化队列实例类型为 Bull 的Queue。queue.add(transcode, { file: audio.mp3 })第一个参数是任务名job name第二个参数是任务携带的数据负载。这里的任务名transcode必须与消费者端Process声明的任务名一致才能被正确路由消费。路由Controller(audio)Post(transcode)组合出POST /audio/transcode接口处理函数为async并await入队结果保证响应与入队完成同步。消费者Processor 与 Process 异步消费任务audio.processor.ts 是队列的消费者端import { Process, Processor } from nestjs/bull; import { Logger } from nestjs/common; import { Job } from bull; Processor(audio) export class AudioProcessor { private readonly logger new Logger(AudioProcessor.name); Process(transcode) handleTranscode(job: Job) { this.logger.debug(Start transcoding...); this.logger.debug(job.data); this.logger.debug(Transcoding completed); } }Processor(audio)类级装饰器声明该类是audio队列的消费者nestjs/bull会在应用启动时自动把该类实例挂载到对应队列上开始监听。Process(transcode)方法级装饰器将handleTranscode注册为transcode任务的处理器。处理器接收 Bull 的Job对象通过job.data读取入队时携带的数据本例为{ file: audio.mp3 }。若省略任务名即Process()则该方法会处理该队列中的全部任务。示例消费端仅用Logger.debug打印开始转码→任务数据→转码完成三段日志来模拟真实业务在实际项目中把这段日志替换为 ffmpeg 调用等重活即可处理完成即代表任务被成功消费。至此示例的完整调用链是POST /audio/transcode ↓ queue.add(transcode, { file: audio.mp3 }) Bull 队列Redis 中转 ↓ Process(transcode) 路由 AudioProcessor.handleTranscode(job) → 模拟转码日志运行应用三种启动模式Redis 就绪且依赖安装完成后即可按 README 的 Running the app 部分启动应用# development开发模式 $ npm run start # watch mode监听文件变更自动重启 $ npm run start:dev # production mode生产模式编译产物直启 $ npm run start:prod从 package.json 的 scripts 可以看到这三个命令的真实含义npm run start→nest startnpm run start:dev→nest start --watchnpm run start:prod→node dist/main即先构建、再以 Node 直接运行编译产物应用默认监听3000端口见 main.ts。启动后向POST http://localhost:3000/audio/transcode发送请求即可向队列投递一个转码任务随后在终端观察AudioProcessor打印的消费日志。也可在应用内配置REDIS_HOST/REDIS_PORT环境变量以连接非本机 Redis。测试验证单元测试与端到端测试示例为队列的生产端和消费端各提供了一套测试对应 README 的 Test 部分# unit tests单元测试 $ npm run test # e2e tests端到端测试 $ npm run test:e2e # test coverage覆盖率 $ npm run test:cov对应 scripts 分别为vitest run、vitest run --config ./vitest.config.e2e.mts与vitest run --coverage本示例当前使用 Vitest 而非 Jest仓库同时保留了 jest.json 供参考。生产者单元测试audio.controller.spec.ts通过getQueueToken(audio)注入 mock 队列验证transcode()方法以(transcode, { file: audio.mp3 })参数调用queue.add并校验调用次数与数据结构。消费者单元测试audio.processor.spec.ts以vi.spyOn(Logger.prototype, debug)监控日志输出传入伪造的Job对象验证处理器的三段日志顺序Start transcoding...→job.data→Transcoding completed以及连续处理多个任务时日志按任务数成倍增长。端到端测试audio.e2e-spec.ts基于supertest对真实 HTTP 服务发起请求验证POST /audio/transcode返回201任务成功入队连续 3 个并发请求均返回201队列可承受并发入队GET /audio/transcode返回404路由仅接受 POST 方法。这套测试既验证了入队接口的可用性也间接验证了队列模块在真实 NestJS 容器中的装配正确性。小结sample/26-queues是一个麻雀虽小、五脏俱全的队列集成范例用BullModule.forRoot建立 Redis 连接用BullModule.registerQueue声明队列用InjectQueue在生产端投递任务用Processor/Process在消费端异步处理并配套完整的单元测试与 e2e 测试。以此为基础你可以把示例中的日志模拟替换为真实的异步业务如转码、发信、数据清洗并进一步研究 Bull 的延迟任务、重试、优先级、并发与事件监听等进阶能力。赞分享后端Web框架【免费下载链接】nestA progressive Node.js framework for building efficient, scalable, and enterprise-grade server-side applications with TypeScript/JavaScript 项目地址https://gitcode.com/GitHub_Trending/ne/nest点击查看免费下载相关推荐探索 NestJS Bull强大的任务队列处理解决方案探索 NestJS Bull强大的任务队列处理解决方案 项目简介 是一个由 NestJS https://nestjs.com/ 提供支持的、基于 Bul消息队列后端Bull 队列完全指南基于 Redis 的 Node.js 分布式任务与消息队列实战Bull 队列完全指南基于 Redis 的 Node.js 分布式任务与消息队列实战 本文围绕开源仓库 bull一个基于 Redis 的 Node.js 任任务调度后端Bull 队列实战指南基于 Redis 的 Node.js 分布式任务队列核心机制与使用详解Bull 队列实战指南基于 Redis 的 Node.js 分布式任务队列核心机制与使用详解 Bull 是一个基于 Redis 的 Node.js 任务队列库任务调度后端上一篇SQLAlchemy MySQL 与 MariaDB 方言完全指南数据类型、全文检索、DML 构造与八大驱动下一篇UADK高级特性动态上下文管理与资源调度优化终极指南创作声明：本文部分内容由AI辅助生成（AIGC），仅供参考