0

現在、ユーザーが自分の Web サイトでページをロードするたびに、新しい RabbitMQ 接続を作成する必要があります。

これにより、毎回新しい TCP 接続が作成されます。ただし、NodeJS AMQP プラグインを使用して、Rabbit に対して行う TCP 接続の数を減らそうとしています。これが私が持っているものです。

var ex_conn = get_connection(uri); //http:rabbitm.com

if(ex_conn == false) {

    var tempConn = amqp.createConnection({
        url: uri
    });

    connections.push({
        host: uri,
        obj: tempConn
    });
}
else {

    var tempConn = ex_conn.obj;

}

私が実行している問題は、私がやろうとすると:

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

});

その後、ready 関数はトリガーされません。これは、ready コールバックが既に定義されていて、再トリガーされないためだと思います。私がやろうとしているのは、次のようにして新しいキューをバインドすることです:

tempConn.queu('', {});

この問題を回避する方法についてのご意見をお待ちしております。

ありがとう。

4

0 に答える 0