我可以在node.js中指定RabbitMQ凭据吗？

Question

我开始使用rabbit.js从node.js应用程序连接到RabbitMQ.

我被阻止了:

错误:服务器关闭了通道:403(ACCESS-REFUSED),并
    在Channel.C.accept(/.../rabbit.js/node_modules/amqplib/lib/channel 上)显示消息"默认交换时不允许使用ACCESS_REFUSED - 操作" . js:398:24
    )
    在Socket.go(/.../ rabbit)的Connection.mainAccept [as accept](/.../ rabbit.js/node_modules/amqplib/lib/ connection.js :63:33). js/node_modules/amqplib/lib/connection.js:448:48)
    在Socket.EventEmitter.emit(events.js:92:17)
...

这是预期的,因为我使用的RabbitMQ实例被配置为要求发布者和订阅者在能够使用消息队列之前提供凭据,并禁用来宾帐户.

rabbit.js的官方文档没有提到凭据.Google搜索"rabbit.js指定凭据"和"rabbit.js登录密码"尚无定论.

是否支持rabbit.js的凭据？如果没有,node.js的其他RabbitMQ客户端是否支持它们？

Answer 1

所以我自己从未使用过rabbit.js,但在深入研究代码后,它似乎正在使用amqplib.可以在这里看到解析它的代码,它似乎在调用标准的nodejs URL模块.因此,也许你可以尝试一些像这样的:

amqp://user:pass@host.com/vhost

希望能帮助到你!

干杯.

Answer 2

const amqp = require('amqplib/callback_api');

const opt = { credentials: require('amqplib').credentials.plain('user', 'password') };
amqp.connect('amqp://localhost', opt, (err, conn) => {});

//

Answer 3

RabbitMQ遵循WHATWG URL标准，即：

amqp://user:pass@sub.example.com:8080

哪里：

• 用户：用户名
• 密码：密码
• sub.example.com:8080：主机：PORT

样例代码：

var amqp = require('amqplib/callback_api');

amqp.connect('amqp://example.username:example.password@localhost', (err, conn) => {});

问候