node.js - 使用Node.js的RabbitMQ

我正在尝试从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);
        });
    });
});

最佳答案

看起来您正在连接到管理端口15672。
标准的AMQP端口是5672。但是，使用amqp://协议(protocol)应自动设置此端口。

因此，尝试更改:

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

网址的RabbitMQ文档为here。

关于node.js - 使用Node.js的RabbitMQ，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/19636003/