1

我想在兔子中发送和保存一些数据;过了一会儿,我运行我的代码,向我的兔子发送了一些数据后,我得到了一些像这样的错误:错误:没有通道可以分配

我多次使用此代码,因为我有几个数据要发送到rabbitMQ

let open = require('amqplib').connect('amqp://localhost:5672')


    open.then(function (conn) {
      return conn.createChannel()
    }).then(function (ch) {
      return ch.assertQueue(q).then(function (ok) {
        ch.sendToQueue(q, Buffer.from(JSON.stringify(data)))
        return ch.close()
      })
    }).catch(console.warn)
4

1 回答 1

1

看起来您在发布消息时正在创建新频道。

我解决了这个问题中的问题

Rabbit MQ amqplib 错误“没有可分配的通道”

于 2021-02-27T10:02:20.083 回答