Azure 服务总线：ReceiveMessagesAsync returns 只是一个子集

Question

我编写了一段代码，从 Azure 服务总线队列中一次性读取 1000 条消息。我阅读了以下行的消息：await receiver.ReceiveMessagesAsync(1000); 但只收到了一部分消息。

我从示例中获取了代码：https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/servicebus/Azure.Messaging.ServiceBus/tests/Samples/Sample01_HelloWorld.cs，SendAndReceiveMessageSafeBatch() 方法

这是我的代码：

public class Program
{
    static void Main(string[] args)
    {
        SendAndReceiveMessage().GetAwaiter().GetResult();
    }

    public static async Task SendAndReceiveMessage()
    {
        var connectionString = "myconnectionstring";
        var queueName = "myqueue";

        // since ServiceBusClient implements IAsyncDisposable we create it with "await using"
        await using var client = new ServiceBusClient(connectionString);

        // create the sender
        var sender = client.CreateSender(queueName);

        IList<ServiceBusMessage> messages = new List<ServiceBusMessage>();
        for (var i = 0; i < 1000; i++)
        {
            messages.Add(new ServiceBusMessage($"Message {i}"));
        }

        // send the messages
        await sender.SendMessagesAsync(messages);

        // create a receiver that we can use to receive the messages
        var options = new ServiceBusReceiverOptions()
        {
            ReceiveMode = ServiceBusReceiveMode.ReceiveAndDelete
        };

        ServiceBusReceiver receiver = client.CreateReceiver(queueName, options);

        // the received message is a different type as it contains some service set properties
        IReadOnlyList<ServiceBusReceivedMessage> receivedMessages = await receiver.ReceiveMessagesAsync(1000);

        Console.WriteLine($"Received {receivedMessages.Count} from the queue {queueName}");

        foreach (ServiceBusReceivedMessage receivedMessage in receivedMessages)
        {
            var body = receivedMessage.Body.ToString();
            Console.WriteLine(body);
        }

        Console.WriteLine("END");
        Console.ReadLine();
    }
}

对于如何一次性阅读所有 1000 条消息，您有什么建议吗？

Answer 1

这是 Azure 服务总线的预期行为。要接收的消息数，maxMessages 是无法保证的最大数量。

Azure 服务总线：ReceiveMessagesAsync returns 只是一个子集

Azure Service Bus: ReceiveMessagesAsync returns only a subset

.net

c#

azure

async-await

azureservicebus