Node.js read.read（）返回null

Question

我想从文件中读取字节，这是示例代码：

var fs = require('fs');

var stream= fs.createReadStream('./lib');
console.log(stream.read(10));

返回null。

我认为这是因为read()方法直接从内部缓冲区获取数据。如果缓冲区中的数据不足，null则返回。该read()方法是一个同步调用，没有回调传递，因此设计很有意义。但是我不知道内部缓冲区何时可以有足够的数据，以便我的read()调用可以返回数据，因为它现在处于暂停模式？

更新1：

活动readable是入门的好方法。但是，如果我想读取一个大文件，并且读取计数> 65536，则将返回null。

var fs = require('fs');

var stream = fs.createReadStream('./lib');
stream.on('readable', function () {
    var buffer = stream.read(65537);
    console.log(buffer.length);

});

我确切想要的是stream.read（）可以始终返回数据，直到EOF。

Answer 1

等待readable事件触发，然后尝试读取以下内容：

var fs = require('fs');

var stream= fs.createReadStream('./lib');
stream.on('readable', function () {
  var buffer = stream.read(10);
  if (buffer) {
    console.log(buffer.toString());
  }
});

Answer 2

根据官方文件：

一旦内部缓冲区耗尽，当有更多数据可用时，“可读”事件将再次触发。

我可以使用 async/await 以便 readable.read() 总是可以返回数据，只要不在 EOF 处。

let rs = fs.createReadStream('./resources/1.gif');

async function readable(): Promise<{}> {
    return new Promise(r => rs.on('readable', r));
}

async function readBytes(num: number = 0): Promise<Buffer> {
    let buf = rs.read(num);
    if (buf) {
        return new Promise<Buffer>(r => r(buf));
    }
    else {
        return new Promise<Buffer>(r => {
            this.readable().then(() => {
                this.readBytes(num).then(b => r(b));
            });
        });
    }
}

async function main() {
    console.log('begin');
    console.log((await readBytes(10)).length);
    console.log((await readBytes(65535)).length);
    console.log((await readBytes(100000)).length);
    console.log((await readBytes(10)).length);
    console.log('end');
}

main();

输出：

begin
10
65535
100000
10
end