6

我曾经使用 RabbitMQ 作为消息传递平台，但我从来没有遇到过任何问题 - 不幸的是，我们最近将我们的基础架构转移到了 Azure，他们不提供 RabbitMQ 服务器，所以我考虑尝试服务总线扩展。

我有一个作家和多个读者。目前，每个读者将阅读不同的消息（消息竞争模式 - 例如有利于负载平衡）。

我想要的是，所有读者都得到相同的信息并自己处理。

读者：

string connectionKey = "....";
        this.client = QueueClient.CreateFromConnectionString(connectionKey, "dev");
        this.client.OnMessage((message) =>
        {
            try
            {
                Console.WriteLine("Message received: " + message.GetBody<string>());
                Console.WriteLine("Message ID: " + message.MessageId);
              //  message.Complete();
            }
            catch (Exception e)
            {
                Console.WriteLine("Exception " + e.Message);
            }
        });

笔者：

Console.WriteLine("Sending message " + message);
        BrokeredMessage msg = new BrokeredMessage(message);
        this.client.Send(msg);

我一直在寻找解决方案两个小时，但找不到任何东西。在 RabbitMQ 中，这将是默认行为。

图片显示了我拥有的东西与我需要的东西的模式

4

1 回答 1

6

Azure 服务总线支持多种范式，其中之一称为“主题”：

如何使用服务总线主题和订阅

与服务总线队列相比，其中每条消息都由单个消费者处理，主题和订阅使用发布/订阅模式提供“一对多”的通信形式。

上面的链接演示了核心主题概念以及代码示例。

于 2016-05-21T20:24:00.740 回答