nodejs如何使用RabbitMQ
时间: 2023-07-26 17:05:53 浏览: 180
Node.js可以通过安装amqplib库来使用RabbitMQ。具体步骤如下:
1. 在Node.js项目中安装amqplib库:
```
npm install amqplib
```
2. 引入amqplib库:
```
const amqp = require('amqplib');
```
3. 连接RabbitMQ服务:
```
const conn = await amqp.connect('amqp://localhost');
```
4. 创建通道:
```
const channel = await conn.createChannel();
```
5. 声明消息队列:
```
const queueName = 'hello';
await channel.assertQueue(queueName);
```
6. 发送消息:
```
const msg = 'Hello World!';
channel.sendToQueue(queueName, Buffer.from(msg));
```
7. 接收消息:
```
channel.consume(queueName, (msg) => {
console.log(msg.content.toString());
}, { noAck: true });
```
注意:noAck参数设置为true表示接收到消息后不需要确认。如果需要手动确认则需要设置noAck为false,并在处理消息后调用channel.ack()确认消息。
以上就是使用Node.js和RabbitMQ进行消息传递的基本步骤。
阅读全文