ubuntu上nodejs如何实现消息队列

5月 7th, 2025

在Ubuntu上使用Node.js实现消息队列，你可以选择多种消息队列服务，如RabbitMQ、Apache Kafka、Redis等。这里以RabbitMQ为例，介绍如何在Ubuntu上使用Node.js实现消息队列。

步骤1：安装RabbitMQ

首先，你需要在Ubuntu上安装RabbitMQ。可以使用以下命令来安装：

sudo apt update
sudo apt install rabbitmq-server

安装完成后，启动RabbitMQ服务：

sudo systemctl start rabbitmq-server

确保RabbitMQ服务正在运行：

sudo systemctl status rabbitmq-server

步骤2：安装Node.js和npm

如果你还没有安装Node.js和npm，可以使用以下命令来安装：

curl -sL https://deb.nodesource.com/setup_14.x | sudo -E bash -
sudo apt-get install -y nodejs

步骤3：创建Node.js项目

创建一个新的Node.js项目，并进入项目目录：

mkdir my-nodejs-queue
cd my-nodejs-queue

初始化一个新的Node.js项目：

npm init -y

步骤4：安装amqplib

安装amqplib库，这是一个用于与RabbitMQ通信的Node.js库：

npm install amqplib

步骤5：编写生产者代码

创建一个名为producer.js的文件，并添加以下代码：

const amqp = require('amqplib');

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

    await channel.assertQueue(queue, { durable: false });
    const message = 'Hello World!';
    channel.sendToQueue(queue, Buffer.from(message));
    console.log(` [x] Sent ${message}`);

    setTimeout(() => {
      channel.close();
      connection.close();
    }, 500);
  } catch (error) {
    console.error(error);
  }
}

sendMessage();

步骤6：编写消费者代码

创建一个名为consumer.js的文件，并添加以下代码：

const amqp = require('amqplib');

async function receiveMessage() {
  try {
    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 ${queue}. To exit press CTRL+C`);

    channel.consume(queue, (msg) => {
      console.log(` [x] Received ${msg.content.toString()}`);
      channel.ack(msg);
    });
  } catch (error) {
    console.error(error);
  }
}

receiveMessage();