消费者的代码如下:
消费者的示例代码如下:
// 构建消费者
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();
网友评论