小编The*_*nda的帖子

C# 服务总线多个侦听器都收到相同的消息( BrokeredMessage)

我曾经使用 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);
            }
        });
Run Code Online (Sandbox Code Playgroud)

笔者:

Console.WriteLine("Sending message " + message);
        BrokeredMessage msg = new BrokeredMessage(message);
        this.client.Send(msg);
Run Code Online (Sandbox Code Playgroud)

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

图像显示了我所拥有的与我需要的模式

c# azure brokeredmessage

5
推荐指数
1
解决办法
6543
查看次数

标签 统计

azure ×1

brokeredmessage ×1

c# ×1