Azure 服务总线队列如何在 HTTPs 模式下向客户端传递消息
How Azure Service Bus Queue delivers messages to client on HTTPs mode
我们在我们的应用程序中为 Azure 服务总线队列使用 HTTPs 模式。
ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https;
但我们不确定 Azure 服务总线如何以 HTTPs 模式传递消息,如果服务总线客户端使用轮询,轮询到 Azure 服务总线队列的频率。
我们使用包:
Microsoft.ServiceBus;
Microsoft.ServiceBus.Messaging;
我们似乎没有这方面的任何官方文档。但是,大多数服务总线客户端使用长轮询,这意味着它们打开到服务总线的连接并保持打开状态,直到它们接收到数据。如果收到消息,客户端将处理该消息并打开一个新连接。如果连接超时,客户端将在增量退避期后打开一个新连接。 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();
}
}
我们在我们的应用程序中为 Azure 服务总线队列使用 HTTPs 模式。
ServiceBusEnvironment.SystemConnectivity.Mode = ConnectivityMode.Https;
但我们不确定 Azure 服务总线如何以 HTTPs 模式传递消息,如果服务总线客户端使用轮询,轮询到 Azure 服务总线队列的频率。
我们使用包:
Microsoft.ServiceBus;
Microsoft.ServiceBus.Messaging;
我们似乎没有这方面的任何官方文档。但是,大多数服务总线客户端使用长轮询,这意味着它们打开到服务总线的连接并保持打开状态,直到它们接收到数据。如果收到消息,客户端将处理该消息并打开一个新连接。如果连接超时,客户端将在增量退避期后打开一个新连接。 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();
}
}