node.js - Node.js アプリはメモリを解放せずに継続的に消費します

Question

私は奇妙な状況に直面しています。5 分ごとに HTTP GET 要求を実行するアプリケーションを作成しました。このようなもの：

// pingy

'use strict';

var https   = require('https'),
    url     = require('url');

exports.ping = function ping (callback) {
    var options = url.parse('https://host.tld/ping');

    callback = callback || function () {};

    https.get(options, function handler (response) {
        var body = '';

        response
            .on('readable', function onReadable() {
                body = body + response.read();
            })
            .on('end', function onEnd() {
                return callback(null, body);
            })
            .on('error', function onError (err) {
                return callback(err);
            });
    });
};

// in other module
var pingy = require('./lib/pingy');

setInterval(pingy.ping, 300000);

かなり簡単です。問題は、しばらくすると、process.memoryUsage() からの「rss」が上昇して上昇することです。作成された ClientRequest オブジェクトが GCed() されることはないようです。この例では https を使用していますが、http モジュールを使用しても同じことが起こります。

ここで何が悪いのか分かりますか？

編集：

上記の問題を解決しました（以下のコメントを参照）。今、私は別の問題に直面しています。これは、追跡するのが本当に非常に困難です（メモリ使用量を分析するためにnode-webkit-agentを使用しましたが、特別なことは何もありません。ヒープは私には安定しているように見えます）。シナリオも特別なものではなく、ストリームを介してソースから宛先に約 200 枚の画像をコピーしています (以下のコードを参照)。何が起こるかというと、「RSS」も増加します。ファイルをパイプする方法に関して、私のコードに何か問題があると確信しています。誤解しないでください。メモリ使用量が高くても問題はありません。私が問題を抱えているのは、メモリが解放されないことです。将来のある時点でメモリがクリアされることを確認するために、http.createServerすべてのファイルがコピーされた後。数時間後でも、「rss」値は同じままです。

では、繰り返しになりますが、ここで何が問題なのか分かりますか? すべてのヒントを事前にありがとう！:)

'use strict';

var http = require('http'),
    fs   = require('fs'),
    path = require('path'),
    util = require('util'),
    directory = '/path/to/your/files/',
    jobs = [];

function printMemoryUsage () {
    var memory = process.memoryUsage();

    memory.rss = (memory.rss / 1024) | 0;
    memory.heapTotal = (memory.heapTotal / 1024) | 0;
    memory.heapUsed = (memory.heapUsed / 1024) | 0;

    console.log(JSON.stringify(memory));
}

function pipeFile() {
    var infile = jobs.pop(),
        outfile = jobs.pop(),
        instream = fs.createReadStream(infile),
        outstream = fs.createWriteStream(outfile);

    instream.pipe(outstream);

    instream.on('close', outstream.end.bind(outstream));
    outstream.on('finish', function onFinish () {
        // console.log('Finished %s -> %s', infile, outfile);

        instream.destroy();
        outstream.destroy();

        next();
    });
}

function next() {
    if (jobs.length) {
        setTimeout(pipeFile, 2000);
    } else {
        http.createServer(function (req, res) {
            res.writeHead(200, {'Content-Type': 'text/plain'});
            res.end('Fooboot\n');
        }).listen(1337, '127.0.0.1');
    }
}

fs.readdir(directory, function (err, files) {
    files.forEach(function onIteration (file) {
        jobs.push(path.join(__dirname, file)); // outfile
        jobs.push(path.join(directory, file)); // infile
    });
    next();
});

setInterval(printMemoryUsage, 3000);

これらはメモリ フットプリントです。

