用途:用于机器人各组件或服务之间的解耦异步通信,构建基于队列的消息工作流。主要能力包括:队列驱动的一次性启动注册、主题命名与负载契约定义、发送与接收处理器实现及错误策略、幂等消费行为保障。使用方式:配合 @commandkit/queue 使用;按预期文件结构组织,包括队列引导模块(如 src/bootstrap/queue.ts)、位于命令/事件/服务层中的生产者与消费者,以及共享的负载类型模块以形成类型化契约;执行流程为先注册队列驱动、再定义主题与负载契约、实现带错误策略的发送/接收处理器,并确保消费幂等。文档参考涵盖文件系统结构、基于 Redis PubSub 的驱动设置、发布/订阅用法及类型化事件契约。限制与护栏:避免无结构负载;避免在没有重试与幂等规划的情况下使用副作用繁重的消费者;本技能当前没有辅助工具脚本。
commandkit-queue
智能体与模型
更新于 10-16 01:35