NPM 是 Node.js 生态系统中非常重要的一部分,允许我们轻松地安装,管理并升级我们的项目所需的各种软件包。@azure/event-hubs 是一个旨在简化开发人员使用事件中心的 Azure 服务的 npm 包。
本文将详细介绍如何使用此 npm 包,包括安装和配置 @azure/event-hubs,以及如何使用它来发送和接收 Azure 事件中心中的消息。
安装和配置 @azure/event-hubs
使用 @azure/event-hubs npm 包之前,必须使用 npm 安装它。我们可以在终端中使用以下命令:
--- ------- -----------------
安装完成后,我们需要将其导入到我们的代码中:
----- - ---------------------- - - -----------------------------
接下来,我们需要将 Azure 服务中的事件中心连接字符串设置为环境变量:
----------------------------------------- - ----------------------
在这里,<connection_string>
是您的 Azure 事件中心服务的连接字符串。请注意,这是您通过 Azure 门户创建的连接字符串,仅包含您的事件中心名称、服务命名空间和共享访问策略的凭据。
完成配置后,我们现在可以使用 @azure/event-hubs 开发应用程序来发送和接收消息。
发送 Azure 事件
在以下示例中,我们将向 Azure 事件中心服务发送消息:
----- - ---------------------- - - ----------------------------- ----- -------- ------ - -- -- ----- ----------- ----- -------------- - --- ------------------------- -- - ----- -------- ----- ----- - ----- ----------------------------- -------------- ----- ------ ------- --- ----- -------------------------------- -- -- ----- ----------- ----- ----------------------- - -------------------- -- - --------------------- ---
在这个例子中,我们首先创建了一个名为 EventHubProducerClient
的生产者客户端来发送消息。然后,我们使用 createBatch()
方法创建一个新的消息批次,将一条消息添加到其中,然后使用 sendBatch()
方法将消息批次发送到 Azure 事件中心。最后,我们使用 close()
方法关闭生产者客户端以释放资源。
接收 Azure 事件
以下示例演示如何使用 EventHubConsumerClient
类从 Azure 事件中心接收消息:
----- - ---------------------- - - ----------------------------- ----- -------- ------ - -- -- ----- ----------- ----- -------------- - --- ------------------------- -- --- ----- -------- ------------------------- - -------------- ----- -------- -- - --- ------ ----- -- ------- - --------------------- ------ ---------------- - -- ------------- ----- ----- -- - ------------------- -- -- - -------------- -------- - -- - -------------------- -- - --------------------- ---
在这个例子中,我们创建了一个名为 EventHubConsumerClient
的消费者客户端来接收来自 Azure 事件中心的消息。然后,我们通过调用 subscribe()
方法订阅消息。在 subscribe()
方法的选项参数中,我们使用 startPosition
属性设置消费者客户端从事件流中的哪个位置开始接收消息。
在 subscribe()
的第一个参数中,我们向该方法传入一个包含处理消息的回调函数和处理错误的回调函数的对象。在这个例子中,我们处理单个消息的方法是将消息打印到控制台中。
总结
在本文中,我们详细介绍了如何使用 @azure/event-hubs npm 包来发送和接收消息。我们还涉及安装和配置 npm 包,在示例代码中遵循了最佳实践。
通过了解如何使用 @azure/event-hubs npm 包,您可以更轻松地连接和管理 Azure 事件中心服务,并有效地处理消息。
来源:JavaScript中文网 ,转载请联系管理员! 本文地址:https://www.javascriptcn.com/post/azure-event-hubs