用途:在 Cloudflare Workers 中构建可靠的异步消息处理,用于卸载后台任务、批量操作、解耦生产者与消费者、控制上游 API 请求速率、捕获失败消息。
主要能力:通过 env.QUEUE_BINDING.send() 发送单条消息,sendBatch() 批量发送;用 async queue(batch, env) 定义消费者并读取 batch.messages。消费默认自动确认,抛出错误即触发重试;可配置 dead_letter_queue、retry_delay、max_retries、max_batch_size、max_batch_timeout 等。支持整批或逐条处理、部分失败重入队、死信队列与日志留存。消息上限 128KB,单批最多 100 条,配置文件与类型接口示例见官方资料。
使用方式:在 wrangler.jsonc 中同时配置 producers 与 consumers,绑定后在 Worker 中发送和消费。
限制与注意:消息超过约 100KB 建议存 R2/KV 只传引用;热点路径谨慎 await send();DLQ 未配置时重试耗尽后消息被丢弃。其他平台、价格、配额等暂未提供。