理解Node.js中的可读流与可写流

2024-01-22 07:51:51

可读流和可写流概述

在Node.js中，流是一种对象，它表示一系列按顺序传输的数据。流可以是可读的、可写的或可读写的。

可读流：可读流允许您从流中读取数据。
可写流：可写流允许您向流中写入数据。
可读写流：可读写流允许您既可以从流中读取数据，也可以向流中写入数据。

可读流

可读流通常用于从文件、网络连接或其他来源读取数据。要创建一个可读流，您可以使用fs.createReadStream()函数或net.createServer()函数。

以下是如何使用fs.createReadStream()函数创建一个可读流的示例：

const fs = require('fs');

const readableStream = fs.createReadStream('file.txt');

readableStream.on('data', (chunk) => {
  console.log(chunk.toString());
});

readableStream.on('end', () => {
  console.log('All data has been read.');
});

可写流

可写流通常用于将数据写入文件、网络连接或其他目的地。要创建一个可写流，您可以使用fs.createWriteStream()函数或net.createServer()函数。

以下是如何使用fs.createWriteStream()函数创建一个可写流的示例：

const fs = require('fs');

const writableStream = fs.createWriteStream('file.txt');

writableStream.write('Hello, world!');

writableStream.end('Goodbye, world!');

流水线和管道

流水线是将多个流连接在一起的一种机制，以便数据可以从一个流流向另一个流。管道是创建流水线的一种简单方法。要创建一个管道，您可以使用pipe()函数。

以下是如何使用pipe()函数创建一个流水线的示例：

const fs = require('fs');

const readableStream = fs.createReadStream('file1.txt');
const writableStream = fs.createWriteStream('file2.txt');

readableStream.pipe(writableStream);