node.js - 使用 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 MQ 团队不再推荐使用这个库，而是推荐使用更底层的 ampq.node 并且允许/要求您手动处理通道。