npm 包 egg-rabbitmq 使用教程

简介

Egg-rabbitmq 是一个基于 Node.js 的 RabbitMQ（一种消息中间件）插件，它可以方便地在 Egg.js 框架中使用 RabbitMQ 进行消息发送和接收。本文将详细介绍 egg-rabbitmq 的安装、配置和使用方法。

安装

首先，在创建一个基于 Egg.js 的应用程序后，可以通过 npm 来安装 egg-rabbitmq 插件：

npm install --save egg-rabbitmq

安装完成后，打开 Egg.js 应用程序的 config/plugin.js 文件，添加：

exports.rabbitmq = {
  enable: true,
  package: 'egg-rabbitmq',
};

插件已经安装完成，我们就可以开始使用它了。

配置

egg-rabbitmq还需要进行一些配置才能正常工作，下面是默认配置（可选）:

exports.rabbitmq = {
  client: {
    hostname: 'localhost',
    port: '5672',
    username: 'guest',
    password: 'guest',
  },
};

使用了默认配置后，RabbitMQ 的服务将会运行在本地机器上并且应用程序将默认使用 guest 用户名和密码访问。

用法

若要在应用程序中使用 egg-rabbitmq 插件，可以在一个 controller 中使用它来进行消息发送和接收。例如，假设我们已经创建了一个名为 client 的连接，它允许我们使用虚拟主机 vhost。

发送消息

要发送消息，我们需要通过连接生成一个频道，然后使用频道来发布一个消息：

const amqpConnection = app.rabbitmq.createConnection();
amqpConnection.on('ready', () => {
  const channel = amqpConnection.createChannel();
  channel.publish('myExchange', 'myRoutingKey', 'hello world');
});

在这个示例中，我们使用 RabbitMQ 中 myExchange 的 myRoutingKey 来发送一个字符串。

接收消息

要接收消息，我们需要使用一个回调函数来处理消费该队列的消息：

const amqpConnection = app.rabbitmq.createConnection();
amqpConnection.on('ready', () => {
  const channel = amqpConnection.createChannel();
  channel.consume('myQueue', (msg) => {
    console.log(`Received message: ${msg.content.toString()}`);
  });
});

在这个示例中，我们使用 RabbitMQ 中 myQueue 队列来接收该队列的消息，然后使用回调函数将消息输出到控制台上。

总结

本文介绍了如何安装、配置和使用 Egg.js 插件 egg-rabbitmq 来进行消息发送和接收。我们可以使用连接和频道来发送和接收消息。希望这篇文章对你有所帮助。

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