0

在 Windows Azure Worker 角色中处理“紧急”消息的最佳方式是什么？

我有一个工人角色开始，做一个无限的while(true)循环，在这个循环中：

  1. 读取队列是否有消息
  2. 处理它们并删除它们
  3. 如果没有更多消息进入睡眠，首先使用 Thread.Sleep(interval) 进行较小的间隔（10 秒），然后逐渐将睡眠间隔增加到 2 分钟
  4. 如果队列中出现一条消息，它将睡眠间隔重置为 0 并返回到第一步

问题是，如果工作人员正在睡眠 2 分钟并且队列中出现一条消息，我想唤醒工作人员而不是等待剩余时间。

有没有办法获取工作者角色的实例并告诉它唤醒？我想在数据库中写一些东西，但是我遇到了同样的问题，即使我有一个这样做的角色，我将如何唤醒另一个已经在睡觉的工作角色？

4

2 回答 2

3

这是使用 Windows Azure 存储队列的缺点之一。您必须在成本和延迟之间做出选择。如果您想优化成本，您将实施退避策略（就像您所做的那样），但这意味着这将影响您的消息何时被处理（增加延迟）。

在您的情况下，评估 Windows Azure 服务总线队列可能会很有趣（在此处了解差异）。使用服务总线队列的优点是它支持长轮询，这意味着它将保持与服务器的连接，直到消息到达（或超时）。

这是您通常会编写的一些示例代码（您仍然需要管理异常等...）：

QueueClient queueClient = factory.CreateQueueClient("myqueue");
while (true)
{
    BrokeredMessage msg = queueClient.Receive(TimeSpan.FromSeconds(45));
    if (msg != null)
    {
        var request = msg.GetBody<CreateOrderMessage>();
        // Do something
        msg.Complete();
    }
}

以下是一些可以帮助您入门的好资源：

于 2012-07-29T11:18:20.647 回答
2

只是睡得少一点。你为什么要睡两分钟而不是一秒钟？从一个实例每秒轮询一次队列的交易费用约为每月 0.25 美元。

于 2012-07-29T15:58:52.650 回答