node.js - RabbitMQ 与 nodejs

Question

我正在尝试从 nodejs 程序建立与 RabbitMQ 的连接。但它没有建立连接，也没有抛出错误。我的代码如下。请有任何建议。

var amqp = require('amqp');
var connection = amqp.createConnection({url:"amqp://guest:guest@localhost:15672"});

connection.on('ready', function(){

    var q = connection.queue('jsonmsg', function(q) {
        console.log('connected');
        q.bind("#");
        q.subscribe(function (message) { 
            console.log('on connection' + message);
        });
    }); 
});

Answer 1

看起来您正在连接到管理端口15672。标准 AMQP 端口是5672. 但是，使用amqp://协议应该会自动设置这个端口。

所以，尝试改变：

var connection = amqp.createConnection({url:"amqp://guest:guest@localhost"});

网址的 RabbitMQ 文档在这里。