消息处理

使用 Cloudflare Queues 处理消息时，生产者（通常是一个 Worker）将消息发送到队列，再由消费者（另一个 Worker 或服务）从队列中消费这些消息。消费者逐条处理消息，执行数据转换、调用 API 或更新数据库等任务。Queues 保证至少一次投递（at-least-once delivery），即即使发生故障，每条消息也至少会被投递给消费者一次。消费者可以确认处理成功，从而将消息从队列中移除。