Azure服务总线丢弃消息？

Question

我正在尝试在Azure中构建一个简单的WebAPI REST服务，后端有一个服务总线队列工作器。我可以从Web API向工作人员发送一条消息。然而，我试图发送更多的信息，只是为了看看一切是如何运作的。因此，我创建了一个简单的控制器，如下所示：

for (int i = 0; i < 100; i++)
{
    var msg = new BrokeredMessage("Ping");
    BioConnector.QueueConnector.OrdersQueueClient.Send(msg);
}

当我呼叫控制器时，我只收到工作人员接收到的大约1/2的消息。其余的似乎都被放弃了。

Answer 1

Azure服务总线提供持久的消息传递，因此您不会丢失任何消息。需要进一步调查的一些项目：1）是否有另一个工作人员角色实例正在从该队列中提取消息2）是否使用peek lock作为接收模式，因为这是保证至少一次传递的唯一方法。接收和删除模式不保证3）消息是否由于消息过期或超过最大传递计数而进入死信队列，也就是说，它们多次收到但未完成4）如果上述任何一项都不适用，则提出支持通知单，Azure产品团队可以调查这些症状，因为正如我提到的，这是一个持久的消息传递系统，因此不会“丢失”任何消息。

Answer 2

这是一个奇怪的问题。通过随机遍历“尝试事物”，我最终改变了队列的字符串名称，然后一切又开始工作了。除了队列的名称，我没有更改任何东西——根本没有更改任何配置参数。

Azure上的特定队列似乎有问题。

Answer 3

我在这里只写了一半关于测试的代码。我已经试过了

>

创建一个新的C#控制台项目

添加对Microsoft的引用。ServiceBus程序集位于C:\Program Files\Microsoft SDK\Windows Azure中。NET SDK\2012-06\ref\Microsoft。服务总线。dll

在应用程序中。配置，使用您自己提供的值将其更改为：

<appSettings>
    <add key="Microsoft.ServiceBus.ConnectionString" value="Endpoint=sb://blahblah.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=pDk0b....=" />
</appSettings>

使用指令添加以下内容：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Xml;
using System.Xml.Linq;
using Microsoft.ServiceBus;
using Microsoft.ServiceBus.Messaging;
using System.Configuration;
using System.Threading;

将代码方法更改为以下内容：

class Program
{
    static void Main(string[] args)
    {
        string connectionString = ConfigurationSettings.AppSettings["Microsoft.ServiceBus.ConnectionString"];
        var namespaceManager = NamespaceManager.CreateFromConnectionString(connectionString);
        QueueDescription queueDesc = new QueueDescription("TestQueue");
        if (!namespaceManager.QueueExists(queueDesc.Path))
        {
            namespaceManager.CreateQueue(queueDesc);
        }
        QueueClient topicClient = QueueClient.CreateFromConnectionString(connectionString, queueDesc.Path);
        int sentMsgCount = 0;
        int recdMsgCount = 0;

        for (int i = 0; i < 100; i++)
        {
            BrokeredMessage msg = new BrokeredMessage("Test message " + i);
            topicClient.Send(msg);
            sentMsgCount++;
            Console.WriteLine("Sent Message: " + msg);
        }

        QueueClient subClient = QueueClient.CreateFromConnectionString(connectionString, queueDesc.Path);

        bool moreMessages = true;
        while (moreMessages)
        {
            BrokeredMessage recdMsg = subClient.Receive(TimeSpan.FromSeconds(3));
            if (recdMsg != null)
            {
                Console.WriteLine("Received Message: " + recdMsg);
                recdMsgCount++;
                recdMsg.Complete();
            }
            else
            {
                moreMessages = false;
            }
        }
        Console.WriteLine("# of sent msgs: " + sentMsgCount + ", # of rec'd msgs: " + recdMsgCount);
        Console.Read();
    }
}