npm 包 @azure/core-amqp 使用教程

介绍

@azure/core-amqp 是一个用于可靠消息传递的 Node.js 包，它使用 AMQP 协议实现了对 Azure 服务的访问。在本教程中，我们将教你如何使用此包来创建和发送消息，以及如何从队列或订阅中接收并处理消息。

安装

首先，你需要安装 Node.js 和 npm。接下来，你可以使用以下命令在你的项目中安装 @azure/core-amqp：

npm install @azure/core-amqp

创建和发送消息

创建和发送消息的过程非常简单。首先，您需要通过以下代码创建一个 AMQP 连接：

import { Connection, SendableMessageInfo } from "@azure/core-amqp";

const connectionString = "YOUR_CONNECTION_STRING";
const connection = new Connection(connectionString);
await connection.open();

接下来，您需要创建一个消息对象：

const message: SendableMessageInfo = {
    body: "Hello, World!",
    contentType: "text/plain",
};

最后，您可以通过以下代码将消息发送到队列：

const sender = connection.createSender("YOUR_QUEUE_NAME");
await sender.send(message);

从队列或订阅中接收并处理消息

接收消息的过程与发送消息非常相似。首先，您需要创建一个 AMQP 连接：

import { Connection, Session } from "@azure/core-amqp";

const connectionString = "YOUR_CONNECTION_STRING";
const connection = new Connection(connectionString);
await connection.open();

接下来，您需要创建一个会话：

const session = await connection.createSession({
    receive_mode: "receive_and_delete",
});

接下来，您需要创建一个订阅或队列接收者：

const receiver = await session.createReceiver("YOUR_QUEUE_OR_SUBSCRIPTION_NAME");

使用以下代码从接收者中接收并处理消息：

-- -------------------- ---- -------
--------------------
    --------------- ----- ----- -- -
        ---------------------------------
        -- -------
    --
    ------------- ----- ----- -- -
        ------------------- ---------
        -- -------
    --
---
展开代码

结论

在本教程中，我们介绍了如何使用 @azure/core-amqp 创建和发送消息，以及从队列或订阅中接收并处理消息。@azure/core-amqp 是一个功能强大且易于使用的 npm 包，它使得与 Azure 服务之间的通信变得非常简单。我希望这篇文章对您有所帮助，并能够在您的下一个项目中提供指导和帮助。

来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/5eedab93b5cbfe1ea06107e2