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

EventProcessorHost 类

定义

命名空间:

Microsoft.ServiceBus.Messaging

程序集:

Microsoft.ServiceBus.Messaging.EventProcessorHost.dll

包:

Microsoft.Azure.ServiceBus.EventProcessorHost v5.0.1

用于处理 EventHub 消息的非常简单的主机。 它负责在 EventProcessorHost 实例之间分发 EventHub 分区。 它为 EventHub 中的每个分区创建一个 Azure 块 Blob，并使用这些 Blob 来管理分区的租约。 每个 EventProcessorHost 实例执行以下两项任务：1) 续订租约：它跟踪主机当前拥有的租约，并持续续订租约。 2) 获取租约：每个实例持续轮询所有租约 blob 以检查如果有任何租约应获取，系统才能进入平衡状态。 客户端应用程序需要实现 IEventProcessor 处理器实现并将其注册到 EventProcessorHost。

public class EventProcessorHost : IDisposable

type EventProcessorHost = class
    interface IDisposable

Public Class EventProcessorHost
Implements IDisposable

继承

Object

EventProcessorHost

实现

IDisposable

构造函数

EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>)	创建 EventProcessorHost 的新实例。
EventProcessorHost(String, String, String, Func<EventProcessorOptions,MessagingFactory>, Func<CloudBlobClient>, String, String)	创建 EventProcessorHost 的新实例。
EventProcessorHost(String, String, String, String)	创建 EventProcessorHost 的新实例。
EventProcessorHost(String, String, String, String, String)	初始化 EventProcessorHost 类的新实例。
EventProcessorHost(String, String, String, String, String, String, String)	初始化 EventProcessorHost 类的新实例。

属性

HostName	获取主机名，它是实例的唯一名称 EventProcessorHost 。
PartitionManagerOptions	获取或设置 PartitionManagerOptions 对象使用的 EventProcessorHost 实例。

方法

Dispose()	用于处理 EventHub 消息的非常简单的主机。 它负责在 EventProcessorHost 实例之间分发 EventHub 分区。 它为 EventHub 中的每个分区创建一个 Azure 块 Blob，并使用这些 Blob 来管理分区的租约。 每个 EventProcessorHost 实例执行以下两项任务：1) 续订租约：它跟踪主机当前拥有的租约，并持续续订租约。 2) 获取租约：每个实例持续轮询所有租约 blob 以检查如果有任何租约应获取，系统才能进入平衡状态。 客户端应用程序需要实现 IEventProcessor 处理器实现并将其注册到 EventProcessorHost。
Dispose(Boolean)	用于处理 EventHub 消息的非常简单的主机。 它负责在 EventProcessorHost 实例之间分发 EventHub 分区。 它为 EventHub 中的每个分区创建一个 Azure 块 Blob，并使用这些 Blob 来管理分区的租约。 每个 EventProcessorHost 实例执行以下两项任务：1) 续订租约：它跟踪主机当前拥有的租约，并持续续订租约。 2) 获取租约：每个实例持续轮询所有租约 blob 以检查如果有任何租约应获取，系统才能进入平衡状态。 客户端应用程序需要实现 IEventProcessor 处理器实现并将其注册到 EventProcessorHost。
RegisterEventProcessorAsync<T>()	使用DefaultEventProcessorFactory<T>工厂向IEventProcessor主机异步注册接口实现。 此方法还会启动主机，并使主机能够开始参与分区分发过程。
RegisterEventProcessorAsync<T>(EventProcessorOptions)	这会使用 DefaultEventProcessorFactory<T>向主机注册IEventProcessor实现。 这也启动主机，并导致它开始参与分区分发过程。
RegisterEventProcessorFactoryAsync(IEventProcessorFactory)	这会向 IEventProcessorFactory 主机注册实现，该主机在获取分区所有权时用于创建 IEventProcessor 实例。 这也启动主机，并导致它开始参与分区分发过程。
RegisterEventProcessorFactoryAsync(IEventProcessorFactory, EventProcessorOptions)	这会向 IEventProcessorFactory 主机注册实现，该主机在获取分区所有权时用于创建 IEventProcessor 实例。 这也启动主机，并导致它开始参与分区分发过程。
ResetAllConnections()	重置此 EventProcessorHost 实例使用的所有事件中心接收器连接。
ResetConnection(String)	用于处理 EventHub 消息的非常简单的主机。 它负责在 EventProcessorHost 实例之间分发 EventHub 分区。 它为 EventHub 中的每个分区创建一个 Azure 块 Blob，并使用这些 Blob 来管理分区的租约。 每个 EventProcessorHost 实例执行以下两项任务：1) 续订租约：它跟踪主机当前拥有的租约，并持续续订租约。 2) 获取租约：每个实例持续轮询所有租约 blob 以检查如果有任何租约应获取，系统才能进入平衡状态。 客户端应用程序需要实现 IEventProcessor 处理器实现并将其注册到 EventProcessorHost。
UnregisterEventProcessorAsync()	异步关闭 EventProcessorHost 实例。 此方法维护当前保留的所有分区的租约，并在当前执行 ProcessEventsAsync(PartitionContext, IEnumerable<EventData>) 完成后使用 Shutdown 对象调用 CloseAsync(PartitionContext, CloseReason) 方法，使每个IEventProcessor实例能够完全关闭。