在多个进程中使用来自Azure服务总线的消息

Question

我正在开发一个基于Azure服务总线的系统，通过一个API和后台服务通过一个主题对大量消息进行异步处理，用于快速启动和忘记。在这个问题的上下文中，主题有一个单一的订阅，为什么它本来可以是一个队列。出于其他原因，我想把这作为一个话题保留下来。

我最近使用WindowsAzure.ServiceBus包将代码从.NET framework应用程序迁移到使用Microsoft.Azure.ServiceBus包的.NET核心包。为了处理大量消息，我使用了MessageReceiver类，如下所示：

var connString = "...";
var subscriptionPath = EntityNameHelper.FormatSubscriptionPath("topic", "subscription");
var messageReceiver = new MessageReceiver(connString, subscriptionPath);
while (...)
{
    var messages = await messageReceiver.ReceiveAsync(10, TimeSpan.FromSeconds(5));
    ...
}

为了简单起见，我隐藏了一系列细节。比如我的应用程序启动5个线程，并使用相同的MessageReceiver实例在每个线程中处理消息。

我通常有一个以上的应用程序实例运行，以分散在线程和进程中。我相信我们终于明白了我的问题。在迁移到.NET核心和新的NuGet包之后，我注意到其中只有一个应用程序在同时处理消息。当打开两个控制台窗口并在每个窗口中启动一个进程时，我可以看到窗口1中的app开始处理。Windows2中的应用程序不处理任何内容。若干秒后，windows 1中的应用程序停止处理，windows 2中的应用程序开始处理。过了一段时间，它又换回来了。交换机中没有真正的模式，但我的所有消息都被成功处理了。

messageReceiver中是否存在某种限制，允许最大的线程总数处理来自同一订阅的消息或类似的内容？

Answer 1

我不知道messageReceiver在线程数方面有什么限制。不过，新的库经过优化，利用了并发性，不需要线程（异步代码）。因此，从技术上讲，您可以使用一个线程运行，并具有多个并发接收任务。另一种方法是使用queueclient和subscriptionclient提供的消息处理程序，它们允许为轻松地处理多个消息指定并发，但它们允许每个并发回调接收一个消息（不批处理）。

代理在一次调用中向第一个竞争的消费者提供尽可能多的消息。如果没有足够的消息，那么所有的消息都将被提供给单个（或前几个）消费者。没有循环往复和公平分配。它确实如预期的那样工作。