Azure服务总线队列如何在HTTPs模式下向客户端交付消息

Question

我们在应用程序中对Azure服务总线队列使用HTTPs模式。

ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https;

但我们不确定Azure服务总线如何在HTTP模式下交付消息，如果服务总线客户端使用轮询，则轮询到Azure服务总线队列的频率。

我们使用以下软件包：

Microsoft.ServiceBus;
Microsoft.ServiceBus.Messaging;

Answer 1

我们似乎没有这方面的任何官方文件。然而，大多数服务总线客户机使用长轮询，这意味着他们打开到服务总线的连接，并将其保持打开状态，直到收到数据为止。如果收到消息，客户端将处理该消息并打开新连接。如果连接超时，客户机将在增量退避期后打开新连接。根据产品团队的说法，超时时间设置为30秒。

您可以使用这个测试程序来查看消息发送到队列后需要多长时间才能收到消息。它目前设置为一次运行一条消息。通过使用批处理，总吞吐量可以比本示例高得多。

在我的机器上，消息通常在放入队列后的100毫秒内被检索。如果我将睡眠时间设置为一个较大的间隔，那么检索将花费稍长的时间，因此增量后退是有效的。如果音量较低，则可能需要稍长的时间才能拾取消息。

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();
        }
    }