c# - 使用一个或多个标准 FIFO 队列实现延迟队列

Question

延迟队列是一种队列，其中每条消息都有与其关联的延迟时间，并且只有在延迟到期时才能获取消息。队列的头部是过去延迟最远到期的消息。如果没有延迟过期，则没有头，出队将返回 null。

实际上，我正在使用 Azure 编写云应用程序，在 Azure 中只有 FIFO 队列可用，而不是优先级/延迟队列。所以我来这里寻找是否有人可以给我一些指示，让我可以从正确的方向开始。我用 google 搜索了很多，但只找到了 Java 中的延迟队列实现，并且没有关于一般延迟队列的标准教程/研究论文。

编辑:

我有什么代码？
实际上，我必须首先设计这个东西并将其呈现给我的经理，一旦我们完成设计，那么只有我可以开始编码。

有关场景的更多详细信息
它是一个基于主/从模型的分布式应用程序。主服务器生成消息并将它们放入 Azure 服务总线队列中，并且有多个从服务器(在多台计算机上运行)从队列中读取并处理它们。如果万一主设备发生故障，那么其中一个从设备将充当主设备并开始生成消息。我不想在主服务器中存储任何状态信息，因为如果主服务器发生故障，所有状态信息也会随之消失。

Answer 1

Windows Azure 队列消息有一个延迟(以秒为单位)，该延迟是您在将消息插入队列时指定的。在达到超时延迟之前，消息将不可见。请参阅this MSDN article查看 API 详细信息。

不可见超时也在各种语言 SDK 实现中实现。由于您使用的是 C#，因此 AddMessage() 调用如下所示。请注意，AddMessage()的第三个参数指定不可见超时:

        var acct = CloudStorageAccount.DevelopmentStorageAccount;
        var queueClient = acct.CreateCloudQueueClient();
        var queue = queueClient.GetQueueReference("myqueue");
        queue.CreateIfNotExist();

        var msg = new CloudQueueMessage("test message");
        queue.AddMessage(msg, TimeSpan.FromHours(2), TimeSpan.FromMinutes(30));