对于使用node-amqp库的RabbitMQ中的每个exchange.publish()，通道数都在不断增加

Question

我在nodejs项目中使用node-amqp库。我还在它的github项目页面上发布了这个问题。

它不断地创建新的通道，它们永远处于空闲状态。一个小时后，频道数约为12000。我检查了交换和发布的选项，但到目前为止，我甚至还没有接近解决方案。

代码有什么问题和/或rabbitmq服务器是否有任何选项/设置来解决此问题？

以下是示例代码：

connection.exchange("brcks-wfa",{type:'direct',durable:true}, function(exchange) {   
setInterval(function() {
        ...
        awS.forEach(function(wc){
                    ...
                    nstbs.forEach(function(br){
                        ...
                        BUpdate(brnewinfo,function(st){
                            if(st){
                                exchange.publish(route, brnewinfo,{contentType:"application/json"});
                            }
                        });
                    });
                    ...
        });
}, 4000);
});

Answer 1

node-amqp中存在一个错误，其中通道未关闭。rabbit团队不再推荐使用这个库，而是推荐使用ampq.node，这是一个更低级的库，让/需要您手动处理通道。