js订阅rabbitmq

在 JavaScript 中订阅 RabbitMQ，你可以使用 RabbitMQ 的 JavaScript 客户端库，例如 amqplib。以下是一个简单的示例代码：

首先，确保你已经安装了 amqplib 包。你可以使用 npm 进行安装：

npm install amqplib

然后，你可以使用以下代码实现 RabbitMQ 的订阅功能：

const amqp = require('amqplib');

async function main() {
  try {
    // 连接到 RabbitMQ
    const connection = await amqp.connect('amqp://localhost');

    // 创建一个信道
    const channel = await connection.createChannel();

    // 声明一个交换机
    const exchangeName = 'my_exchange';
    await channel.assertExchange(exchangeName, 'fanout', { durable: false });

    // 声明一个临时队列
    const queue = await channel.assertQueue('', { exclusive: true });

    // 绑定队列到交换机
    await channel.bindQueue(queue.queue, exchangeName, '');

    // 接收消息
    channel.consume(queue.queue, (msg) => {
      console.log('收到消息:', msg.content.toString());
    }, { noAck: true });

    console.log('等待接收消息...');

  } catch (error) {
    console.error('出现错误:', error);
  }
}

main();

在上面的代码中，我们首先连接到 RabbitMQ，然后创建一个信道。接下来，我们声明一个交换机，并创建一个临时队列。然后，我们将队列绑定到交换机上。最后，我们通过 `channel.consume` 方法来接收消息，并将收到的消息输出到控制台。

请注意，上述代码假设 RabbitMQ 运行在本地的默认端口上（5672）。你可能需要根据实际情况修改连接字符串。

希望能对你有所帮助！如果你有任何其他问题，请随时提问。