Queues

Cloudflare Queues 是一個「訊息佇列（message queue）」：一條可靠的排隊線，一個 Worker 把訊息放進去，另一個 Worker 之後再取出來處理。它保證送達，所以就算接收方很忙、或短暫出錯，訊息也不會弄丟。

「訊息（message）」就是一小塊資料——例如「寄歡迎信給使用者 123」或「把這張剛上傳的照片縮圖」。與其讓使用者乾等你做完那件慢事，你把訊息丟進佇列、馬上回應，慢工作就在背景進行。

如果你的 Worker 想在「一次請求」裡把所有事做完，慢任務會讓使用者乾等，而且一出錯整個工作就沒了。佇列把「接下工作」和「執行工作」拆開，讓你的 App 更快、也可靠許多。

只要某件工作「可以晚點做、不用馬上做」，或是系統的某一部分需要安全地把工作交給另一部分，就用 Queues。

你用 Wrangler 建立一個佇列，然後把一個 Worker 設成 producer（生產者，負責送訊息），把另一個 handler 設成 consumer（消費者，負責處理）。同一個 Worker 也可以同時兼任兩者。

1. 建立佇列

   用一個名稱建立新佇列。訊息就會在這裡排隊等候。

   bashcontent_copy複製

   npx wrangler queues create my-queue

2. 在設定檔加上綁定

   在 wrangler.jsonc 裡，把佇列宣告成 producer（讓 Worker 能送訊息進去）以及 consumer（讓 Worker 被叫來處理一批批訊息）。

   jsonccontent_copy複製

   {
     "queues": {
       "producers": [
         { "queue": "my-queue", "binding": "MY_QUEUE" }
       ],
       "consumers": [
         {
           "queue": "my-queue",
           "max_batch_size": 10,
           "max_batch_timeout": 5
         }
       ]
     }
   }

3. 部署

   發佈你的 Worker。用 wrangler tail 就能即時看到訊息被消費的過程。

   bashcontent_copy複製

   npx wrangler deploy
   npx wrangler tail

export default {
  // PRODUCER: runs on each HTTP request and sends a message
  async fetch(request, env, ctx) {
    await env.MY_QUEUE.send({
      url: request.url,
      time: Date.now(),
    });
    return new Response("Queued!");
  },

  // CONSUMER: runs in the background with a batch of messages
  async queue(batch, env, ctx) {
    for (const message of batch.messages) {
      console.log("Processing:", message.body);
      // ...do the slow work here...
      message.ack(); // mark this message as done
    }
  },
};

值得記住的限制

• 每個帳號最多 10,000 個佇列
• 最大訊息大小：128 KB
• 最大批次：100 則訊息（或合計 256 KB）
• 最長批次等待：60 秒
• 吞吐量：每個佇列最多 5,000 則訊息/秒
• 重試：最多 100 次；保留期可設定到最多 14 天