node rabbit mq 消费者

2024-01-24  本文已影响0人  寻找无名的特质

消费者的代码如下:

消费者的示例代码如下:
// 构建消费者
const amqp = require('amqplib');

async function consumer() {
const conn={
protocol:'amqp',
hostname:'localhost',
port:5672,
username:'admin',
password:'admin',
vhost:'/'
}
// 1. 创建链接对象
const connection = await amqp.connect(conn);
// 2. 获取通道
const channel = await connection.createChannel();
// 3. 声明参数
const queueName = 'Output';
// 4. 声明队列,交换机默认为 AMQP default
await channel.assertQueue(queueName);
// 5. 消费
await channel.consume(queueName, msg => {
console.log('Consumer:', msg.content.toString());
channel.ack(msg);
});
}
consumer();

上一篇 下一篇

猜你喜欢

热点阅读