8

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

1 に答える 1

16

管理ポートに接続しているようです15672。標準の AMQP ポートは5672. ただし、amqp://プロトコルを使用すると、このポートが自動的に設定されます。

したがって、次のように変更してみてください。

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

URL の RabbitMQ ドキュメントはこちらです。

于 2013-10-28T13:30:25.883 に答える