Node.js fs.createReadStream() 方法

Node.js中的fs模块提供了许多用于文件系统操作的API，其中之一是createReadStream()方法。这个方法可以用来读取文件并将其转换成可读流（Readable Stream）。

使用方法

createReadStream()的基本用法如下：

const fs = require('fs');

const readableStream = fs.createReadStream('path/to/file');

这个方法通过传入文件的路径来创建一个可读流，流中的数据是从指定文件中读取的。

除了文件路径之外，你还可以传入一些配置选项，例如：

• flags - 文件系统标志，如r表示只读（默认值为r）。
• encoding - 编码类型（默认值为null）。
• fd - 已打开的文件描述符（默认情况下会被忽略）。
• mode - 设置文件模式（默认值为0o666）。
• autoClose - 是否在读取完成后自动关闭文件描述符（默认值为true）。
• start - 文件读取的起始位置（默认值为0）。
• end - 文件读取的结束位置（默认值为文件末尾）。

例如：

const fs = require('fs');

const readableStream = fs.createReadStream('path/to/file', {
    flags: 'r',
    encoding: 'utf8',
    start: 0,
    end: 10
});

这个例子创建了一个从文件开头读取10个字符的可读流。请注意，在这个例子中，我们还指定了编码类型为utf8，因此读取到的数据将以UTF-8编码返回。

事件监听

一旦你创建了一个可读流，你就可以通过监听事件来处理流中的数据。

const fs = require('fs');

const readableStream = fs.createReadStream('path/to/file', {
    encoding: 'utf8'
});

readableStream.on('data', (chunk) => {
    console.log(`Received ${chunk.length} bytes of data.`);
});

readableStream.on('end', () => {
    console.log('Finished reading the file.');
});

在这个例子中，我们监听了data事件，每当流中有新的数据块可用时，就会调用处理函数。我们还监听了end事件，以便在读取完成后清理资源（在这种情况下，我们只是简单打印了一个消息）。

总结

createReadStream()是一个非常强大的方法，可以帮助我们在Node.js中有效地读取大型文件。通过了解不同的选项和事件，你可以为你的应用程序构建出非常复杂的数据处理流水线。