node.js - 如何在 node.js 中停止/中止读取文件

Question

假设我正在异步读取 500 MB 的文件。这需要时间阅读。现在，在异步读取文件时，如何停止/中止读取文件并调用回调（即成功中止）函数？

fs.readFile(filePath, function(err, data) {
    //Do work
});

Answer 1

fs.readFile确实异步读取文件，但在读取整个文件之前它不会调用您的回调，因此您无法通过使用该方法来实现这一点。相反，我相信你必须使用fs.createReadStream()which 给你一个stream.Readable. 然后，您可以为该对象实现适当的事件。

function readTheFile(fileName, callback) {
    var stream = fs.createReadStream(fileName);
    stream.on('readable', function() {}); // Do your read logic
    stream.on('error', function(err) {}); // Handle the error
}

Answer 2

只需使用fs.read(with fs.open) 而不是fs.readFile. 例子：

fs.open(filepath, 'r', function(err, fd) {

    var finalize = function(buffer) {
        fs.close(fd);
        console.log(buffer);
    };

    if (err) {
        finalize();
        return;
    }

    fs.fstat(fd, function(err, stats) {
        if (err) {
            finalize();
            return;
        }

        var bufferSize = stats.size,
            chunkSize = 512,
            buffer = new Buffer(bufferSize),
            bytesRead = 0;

        var inner_read = function() {
            if ((bytesRead + chunkSize) > bufferSize) {
                chunkSize = (bufferSize - bytesRead);
            };
            if (chunkSize > 0) {
                fs.read(fd, buffer, bytesRead, chunkSize, bytesRead, function(err) {
                    // YOU CAN DO SOMETHING HERE TO STOP READING
                    if (err) {
                        finalize(buffer);
                        return;
                    }
                    bytesRead += chunkSize;
                    inner_read();
                });
            } else {
                finalize(buffer);
            }
        }
        inner_read();
    });
});