BullMQ 专家
将以下提示词粘贴到你的 AI 对话框中:
请根据 https://skillhub.cn/install/skillhub.md,安装 @org-02qudk26/bullmq-specialist。
技能介绍
队列问题往往不在「队列库」本身
在 Node.js 服务里用 BullMQ 做异步任务时,常见痛点是:流量峰值把下游打挂、多步业务流程难以建模、凌晨任务卡在 active 或 Redis 连接抖动导致重复消费。多数故障追到底,要么是 Redis 配置与键空间 问题,要么是 载荷过大、并发无界、缺少失败出口 的应用设计问题。
技能如何协助你
本技能以「处理过生产环境数十亿任务」的视角,围绕 BullMQ 的核心能力展开:
bullmq-queues:可上线的队列初始化与连接、默认 Job 选项- 延迟与定时:
delayed-jobs、repeatable-jobs、job-scheduling - 流量与优先级:
job-priorities、rate-limiting-jobs - 可观测与 Worker:
job-events、worker-patterns、并发与吞吐权衡 - 复杂流程:
flow-producers、job-dependencies下的父子任务与多步编排
对话中可以按场景走 基础队列搭建、延迟/定时任务、任务流与依赖 等模式,并明确提醒反模式:巨型任务载荷、没有死信队列(或等价失败处理)、无限提高 Worker 并发。
适用边界
技能聚焦 BullMQ + Redis 侧的队列语义与实现细节,不替代你对业务幂等、数据库事务、邮件/AI 流水线等域内逻辑的设计。与 Redis、后端架构、邮件系统、工作流自动化类技能组合时,边界会更清晰。
使用场景
- Next.js 或 Express 服务要把发邮件、生成报表从 HTTP 请求里拆出去,需要可上线的 BullMQ 队列与 Worker 配置
- 生产环境出现任务长期停在 active、重复执行或吞吐上不去,需要结合 job-events 与 Redis 侧排查卡住原因
- 业务要求每天固定时间跑批或「延迟 N 分钟再处理」,要用 repeatable-jobs 与 delayed-jobs 设计调度策略
- 订单/审批等多步流程要用 flow-producers 建父子任务,并处理某一步失败时的依赖与重试边界
适合人员
- 维护 Node.js 后端、负责 BullMQ Worker 部署与 Redis 连接的工程师,希望队列默认项和并发策略能扛流量峰值
- 负责异步流水线(Webhook 回调、AI 批处理)的开发者,要把多步任务拆成可观测的父子 Job 并控制速率
- 从 Bull 迁移到 BullMQ 的团队技术负责人,需要梳理 delayed/repeatable、优先级与失败任务出口(含死信思路)
- 凌晨/on-call 处理队列堆积或 Redis 抖动的 SRE,需要按反模式清单核对载荷大小、并发上限与失败处理