{"rss":13904,"heapTotal":6963,"heapUsed":1758}
{"rss":16012,"heapTotal":6963,"heapUsed":2016}
{"rss":26040,"heapTotal":6963,"heapUsed":2265}
{"rss":31468,"heapTotal":6963,"heapUsed":2453}
{"rss":41080,"heapTotal":6963,"heapUsed":2712}
{"rss":46620,"heapTotal":6963,"heapUsed":2844}
{"rss":49260,"heapTotal":6963,"heapUsed":1999}
{"rss":49524,"heapTotal":6963,"heapUsed":2249}
{"rss":49524,"heapTotal":6963,"heapUsed":2362}
{"rss":49788,"heapTotal":6963,"heapUsed":2621}
{"rss":49788,"heapTotal":6963,"heapUsed":2755}
{"rss":52692,"heapTotal":6963,"heapUsed":2001}
{"rss":52692,"heapTotal":6963,"heapUsed":2138}
{"rss":52692,"heapTotal":6963,"heapUsed":2270}
{"rss":52692,"heapTotal":6963,"heapUsed":2483}
{"rss":52692,"heapTotal":6963,"heapUsed":2600}
{"rss":52692,"heapTotal":6963,"heapUsed":2796}
{"rss":52956,"heapTotal":6963,"heapUsed":1951}
{"rss":52956,"heapTotal":6963,"heapUsed":2079}
{"rss":52956,"heapTotal":6963,"heapUsed":2343}
{"rss":52956,"heapTotal":6963,"heapUsed":2462}
{"rss":52956,"heapTotal":6963,"heapUsed":2689}
{"rss":52956,"heapTotal":6963,"heapUsed":2831}
{"rss":53136,"heapTotal":9011,"heapUsed":1927}
{"rss":53136,"heapTotal":9011,"heapUsed":2176}
{"rss":53136,"heapTotal":9011,"heapUsed":2273}
{"rss":53136,"heapTotal":9011,"heapUsed":2447}
{"rss":53136,"heapTotal":9011,"heapUsed":2545}
{"rss":53136,"heapTotal":9011,"heapUsed":2627}
{"rss":53136,"heapTotal":9011,"heapUsed":2804}
{"rss":53136,"heapTotal":9011,"heapUsed":2890}
{"rss":59732,"heapTotal":9011,"heapUsed":3100}
{"rss":65012,"heapTotal":9011,"heapUsed":3211}
{"rss":73496,"heapTotal":9011,"heapUsed":3409}
{"rss":79304,"heapTotal":9011,"heapUsed":3536}
{"rss":83792,"heapTotal":9011,"heapUsed":3633}
{"rss":95408,"heapTotal":9011,"heapUsed":3865}
{"rss":98840,"heapTotal":9011,"heapUsed":1824}
{"rss":98840,"heapTotal":9011,"heapUsed":2003}
{"rss":98840,"heapTotal":9011,"heapUsed":2205}
{"rss":98840,"heapTotal":9011,"heapUsed":2297}
{"rss":98840,"heapTotal":9011,"heapUsed":2491}
{"rss":98840,"heapTotal":9011,"heapUsed":2608}
{"rss":98840,"heapTotal":9011,"heapUsed":2717}
{"rss":98840,"heapTotal":9011,"heapUsed":2919}
{"rss":99368,"heapTotal":9011,"heapUsed":3036}
{"rss":99368,"heapTotal":9011,"heapUsed":3247}
{"rss":99632,"heapTotal":9011,"heapUsed":3351}
{"rss":99632,"heapTotal":9011,"heapUsed":3452}
{"rss":99896,"heapTotal":9011,"heapUsed":3606}
{"rss":99896,"heapTotal":9011,"heapUsed":3686}
{"rss":105968,"heapTotal":9011,"heapUsed":3824}
{"rss":106760,"heapTotal":9011,"heapUsed":1936}
{"rss":106760,"heapTotal":9011,"heapUsed":2022}
{"rss":106760,"heapTotal":9011,"heapUsed":2187}
{"rss":106760,"heapTotal":9011,"heapUsed":2279}
{"rss":106760,"heapTotal":9011,"heapUsed":2474}
{"rss":106760,"heapTotal":9011,"heapUsed":2614}
{"rss":106760,"heapTotal":9011,"heapUsed":2690}
{"rss":106760,"heapTotal":9011,"heapUsed":2854}
{"rss":106760,"heapTotal":9011,"heapUsed":2953}
{"rss":106760,"heapTotal":9011,"heapUsed":3241}
{"rss":106760,"heapTotal":9011,"heapUsed":3391}
{"rss":106760,"heapTotal":9011,"heapUsed":3535}
{"rss":107288,"heapTotal":9011,"heapUsed":3797}
{"rss":108248,"heapTotal":9011,"heapUsed":1908}