露珠111 2021-06-08 09:46 采纳率: 100%
浏览 56
已采纳

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)
请教一下各位高手,什么原因呢?

 

  • 写回答

2条回答 默认 最新

  • 露珠111 2021-06-10 09:42
    关注

    搞定了,端口好不对,改了端口号为5672就OK了,谢谢!

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 求差集那个函数有问题,有无佬可以解决
  • ¥15 【提问】基于Invest的水源涵养
  • ¥20 微信网友居然可以通过vx号找到我绑的手机号
  • ¥15 寻一个支付宝扫码远程授权登录的软件助手app
  • ¥15 解riccati方程组
  • ¥15 display:none;样式在嵌套结构中的已设置了display样式的元素上不起作用?
  • ¥15 使用rabbitMQ 消息队列作为url源进行多线程爬取时,总有几个url没有处理的问题。
  • ¥15 Ubuntu在安装序列比对软件STAR时出现报错如何解决
  • ¥50 树莓派安卓APK系统签名
  • ¥65 汇编语言除法溢出问题