监听队列（事件驱动无轮询）服务总线/存储队列

Question

我试图弄清楚如何监听队列中的事件（尤其是入队事件）。

假设我有一个控制台应用程序和一个服务总线队列/主题，我如何连接到队列并等待新消息？

我试图在没有While(true) 和持续轮询的情况下实现这一点，我试图以一种非常倾听的方式来做更多的事情，比如保持连接到队列的套接字。

我不想使用轮询的原因是我知道它会用请求淹没服务器，我需要一个可以在大量负​​载下工作的解决方案。

谢谢。

为了问题的简单性，我举了一个非常基本的例子，但我的实际情况有点复杂：

我有一个 Web-API，它使用服务总线队列将需要处理的消息发送到工作角色。

我需要以某种方式知道 Worker 何时处理了消息。 我希望 Worker 向队列发送一条消息，提醒 Web API 已处理该消息，但现在我需要让 Web-API “坐下”并等待 Worker 回复，这导致我的问题：

如何在不进行轮询的情况下不断收听队列（因为有很多实例会进行池化，并且会创建很多可能最好避免的请求。

Answer 1

使用 Azure WebJobs SDK - 它有触发器来监控队列和 blob，代码如下：

public static void Main()
{
    JobHost host = new JobHost();
    host.RunAndBlock();
}

public static void ProcessQueueMessage([QueueTrigger("webjobsqueue")] string inputText, 
    [Blob("containername/blobname")]TextWriter writer)
{
    writer.WriteLine(inputText);
}

What is the Azure WebJobs SDK 有一个很棒的教程。

Answer 2

我最终使用QueueClient.ReceiveAsync 来等待带有Timespan 参数的消息。

            BrokeredMessage msg = subClient.ReceiveAsync(TimeSpan.FromMinutes(3));

这是一篇很好的文章，它解释了 Azure 服务总线 link 和 Service Bus best practice 的大部分内容。