0

目前,每次用户在我的网站上加载页面时,我都被迫创建一个新的 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() {

});

然后准备功能不会被触发。我假设,那是因为就绪回调已经定义并且不会被重新触发。我想要做的是绑定一个新队列:

tempConn.queu('', {});

非常感谢有关如何解决此问题的任何想法。

谢谢。

4

0 回答 0