Azure Service Bus Queue如何在HTTPs模式下向客户端传递消息

Question

我们在应用程序中为Azure Service Bus Queue使用HTTPs模式。

ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https;

但是，如果Service Bus客户端使用轮询，则轮询Azure Service Bus队列的频率，我们不确定Azure Service Bus如何在HTTP模式下传递消息。

我们使用包：

Microsoft.ServiceBus;
Microsoft.ServiceBus.Messaging;

Answer 1

我们似乎没有任何关于此的官方文件。但是，大多数Service Bus客户端使用长轮询，这意味着它们打开与Service Bus的连接并保持打开直到它们接收数据。如果收到消息，客户端将处理该消息并打开新连接。如果连接超时，客户端将在增量退回期后打开新连接。 According to the product team，超时时间设置为30秒。

您可以使用此测试程序查看在将消息发送到队列后接收消息所需的时间。它目前设置为一次运行一条消息。通过使用批处理，总吞吐量可以远高于此示例。

在我的机器上，通常在放入队列的100毫秒内检索消息。如果我将sleepTime设置为更大的间隔，则检索将花费更长的时间，因此增量后退将生效。如果音量较低，则可能需要更长时间才能获取消息。

class Program
    {
        private static readonly string connectionString = "";
        private static readonly int sleepTime = 100;
       private static readonly int messageCount = 10;
        static void Main(string[] args)
        {
            ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https;

            var client = QueueClient.CreateFromConnectionString(connectionString, "testqueue");
            client.PrefetchCount = 1;
            var timeCheck = DateTime.UtcNow;

            client.OnMessage((message) =>
            {
                var timing = (DateTime.UtcNow - message.EnqueuedTimeUtc).TotalMilliseconds;
                Console.WriteLine($"{message.GetBody<string>()}: {timing} milliseconds between between send and receipt.");
            });

            for (int i = 0; i < messageCount; i++)
            {
                client.Send(new BrokeredMessage($"Message {i}"));
                Console.WriteLine($"Message {i} sent");
                Thread.Sleep(sleepTime);
            }

            Console.WriteLine("Test Complete");

            Console.ReadLine();
        }
    }