5

我正在使用node-amqp库连接到在线 stomp 服务，在我使用stomp-client之前，它连接非常成功，但它不支持自动故障检测和重新连接，所以我想切换到node-amqp 以获得更强大的支持。

var amqp = require('amqp');
var option = { 
  host: 'host'
, port: 61618
, login: 'my username'
, password: 'my password'
};

var implOpts = {
      reconnect: true,
      reconnectBackoffStrategy: 'exponential',
      reconnectBackoffTime: 500
};

var connection  = amqp.createConnection(option,implOpts);
connection.addListener('ready', function(){
    console.log('ready connection ');

});

connection.on('error', function (error) {
    console.log('Connection error' ,error);

});

connection.on('close', function () {
    console.log('Connection close ');

});

主机名、密码、用户名和端口是正确的，并且在 stomp-client 库示例中工作。但是，通过使用上面的代码，我收到一条错误消息，提示连接错误 { 消息：'连接已结束：可能是由于身份验证失败。' }。我查看了代码，没有发现我的身份验证或代码有任何问题。

这是 stomp-client 库中的工作代码。

var StompClient = require('stomp-client').StompClient;

var client = new StompClient('host', 61618, 'my username', 'my password', '1.0');

client.connect(function(sessionId) {
   console.log('Trying to connect the real time service...');

});

谁能告诉我如何使用 node-amqp 来连接 stomp 服务

4

1 回答 1

0

不知道你是否找到了这个问题的答案，但我发现自己在这个问题上打了我的头，并在谷歌搜索的顶部附近点击了这个，所以我想我会分享我的发现：

一些快速信息；

  • 兔MQ 3.5.6
  • 节点JS 6.2.2
  • amqplib 0.4.2

在四处挖掘之后，我在 github 上找到了该项目，并深入测试以找到https://github.com/squaremo/amqp.node/blob/master/test/connect.js，它有一个简单的身份验证示例。我发现的关键是您必须调用一个特殊函数来格式化凭据，然后将它们作为对象传递：

var credentials = require('amqplib/lib/credentials');
var options = {};
options.credentials = credentials.plain(configuration.rabbitmq.user, configuration.rabbitmq.pass);
amqp.connect(connstr, options ....

还提到将用户名和密码嵌入到 URL 中，即：

amqp://user:pass@server:port

但是，这对我的情况不起作用。

于 2016-08-18T05:49:50.340 回答