如何在 Node.js 中使用 RabbitMQ？

推荐答案

在 Node.js 中使用 RabbitMQ 可以通过 amqplib 库来实现。以下是一个简单的示例，展示了如何在 Node.js 中连接 RabbitMQ、发送消息和接收消息。

安装依赖

首先，安装 amqplib 库：

npm install amqplib

发送消息

以下是一个发送消息的示例代码：

// www.javascriptcn.com code example
const amqp = require('amqplib');

async function sendMessage() {
    const connection = await amqp.connect('amqp://localhost');
    const channel = await connection.createChannel();
    const queue = 'hello';

    await channel.assertQueue(queue, { durable: false });
    channel.sendToQueue(queue, Buffer.from('Hello RabbitMQ!'));

    console.log(" [x] Sent 'Hello RabbitMQ!'");

    setTimeout(() => {
        connection.close();
        process.exit(0);
    }, 500);
}

sendMessage();

接收消息

以下是一个接收消息的示例代码：

// www.javascriptcn.com code example
const amqp = require('amqplib');

async function receiveMessage() {
    const connection = await amqp.connect('amqp://localhost');
    const channel = await connection.createChannel();
    const queue = 'hello';

    await channel.assertQueue(queue, { durable: false });

    console.log(" [*] Waiting for messages in %s. To exit press CTRL+C", queue);

    channel.consume(queue, (msg) => {
        if (msg !== null) {
            console.log(" [x] Received %s", msg.content.toString());
            channel.ack(msg);
        }
    }, { noAck: false });
}

receiveMessage();

本题详细解读

1. 连接 RabbitMQ

在 Node.js 中，使用 amqplib 库可以轻松连接到 RabbitMQ。通过 amqp.connect 方法连接到 RabbitMQ 服务器，默认情况下，RabbitMQ 运行在 localhost 的 5672 端口。

const connection = await amqp.connect('amqp://localhost');

2. 创建通道

连接成功后，需要创建一个通道（Channel），通道是实际进行消息传递的管道。

const channel = await connection.createChannel();

3. 声明队列

在发送或接收消息之前，需要确保队列存在。如果队列不存在，assertQueue 方法会自动创建它。

await channel.assertQueue(queue, { durable: false });

durable: false 表示队列是非持久化的，RabbitMQ 重启后队列会被删除。

4. 发送消息

使用 sendToQueue 方法将消息发送到指定的队列中。

channel.sendToQueue(queue, Buffer.from('Hello RabbitMQ!'));

5. 接收消息

使用 consume 方法从队列中接收消息。noAck: false 表示需要手动确认消息，确保消息被正确处理。

channel.consume(queue, (msg) => {
    if (msg !== null) {
        console.log(" [x] Received %s", msg.content.toString());
        channel.ack(msg);
    }
}, { noAck: false });

6. 关闭连接

在完成消息发送或接收后，可以关闭连接以释放资源。

connection.close();

通过以上步骤，你可以在 Node.js 中轻松使用 RabbitMQ 进行消息的发送和接收。