在当今的云计算时代，事件驱动架构已成为应用程序开发的一种首选方式。为了在云计算时代建立可靠和可扩展的应用程序，Azure Event Grid 和 Azure Event Hubs 被引入作为事件中心来处理和分发事件。@microsoft.azure/eventing 是一个用于 Azure 事件流程处理的 npm 包，提供了封装和处理事件的方便性和可操作性，使得开发人员可以更高效地开发事件驱动微服务。
安装 @microsoft.azure/eventing
使用 npm 包管理程序进行安装，打开终端并输入以下命令：
npm install @microsoft.azure/eventing
如何使用 @microsoft.azure/eventing
创建订阅
创建订阅是为了处理特定事件类型的流。@microsoft.azure/eventing 允许您使用 eventProcessorHost 对象来创建订阅。eventProcessorHost 负责启动和停止事件流处理器宿主，并管理事件传输和流序列化过程。
-- -------------------- ---- ------- ----- - ------------------ - - ------------------------------------- ----- ---- - --- -------------------- -------------- -------------------- ----------------- --------------------------------------------------------------------------------------------------------------- -- ------------ -- -------- - ---- -- -------- ------- -- --- ---- -- --------- -- --- -------------------------- ------------- --------------- ------------------------ -------------------------------------------------------------------------------------------------------------------------------------------------------- --------------------- ----------------- --- --------------------------------------
在本示例中，我们使用 EventProcessorHost 创建了一个新的事件流处理器宿主，并定义了以下参数：
consumerGroup- 消费组名称。connectionString- Azure 服务总线连接字符串。eventHubPath- Azure Event Hub 名称。storageConnectionString- Azure 存储连接字符串。storageContainerName- Azure 存储组件的容器名称。
处理事件
处理事件是 eventProcessor 的主要功能。eventProcessor 对象封装了 context，使得订阅的用户可以轻松地读取和处理输入事件。此外，eventProcessor 还负责事件的处理和确认，以确保您的订阅可以无缝地处理大量的流和事件。
以下是使用 eventProcessor 处理事件的示例：
-- -------------------- ---- -------
----- - --------------- ----- - - -------------------------------------
----- ------------------ ------- -------------- -
----- ---------------------- ------- -
--- ------ ----- -- ------- -
------------------ ---------------- --- ----------------------- --- -------------------------
-
----- ------------
---------------------
-
-
----- -------- ---------------------------------- --------- -
----- -------------- - --- ---------------------
--------------------------------------- ----------
-
--------------------------------------在本示例中，我们定义了一个 TestEventProcessor 类，并使用 eventProcessor.processMessages() 方法处理传入的事件流。processMessages() 方法通过 context.checkpoint() 函数来确认处理成功，确保事件在处理之后不再重新发送。
结论
@microsoft.azure/eventing 是 Azure 事件中心处理的一个方便和易于使用的 npm 包。通过本文提供的教程和示例代码，开发人员可以更快速和高效地开发和运行事件驱动型应用程序。如果您是一个微服务开发人员或者是云计算架构设计师，@microsoft.azure/eventing 将是您不可错过的工具之一。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/600673e0fb81d47349e53cd5