你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。

PartitionReceiver.ReceiveAsync 方法

定义

命名空间:

Microsoft.Azure.EventHubs

程序集:

Microsoft.Azure.EventHubs.dll

包:

Microsoft.Azure.EventHubs v4.3.2

重载

ReceiveAsync(Int32)	从 EventHub 分区接收一批 EventData的
ReceiveAsync(Int32, TimeSpan)	通过允许每个单独调用的等待时间，从 EventHub 分区接收一批 EventData。

ReceiveAsync(Int32)

Source:

PartitionReceiver.cs

从 EventHub 分区接收一批 EventData的

public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Microsoft.Azure.EventHubs.EventData>> ReceiveAsync (int maxMessageCount);

member this.ReceiveAsync : int -> System.Threading.Tasks.Task<seq<Microsoft.Azure.EventHubs.EventData>>

Public Function ReceiveAsync (maxMessageCount As Integer) As Task(Of IEnumerable(Of EventData))

参数

maxMessageCount

Int32

返回

Task<IEnumerable<EventData>>

一个任务，它将从创建此接收器的分区中生成一批 EventData 。 如果没有 EventData，则返回“null”。

示例

示例代码：

EventHubClient client = EventHubClient.Create("__connectionString__");
PartitionReceiver receiver = client.CreateReceiver("ConsumerGroup1", "1");
IEnumerable<EventData> receivedEvents = await receiver.ReceiveAsync(BatchSize);

while (true)
{
    int batchSize = 0;
    if (receivedEvents != null)
    {
        foreach (EventData receivedEvent in receivedEvents)
        {
            Console.WriteLine("Message Payload: {0}", Encoding.UTF8.GetString(receivedEvent.Body));
            Console.WriteLine("Offset: {0}, SeqNo: {1}, EnqueueTime: {2}", 
                receivedEvent.SystemProperties.Offset, 
                receivedEvent.SystemProperties.SequenceNumber, 
                receivedEvent.SystemProperties.EnqueuedTime);
            batchSize++;
        }
    }

    Console.WriteLine("ReceivedBatch Size: {0}", batchSize);
    receivedEvents = await receiver.ReceiveAsync();
}

ReceiveAsync(Int32, TimeSpan)

Source:

PartitionReceiver.cs

通过允许每个单独调用的等待时间，从 EventHub 分区接收一批 EventData。

public System.Threading.Tasks.Task<System.Collections.Generic.IEnumerable<Microsoft.Azure.EventHubs.EventData>> ReceiveAsync (int maxMessageCount, TimeSpan waitTime);

member this.ReceiveAsync : int * TimeSpan -> System.Threading.Tasks.Task<seq<Microsoft.Azure.EventHubs.EventData>>

Public Function ReceiveAsync (maxMessageCount As Integer, waitTime As TimeSpan) As Task(Of IEnumerable(Of EventData))

参数

maxMessageCount

Int32

waitTime

TimeSpan

返回

Task<IEnumerable<EventData>>

一个任务，它将从创建此接收器的分区中生成一批 EventData 。 如果没有 EventData，则返回“null”。