azure - ReadEventsAsync EventHub 不会停止

Question

我正在 Azure 事件中心存储一些应用程序生成的消息，这些消息是由 Web 应用程序生成的，我想在 Rest API 调用中从 Azure 事件中心检索这些消息，以在 Web 应用程序中显示这些消息。

Issue

当我尝试使用以下代码从 Azure 事件中心读取消息时

var messages = new List<MessagingModel>();

            string consumerGroup = EventHubConsumerClient.DefaultConsumerGroupName;

            await using (var consumerClient = new EventHubConsumerClient(consumerGroup, eventHubConnectionString, eventHubName))
            {
                await foreach (var partitionEvent in consumerClient.ReadEventsAsync())
                {
                    string json = Encoding.UTF8.GetString(partitionEvent.Data.Body.ToArray());
                    var message = JsonConvert.DeserializeObject<MessagingModel>(json);
                    Console.WriteLine(json);
                }

                await consumerClient.CloseAsync();
            }

            return messages;

控件永远不会出来，这不是我们想要的，我还观察到，当新消息发送到事件中心时，控件返回处理该消息，然后等待下一条消息出现.

我只想阅读消息列表。

Answer 1

当没有更多事件可以接收时，您可以中断循环。检查下面的示例。

https://github.com/Azure/azure-sdk-for-net/blob/main/sdk/eventhub/Azure.Messaging.EventHubs/samples/Sample05_ReadingEvents.md#read-events-from-all-partitions-with-a-maximum-wait-time