2013-10-28 36 views
8

我试图从nodejs程序与RabbitMQ建立连接。但它没有建立连接,也没有发生错误。我的代码如下。任何建议请。RabbitMQ with nodejs

var amqp = require('amqp'); 
var connection = amqp.createConnection({url:"amqp://guest:[email protected]: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); 
     }); 
    }); 
}); 

回答

16

看起来像是连接到管理端口15672。 标准AMQP端口是5672。但是,使用amqp://协议应自动设置此端口。

因此,尝试改变:

var connection = amqp.createConnection({url:"amqp://guest:[email protected]"}); 

的URL RabbitMQ的文档是here

+0

嘿它现在工作正常。非常感谢:)现在可以连接到RabbitMQ。 –

+0

接受答案,如果它帮助你..! – Alan