从 azure 服务总线接收消息

Question

可以使用这两种方法之一在 azure 服务总线中接收消息..

queueClient.BeginReceiveBatch 或 messageReceiver.ReceiveBatchAsync

这两种方法在速度方面或其他方面有什么区别。

谢谢

Answer 1

如果您不需要批量接收功能，我更喜欢在队列客户端的 OnMessage 事件上连接回调的方法。我们有一些相当高的吞吐量服务依赖于这种消息处理模式，没有任何问题（每天超过 100 万条消息）

我喜欢你最终得到更少、更简单的代码，并且可以轻松控制要并行处理的消息数量、接收模式（查看和锁定，与接收和删除）等选项

this documentation 中有一个示例：

string connectionString =
  CloudConfigurationManager.GetSetting("Microsoft.ServiceBus.ConnectionString");
QueueClient Client =
  QueueClient.CreateFromConnectionString(connectionString, "TestQueue");

// Configure the callback options
OnMessageOptions options = new OnMessageOptions();
options.AutoComplete = false;
options.AutoRenewTimeout = TimeSpan.FromMinutes(1);

// Callback to handle received messages
Client.OnMessage((message) =>
{
    try
    {
        // Process message from queue
        Console.WriteLine("Body: " + message.GetBody<string>());
        Console.WriteLine("MessageID: " + message.MessageId);
        Console.WriteLine("Test Property: " +
        message.Properties["TestProperty"]);

        // Remove message from queue
        message.Complete();
    }
        catch (Exception)
    {
        // Indicates a problem, unlock message in queue
        message.Abandon();
    }
};