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

EventProcessorHost 类

定义

命名空间:

Microsoft.Azure.EventHubs.Processor

程序集:

Microsoft.Azure.EventHubs.Processor.dll

包:

Microsoft.Azure.EventHubs.Processor v4.3.2

Source:

EventProcessorHost.cs

表示用于处理事件中心事件数据的主机。

public sealed class EventProcessorHost

type EventProcessorHost = class

Public NotInheritable Class EventProcessorHost

继承

Object

EventProcessorHost

构造函数

EventProcessorHost(String, String, String, String, ICheckpointManager, ILeaseManager)	创建一个新主机以处理来自事件中心的事件。 构造函数的此重载可实现最大的灵活性。 此名称还允许调用方指定处理器主机的名称。 重载还允许调用方提供自己的租约和检查点管理器，以替换基于 Azure 存储的内置管理器。
EventProcessorHost(String, String, String, String, String)	创建一个新主机以处理来自事件中心的事件。 由于事件中心经常用于横向扩展的高流量方案，因此通常每个进程只有一个主机，并且进程将在单独的计算机上运行。 但是，如果吞吐量不是问题，则支持在一台计算机上运行多个主机，甚至在一个进程中运行。 构造函数的此重载使用默认的内置租约和检查点管理器。 内置管理器使用 storageConnectionString 参数指定的 Azure 存储帐户来记录租约和检查点。
EventProcessorHost(String, String, String, String, String, String, String)	创建一个新主机以处理来自事件中心的事件。 构造函数的此重载使用默认的内置租约和检查点管理器。
EventProcessorHost(String, Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	使用提供的事件中心创建用于处理事件的新主机 TokenProvider
EventProcessorHost(String, Uri, String, String, ITokenProvider, ICheckpointManager, ILeaseManager, Nullable<TimeSpan>, TransportType)	使用提供的事件中心创建用于处理事件的新主机 TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String)	使用提供的事件中心创建用于处理事件的新主机 TokenProvider
EventProcessorHost(Uri, String, String, ITokenProvider, CloudStorageAccount, String, String, Nullable<TimeSpan>, TransportType)	使用提供的事件中心创建用于处理事件的新主机 TokenProvider

属性

ConsumerGroupName	获取使用者组名称。
EndpointAddress	获取事件终结点 URI。
EventHubPath	获取事件中心路径。
HostName	返回处理器主机名。 如果处理器主机名是自动生成的，则这是获取它的唯一方法。
OperationTimeout	获取操作超时值。
PartitionManagerOptions	获取或设置 PartitionManagerOptions 对象使用的 EventProcessorHost 实例。
TransportType	获取传输类型。

方法

RegisterEventProcessorAsync<T>()	这会使用 Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1向主机注册IEventProcessor实现。 这也启动主机，并导致它开始参与分区分发过程。
RegisterEventProcessorAsync<T>(EventProcessorOptions)	这会使用 Microsoft.Azure.EventHubs.Processor.DefaultEventProcessorFactory`1向主机注册IEventProcessor实现。 这也启动主机，并导致它开始参与分区分发过程。
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	这会向 IEventProcessorFactory 主机注册实现，该主机在获取分区所有权时用于创建 IEventProcessor 实例。 这也启动主机，并导致它开始参与分区分发过程。
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	这会向 IEventProcessorFactory 主机注册实现，该主机在获取分区所有权时用于创建 IEventProcessor 实例。 这也启动主机，并导致它开始参与分区分发过程。
UnregisterEventProcessorAsync()	停止处理事件。 在关闭完成之前不会返回 。