SuperAPI AI 工具集

glide-mq

编程与开发

查看项目

更新于 10-15 19:51

技能介绍

用途:为使用 glide-mq 构建新消息队列系统提供开发指导,覆盖队列、worker、生产者、任务调度与工作流编排(flows、DAG、chains)等场景。当需要搭建新队列系统、编写生产者/消费者模式或查询 glide-mq API 与配置时可参考。

安装与依赖:使用 npm install glide-mq,需 Node.js 20+,以及 Valkey 7.0+ 或 Redis 7.0+。

连接:所有类使用 addresses 数组格式,例如 const connection = { addresses: [{ host: 'localhost', port: 6379 }] };支持 TLS、credentials 密码与 clusterMode。

主要能力:Queue 负责入队与管理任务(add、addBulk、addAndWait、pause、resume、drain);Worker 处理任务(构造函数为 name、processor、opts,事件包括 completed、failed、active);Producer 为轻量入队(适合 serverless);FlowProducer 处理父子任务树与 DAG;QueueEvents 监控事件;Broadcast 为持久化发布/订阅。任务选项支持 attempts、backoff(exponential 或 fixed)、delay、priority、ttl、jobId 去重;压缩需在 Queue 构造函数中设置。Worker 选项含 concurrency、lockDuration、stalledInterval,默认分别为 1、30000、30000 毫秒。

调度与测试:可用 queue.upsertJobScheduler 配置 cron 表达式与时区;测试可用 glide-mq/testing 的 TestQueue 与 TestWorker,无需 Valkey/Redis。

注意:连接格式不是 { host, port } 直连;priority 数字越小优先级越高(0 最高);key 使用 hash-tag 以支持集群;每次操作一次 FCALL。完整 API 与高级用法见 node_modules/glide-mq/skills/ 或官方文档站点。