Node.js中流(stream)的使用方法示例

以下是Node.js中流的使用方法示例的完整攻略。

什么是流？

流是Node.js中许多模块所使用的核心概念之一，它是一种用于处理大量数据的技术。流是将数据拆分为小块一次一块地处理，而不是一次将整个数据处理完成。这样可以减少内存的使用，提高处理效率。

流的类型

Node.js中有四个流的类型，分别是：可读（Readable）、可写（Writable）、可读可写（Duplex）和转换（Transform）。其中，可读流向目标节点提供数据，可写流从源节点接受数据，可读可写是两者的结合，转换流可以将数据从一种格式转换成另一种格式。

流的使用方法

可读流

const fs = require("fs");
const readStream = fs.createReadStream("example.txt");
readStream.setEncoding("UTF8");
let data = "";
readStream.on("data", chunk => {
    data += chunk;
});
readStream.on("end", () => {
    console.log("读取完成");
    console.log(data);
});

上述代码使用fs.createReadStream()方法创建可读流，指定文件名为example.txt。使用setEncoding()方法将流的编码格式设置为UTF8编码。使用on()方法监听data事件，读取数据块，并将其拼接到data变量中。当读取完成时，end事件被触发，输出读取的数据。

可写流

const fs = require("fs");
const writeStream = fs.createWriteStream("output.txt");
writeStream.write("Hello World", "UTF8");
writeStream.end();
writeStream.on("finish", () => {
    console.log("写入完成");
});

上述代码使用fs.createWriteStream()方法创建可写流，指定文件名为output.txt。使用write()方法写入Hello World的数据块。使用end()方法结束写入。使用on()方法监听finish事件，输出写入完成的信息。

总结

可读流和可写流分别用于向目标节点提供数据和从源节点接受数据。在使用可读流时，需要监听data事件以读取数据，监听end事件以捕获流的结束。在使用可写流时，需要使用write()方法写入数据块，使用end()方法结束写入，监听finish事件以捕获流的结束。