Azure 服务总线 - 多个服务的循环主题

Question

这是场景：

Publisher #1 ═══╗             ╔═══ Round Robin ═══╦═══ Subscriber #1 (Service 1)
                ║             ║                   ╚═══ Subscriber #2 (Service 1)
                ╠═══ Topic ═══╣
                ║             ║                   ╔═══ Subscriber #3 (Service 2)
Publisher #2 ═══╝             ╚═══ Round Robin ═══╩═══ Subscriber #4 (Service 2)

我有一条消息需要由多个订阅者处理，但每个服务只有一个（每个服务将运行多个实例）。

消息#1，需要由订阅者#1 和#3 处理。消息#2，需要由订阅者#2 和#4 处理。消息 #3，订阅者 #1 和 #3 再次。基本上，每条消息都应该轮询订阅每条消息的每个负载平衡服务，并按每个正在连接的服务分组。在不创建多个主题的情况下是否可以这样做？

即使不是轮询，我也想尽最大努力跨多个服务进行负载平衡。这可能吗？

Answer 1

1。主题

主题是一种发布/分发机制，每个订阅（订阅者）将发送一次消息。

主题订阅类似于接收发送到主题的消息副本的虚拟队列。从订阅接收消息的方式与从队列接收消息的方式相同...

订阅支持本节前面关于队列的相同模式：竞争消费者、时间解耦、负载均衡和负载平衡。

来源：MSDN Article

您需要在竞争消费者（服务实例）之间重复使用主题订阅来实现您的场景。

Publisher #1 ═══╗             ╔═══ Subscription 1 ═══╦═══ Service 1-instance 1
                ║             ║                      ╚═══ Service 1-instance 2
                ╠═══ Topic ═══╣
                ║             ║                      ╔═══ Service 2-instance 1
Publisher #2 ═══╝             ╚═══ Subscription 2 ═══╩═══ Service 2-instance 2

A.创建主题订阅

string connectionString = "<Secret>"
var namespaceManager =
    NamespaceManager.CreateFromConnectionString(connectionString);

if (!namespaceManager.SubscriptionExists("TestTopic", "Inventory"))
{
    namespaceManager.CreateSubscription("TestTopic", "Inventory");
}

B.收听现有订阅

MessagingFactory factory = MessagingFactory.Create(uri, tokenProvider);

MessageReceiver receiver = factory.CreateMessageReceiver("TestTopic/subscriptions/Inventory");

2。队列

使用多个Queues 也可以适合您的特定场景。每个具有多个竞争消费者（实例）的Queue 只会将消息传递给第一个请求并成功处理它的客户端。

然后设计变成：

Publisher #1 ═══╗         ╔═══ Service 1 Queue ═══╦═══ Subscriber #1 (Service 1)
                ║         ║                       ╚═══ Subscriber #2 (Service 1)
                ╠═══ASB═══╣
                ║         ║                       ╔═══ Subscriber #3 (Service 2)
Publisher #2 ═══╝         ╚═══ Service 2 Queue ═══╩═══ Subscriber #4 (Service 2)

Answer 2

我想尽最大努力在多个服务之间实现负载平衡。这可能吗？

根据您的描述，您似乎正在尝试在任何给定服务的多个实例之间进行负载平衡，而不是单个服务。您可以通过 ASB 支持的竞争性消费者模式开箱即用。并不是你真正需要为之工作的。

我要解决的问题是，我只希望每个服务中的 1 个消费者在单个主题上消费消息。 ASB 可以做到这一点吗？

是的，这是可能的。如果您有一个按服务（而非实例）订阅的共享主题，并且包含始终评估为真的规则，SqlFilter (1 = 1)。然后每个订阅者都会得到该消息的副本。本质上，您会将消息广播到您的所有服务。由于竞争消费者，每个服务只有一个实例会收到该消息。

要针对特定​​服务，您需要创建一个额外的规则来过滤掉有关属性（标准属性或自定义属性）的消息。例如，它可以是服务名称。

如果您不想专注于微服务的中间件，您可以看看为您做这件事的框架。这样的框架通常也倾向于提供额外的特性。例如，看看NServiceBus 或 MassTransit。

完全免责声明 - 我正在研究 NServiceBus 及其 ASB 传输。