什么是 oly-amqp
oly-amqp 是一个基于 Node.js 的 AMQP 客户端库，它实现了 AMQP 协议的基本操作，使用户可以轻松地与 AMQP 服务器进行交互。
oly-amqp 支持 AMQP 0.9.1 协议，同时也支持 RabbitMQ 和其他 AMQP 服务器。它提供了一系列的类和方法，用户可以使用这些类和方法处理队列、交换机和消息等AMQP 的基本概念。
安装
使用 npm 安装 oly-amqp：
npm install oly-amqp
安装完成后，可以在代码中引入 AMQP 模块：
const amqp = require('oly-amqp');创建连接
在使用 oly-amqp 之前，需要先创建一个连接：
const url = 'amqp://localhost'; const connection = await amqp.connect(url);
创建通道
连接创建完成后，接下来需要创建一个通道：
const channel = await connection.createChannel();
发布消息
现在我们可以向队列中发布一条消息了：
const queueName = 'hello';
const message = 'Hello World!'
const queueOptions = { durable: false };
await channel.assertQueue(queueName, queueOptions);
channel.sendToQueue(queueName, Buffer.from(message));这里我们定义了一个队列名称为 hello，消息内容为 Hello World!。同时，我们还定义了队列的选项 durable，设置为 false。如果设置为 true，则表示队列在 RabbitMQ 服务器重启后也能够存活。
消费消息
接下来，我们可以为队列设置一个消费者，从队列中消费消息：
const consumeHandler = (msg) => {
console.log("Received: ", msg.content.toString());
}
const consumerOptions = { noAck: true };
channel.consume(queueName, consumeHandler, consumerOptions);这里我们定义了一个 consume 函数，它接收三个参数：队列名称、一个处理函数和消费者的选项。
消息处理函数 consumeHandler 接收一个消息作为参数，输出消息内容，输出结果如下：
Received: Hello World!
总结
以上是 oly-amqp 的基本使用流程，学习完成后你可以使用 oly-amqp 客户端库与 RabbitMQ 和其他 AMQP 服务器进行交互。
在实践过程中，你可以根据具体应用场景和需求，使用不同的 API，掌握 AMQP 协议的基本概念和操作方法，从而为你的项目开发和运维带来便利和高效。
示例代码
完整的示例代码，包括发布和消费消息：
-- -------------------- ---- ------- ----- ---- - -------------------- ----- --- - ------------------- ----- --------- - -------- ----- -------------- - ----- -- - ---------------------- -- ------------------------ - ----- --------------- - - ------ ---- -- ----- -------- -------- - ----- ---------- - ----- ------------------ ----- ------- - ----- --------------------------- ----- ------- - ------ -------- ----- ------------ - - -------- ----- -- ----- ------------------------------ -------------- ------------------------------ ---------------------- ------------------ -- --------- ----- ---------------- ----- ------------------- - ----- -------- ---------- - ----- ---------- - ----- ------------------ ----- ------- - ----- --------------------------- ----- ------------ - - -------- ----- -- ----- ------------------------------ -------------- -------------------------- --------------- ----------------- - --------- -------------------- ------
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/60066fb03d1de16d83a67357