node.js - node-amqp ライブラリを使用した RabbitMQ の exchange.publish() ごとにチャネルが増加し続けます

Question

nodejs プロジェクトに node-amqp ライブラリを使用しています。問題を github プロジェクト ページにも投稿しました。

新しいチャネルを作成し続け、それらは永遠にアイドル状態のままです。1 時間後、チャネルは ~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 を推奨しています。