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

EventHubClient 类

定义

用于向事件中心发送和接收事件的定位点类。

public abstract class EventHubClient : Microsoft.ServiceBus.Messaging.ClientEntity
type EventHubClient = class
    inherit ClientEntity
Public MustInherit Class EventHubClient
Inherits ClientEntity
继承
EventHubClient

属性

DisableEntityLevelPerformanceCounters

获取或设置一个值,该值指示是否应在内存中收集实体级别性能计数器。 请注意,这仅影响实体级别计数器,并且始终收集命名空间级别计数器。

IsClosed

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
Path

获取事件中心的路径。

PrefetchCount

获取或设置任何接收操作将主动缓存的事件数。 默认情况下,如果当前实例是从工厂方法创建的,则此值继承自 MessagingFactory 。 否则,默认值为 10,000。

PrefetchSizeInBytes

获取或设置 (最大大小(以字节为单位),) 任何接收操作都将主动缓存。 每个事件数据的大小由 SerializedSizeInBytes 属性确定。

RetryPolicy

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
ThisLock

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)

方法

Abort()

对消息传送实体执行中止功能。

(继承自 ClientEntity)
Close()

向服务总线发送清理消息,以指示实体的使用完成。

(继承自 ClientEntity)
CloseAsync()

以异步方式将清理消息发送到服务总线,以指示实体的使用完成。

(继承自 ClientEntity)
Create(String)

使用应用程序配置设置中的 EventHubClient 连接字符串创建 实例的新实例。

CreateBatch()

创建一个批处理,可在其中添加事件数据对象供以后的 SendBatch 或 SendBatchAsync 调用使用。

CreateFromConnectionString(String)

使用指定的连接字符串创建事件中心客户端的新实例。 可以使用事件中心的名称填充 EntityPath 属性。

CreateFromConnectionString(String, String)

使用指定的连接字符串创建事件中心客户端的新实例。 仅当连接字符串不使用 属性时, EntityPath 才使用此重载。

CreatePartitionedSender(String)

为指定的事件中心分区创建事件中心发送方。

CreatePartitionedSenderAsync(String)

CreatePartitionedSender(String) 的异步版本。

CreateSender(String)

为指定的发布者创建事件中心发送方。

CreateSenderAsync()

创建事件中心发送方。 此方法供内部使用,不应从用户代码调用。

CreateSenderAsync(String)

CreateSender(String) 的异步版本。

CreateWithAzureActiveDirectory(Uri, String, AzureActiveDirectoryTokenProvider+AuthenticationCallback, String, Nullable<TimeSpan>, Boolean)

使用 Azure Active Directory 身份验证上下文创建 的新实例 EventHubClient

CreateWithManagedIdentity(Uri, String, Nullable<TimeSpan>, Boolean)

使用 Azure 托管标识身份验证创建 的新 EventHubClient 实例。

Fault()

仅限内部使用。 请勿从此类继承。

(继承自 ClientEntity)
GetConsumerGroup(String)

为事件数据的接收操作返回具有指定名称的使用者组。

GetDefaultConsumerGroup()

返回事件数据接收操作的默认使用者组。

GetPartitionRuntimeInformation(String)

检索事件中心的指定分区的运行时信息。

GetPartitionRuntimeInformationAsync(String)

GetPartitionRuntimeInformation(String) 的异步版本。

GetRuntimeInformation()

检索创建 EventHubSenderEventHubReceiver 对象所需的事件中心运行时信息。

GetRuntimeInformationAsync()

GetRuntimeInformation() 的异步版本。

OnAbort()

执行中止操作。

OnBeginClose(TimeSpan, AsyncCallback, Object)

执行开始关闭操作。

OnBeginOpen(TimeSpan, AsyncCallback, Object)

执行开始打开操作。

OnClose(TimeSpan)

执行关闭操作。

OnClosed()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
OnEndClose(IAsyncResult)

执行结束关闭操作。

OnEndOpen(IAsyncResult)

执行结束打开操作。

OnFaulted()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
OnOpen(TimeSpan)

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
OnOpened()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
Send(EventData)

将事件数据发送到事件中心。

SendAsync(EventData)

以异步方式将事件数据发送到事件中心。

SendBatch(IEnumerable<EventData>)

发送一批事件数据。

SendBatchAsync(IEnumerable<EventData>)

异步发送一批事件数据。

ThrowIfClosed()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
ThrowIfDisposed()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
ThrowIfDisposedOrImmutable()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
ThrowIfDisposedOrNotOpen()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)
ThrowIfFaulted()

用于向事件中心发送和接收事件的定位点类。

(继承自 ClientEntity)

适用于