Cloudflare Queues 消息缓冲

Q: 什么是Cloudflare Queues 消息缓冲？它解决什么问题？

Workers 的持久消息队列，支持批处理、重试和死信队列异步处理。 它可帮助开发者在不自建基础设施的前提下完成部署、存储与扩展，是云服务选型的核心参考。

Q: Cloudflare Queues 消息缓冲 的最佳实践有哪些？

Cloudflare Queues 消息缓冲 的最佳实践包括：始终设死信队列 — 防止毒消息阻塞消费者；消费者幂等 — 用消息 ID + KV 去重，安全处理重投递；积极批处理 — max_batch_size=100 降低每消息开销 10 倍。其中首条「始终设死信队列 — 防止毒消息阻塞消费者」应作为团队默认规范写入 IaC 模板。

Workers 的持久消息队列，支持批处理、重试和死信队列异步处理。

Cloudflare进阶

为什么

Queues 解耦生产者与消费者，通过缓冲处理流量尖峰，保证至少一次投递和自动重试。免费：100 万操作/月，无空闲成本。

Cloudflare 网络覆盖 125+ 国家的 330+ 城市，服务 20% 的互联网流量。Workers 冷启动为 0ms（基于 isolate），免费套餐覆盖每天 10 万请求。

何时使用

用于发邮件、webhook 扇出、图片处理和限流平滑。避免跨分区严格排序或需恰好一次语义。

如何做

1. 创建队列 — wrangler queues create my-queue 2. 生产者 — [[queues.producers]] binding="MYQ" queue="my-queue" 3. 消费者 — [[queues.consumers]] queue="my-queue" max_batch_size=10 max_retries=3 4. 发送 — await env.MYQ.send({ body: JSON.stringify(payload) }) 5. 批量发送 — env.MYQ.sendBatch([{body:"a"},{body:"b"}]) 6. 消费 — export default { async queue(batch, env) { for (const msg of batch.messages) {...} } } 7. 死信 — 消费者设 dead_letter_queue="dlq"，失败消息进 DLQ

示例

// wrangler.toml [[queues.producers]] binding = "EMAILQ" queue = "email-queue" [[queues.consumers]] queue = "email-queue" max_batch_size = 10 max_retries = 3 dead_letter_queue = "email-dlq" // 生产者（HTTP handler 入队） export default { async fetch(request: Request, env: Env) { const { to, subject } = await request.json(); await env.EMAILQ.send({ body: JSON.stringify({ to, subject }) }); return Response.json({ queued: true }); }, // 消费者（批处理） async queue(batch: MessageBatch, env: Env) { for (const msg of batch.messages) { try { const { to, subject } = JSON.parse(msg.body); await sendEmail(env, to, subject); msg.ack(); } catch (e) { msg.retry(); // 重试至 max_retries，然后进 DLQ } } }, };

常见问题

⚠至少一次非恰好一次 — 消费者必须幂等，按消息 ID 去重
⚠max_batch_timeout 太短 — 批处理等满大小或超时，按延迟 vs 吞吐调整
⚠毒消息循环 — 无 DLQ 时重试耗尽，消息阻塞队列

最佳实践

✓始终设死信队列 — 防止毒消息阻塞消费者
✓消费者幂等 — 用消息 ID + KV 去重，安全处理重投递
✓积极批处理 — max_batch_size=100 降低每消息开销 10 倍

常见问题解答

什么是Cloudflare Queues 消息缓冲？它解决什么问题？

Workers 的持久消息队列，支持批处理、重试和死信队列异步处理。它可帮助开发者在不自建基础设施的前提下完成部署、存储与扩展，是云服务选型的核心参考。

如何在 5 分钟内上手Cloudflare Queues 消息缓冲？

两步即可跑通：① 创建队列 — wrangler queues create my-queue；② 生产者 — [[queues.producers]] binding="MYQ" queue="my-queue"。建议先用免费套餐验证流程，再接入生产环境。