node 调用amqplib插件报错

源码:

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天,您在需要使用的时候【私信】联系我,我会为您补发。