你当前正在访问 Microsoft Azure Global Edition 技术文档网站。 如果需要访问由世纪互联运营的 Microsoft Azure 中国技术文档网站，请访问 https://docs.azure.cn。
EventProcessor<TPartition> 类
定义
重要
一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。 对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。
为创建自定义处理器提供基础，该处理器在给定事件中心的所有分区中为特定使用者组使用事件。 处理器能够与同一事件中心和使用者组配对的其他实例协作，通过使用通用存储平台进行通信来共享工作。 此外，还内置了容错功能，允许处理器在遇到错误时具有复原能力。
public abstract class EventProcessor<TPartition> where TPartition : EventProcessorPartition, new()type EventProcessor<'Partition (requires 'Partition :> EventProcessorPartition and 'Partition : (new : unit -> 'Partition))> = classPublic MustInherit Class EventProcessor(Of TPartition)类型参数
- TPartition
要对其执行操作的分区的上下文。
- 继承
-
EventProcessor<TPartition>
- 派生
注解
为了在实例之间 EventProcessor<TPartition> 实现分区共享的协调，他们将断言对使用者组的分区的独占读取访问权限。 除了打算协作的处理器之外，其他读取器不应在使用者组中处于活动状态。 非独占读者将被拒绝访问;独占读取器（包括使用不同存储位置的处理器）将干扰处理器的操作和性能。
可以 EventProcessor<TPartition> 安全地缓存并在应用程序的生存期内使用，这是推荐的方法。 处理器负责确保高效的网络、CPU 和内存使用。 StopProcessingAsync(CancellationToken)当所有处理完成或应用程序关闭时调用 或 StopProcessing(CancellationToken) 将确保正确清理网络资源和其他非托管对象。
构造函数
属性
| ConsumerGroup |
与此事件处理程序关联的使用者组的名称。 事件将在此组的上下文中为只读。 |
| EventHubName |
处理器连接到的事件中心的名称，特定于包含它的事件中心命名空间。 |
| FullyQualifiedNamespace |
与处理器关联的完全限定的事件中心命名空间。 这可能类似于 |
| Identifier |
用于标识此事件处理程序的唯一名称。 |
| IsRunning |
指示此事件处理程序当前是否正在运行。 |
| RetryPolicy |
控制处理器重试尝试的活动策略。 |
