浅析 Node.js 中的可读流（fs.createReadStream）
2024-02-25 18:58:21
在 Node.js 的世界里，处理数据，尤其是大文件，是一项常见的任务。想象一下，你需要处理一个巨大的日志文件或者一个高清视频，如果直接把整个文件加载到内存中，你的程序可能会变得缓慢甚至崩溃。这时，流 就闪亮登场了。它就像一条传送带，可以把数据分成一块一块地传输，而不是一股脑地全部塞进来，这样就大大减轻了内存的压力。
为什么要用流？
我们先来看看传统的做法。Node.js 的 fs 模块提供了 readFileSync 和 readFile 这样的方法，可以一次性读取整个文件。这对于小文件来说没什么问题，但如果文件很大，就会占用大量的内存。打个比方，就像你要把一整箱货物一次性搬到楼上，很可能会累趴下。而流就像电梯，可以把货物分批次运上去，轻松多了。
fs.createReadStream：打开数据之门
Node.js 提供了一个非常方便的工具来创建可读流：fs.createReadStream。你只需要传入文件的路径，它就会返回一个可读流对象，就像打开了一扇通往文件数据的大门。这个对象是一个 EventEmitter 的实例，会发出各种事件来告诉你流的状态，比如数据来了，文件读完了，或者出错了。
可读流的事件：倾听数据的脚步
fs.createReadStream 会发出一些重要的事件，就像数据传送带上的指示灯，告诉你传送带的运行情况：
data事件：当有一块数据准备好了，就会触发这个事件，就像传送带送来了一批货物。这个事件会带一个参数，就是这块数据本身，通常是一个 Buffer 对象。end事件：当文件读取完毕，就会触发这个事件，就像传送带停止运行了，告诉你所有的货物都送到了。error事件：如果读取过程中发生错误，就会触发这个事件，就像传送带卡住了。这个事件会带一个参数，就是错误对象，告诉你出了什么问题。
如何使用 fs.createReadStream：驾驭数据之流
使用 fs.createReadStream 非常简单，就像操作传送带一样：
-
首先，你需要创建一个可读流对象，就像启动传送带：
const fs = require('fs'); const readableStream = fs.createReadStream('./my-large-file.txt'); -
然后，你需要监听
data事件，就像在传送带旁边等着接收货物：readableStream.on('data', (chunk) => { // 处理数据块，比如打印出来或者写入另一个文件 console.log(chunk.toString()); }); -
最后，你需要监听
end事件，就像货物全部送达后做一些清理工作：readableStream.on('end', () => { console.log('文件读取完毕'); }); -
别忘了监听
error事件，以防传送带出故障：readableStream.on('error', (err) => { console.error('读取文件出错:', err); });
流管道：连接数据之路
Node.js 还提供了一种更便捷的方式来处理流：管道 。管道就像把多个传送带连接起来，让货物自动从一个传送带流向另一个传送带。你可以使用管道符号 (|) 来连接两个流，比如把一个可读流连接到一个可写流，这样就可以直接把文件内容写入另一个文件，而不用手动处理数据块。
const readableStream = fs.createReadStream('./my-large-file.txt');
const writableStream = fs.createWriteStream('./my-new-file.txt');
readableStream.pipe(writableStream);
总结：流的力量
fs.createReadStream 是 Node.js 中一个非常强大的工具，它让我们可以高效地处理大文件，避免内存溢出。通过理解可读流的原理和使用方法，我们可以构建更健壮、更高效的 Node.js 应用程序。
常见问题解答
-
fs.createReadStream 和 fs.readFile 有什么区别？
fs.createReadStream用于创建可读流，可以逐块读取文件，适合处理大文件；fs.readFile则是一次性读取整个文件内容，适合处理小文件。 -
如何控制读取速度？
可以通过
readableStream.pause()暂停读取，readableStream.resume()恢复读取来控制读取速度。 -
如何处理读取错误？
可以通过监听
error事件来处理读取错误，例如记录错误日志或向用户显示错误信息。 -
如何将读取到的数据写入另一个文件？
可以使用管道将可读流连接到可写流，例如
fs.createWriteStream，从而将数据写入另一个文件。 -
如何处理非文本文件，例如图片或视频？
fs.createReadStream可以读取任何类型的文件，包括二进制文件。读取到的数据块会以 Buffer 对象的形式传递，你可以根据文件类型进行相应的处理。
