带有nodejs的RabbitMQ

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"});

适用于url的RabbitMQ文档就在这里.