源码:
const amqp =require('amqplib');
async function consumer() {
// 1. 创建链接对象
const connection = await amqp.connect('amqp://admin:admin@192.168.1.112:15672/');
// 2. 获取通道
const channel = await connection.createChannel();
// 声明参数
const exchangeName = 'fanout_koala_exchange';
const queueName = 'hello';
const routingKey = '';
// 声明一个交换机
await channel.assertExchange(exchangeName, 'fanout', { durable: true });
// 声明一个队列
await channel.assertQueue(queueName);
// 绑定关系(队列、交换机、路由键)
await channel.bindQueue(queueName, exchangeName, routingKey);
// 消费
await channel.consume(queueName, msg => {
console.log('Consumer:', msg.content.toString());
channel.ack(msg);
});
console.log('消费端启动成功!');
}
consumer();
报错:
PS E:\网页GIS-2021\fire-control\src\dbmanager> node MQconstructor.js
(node:16660) UnhandledPromiseRejectionWarning: Error: Socket closed abruptly during opening handshake
at Socket.endWhileOpening (E:\网页GIS-2021\fire-control\node_modules\amqplib\lib\connection.js:260:17)
at Socket.emit (events.js:388:22)
at endReadableNT (internal/streams/readable.js:1336:12)
at processTicksAndRejections (internal/process/task_queues.js:82:21)
请教一下各位高手,什么原因呢?
搞定了,端口好不对,改了端口号为5672就OK了,谢谢!
你好,我是有问必答小助手,非常抱歉,本次您提出的有问必答问题,技术专家团超时未为您做出解答
本次提问扣除的有问必答次数,将会以问答VIP体验卡(1次有问必答机会、商城购买实体图书享受95折优惠)的形式为您补发到账户。
因为有问必答VIP体验卡有效期仅有1天,您在需要使用的时候【私信】联系我,我会为您补发。