JS Stream详解|极客笔记

JS Stream详解

在JavaScript中，Stream（流）是一种实现异步数据处理的机制。使用流可以逐块读取数据并逐块进行处理，而不需要一次性将全部数据加载到内存中。

什么是Stream？

Stream是一种由多个数据流组成的序列，数据会被分成多个块进行传输和处理。在Node.js中，Stream是一种基础的数据处理API，可以用来处理文件、网络请求、以及其他类型的数据源。

Stream可以分为可读流（Readable）、可写流（Writable）、双向流（Duplex）和转换流（Transform）。其中，可读流用于从数据源读取数据，可写流用于向目标写入数据，双向流则可以同时读取和写入数据，而转换流则是一种特殊的双向流，它可以对数据进行处理后再输出。

使用Stream的好处

使用Stream的主要好处包括：

内存效率：Stream允许逐块处理数据，而不需要将整个数据源加载到内存中。这对处理大型文件和网络数据非常有用。
实时处理：Stream可以实时处理数据，而不需要等到所有数据加载完毕才开始处理。
模块化和可组合：Stream可以链式调用，实现数据处理的模块化和可组合，使得处理逻辑更清晰、可复用。

使用可读流（Readable Stream）

可读流用于从数据源读取数据。Node.js提供了fs模块，可以使用可读流读取文件数据。

const fs = require('fs');
const readableStream = fs.createReadStream('example.txt');

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

readableStream.on('end', () => {
  console.log('Done reading data');
});

运行上面的代码，将会打印出文件的内容（以块为单位），直到读取完文件的所有数据。

使用可写流（Writable Stream）

可写流用于向目标写入数据。Node.js提供了fs模块，可以使用可写流写入文件数据。

const fs = require('fs');
const writableStream = fs.createWriteStream('output.txt');

writableStream.write('Hello World\n');

writableStream.end(() => {
  console.log('Done writing data');
});

上面的代码将会向output.txt文件写入”Hello World”，并在写入完成后输出”Done writing data”。

使用转换流（Transform Stream）

转换流用于处理数据后再输出。Node.js提供了stream模块，可以使用Transform类创建转换流。

const { Transform } = require('stream');

const upperCaseTransform = new Transform({
  transform(chunk, encoding, callback) {
    this.push(chunk.toString().toUpperCase());
    callback();
  }
});

process.stdin.pipe(upperCaseTransform).pipe(process.stdout);

上面的代码将会将输入的数据转换成大写后输出。可以通过键盘输入数据，然后查看转换后的结果。