七天学会 Node.js 流：掌握数据流动的艺术

前端

2023-11-06 06:18:11

Node.js 中的流是什么？

流是数据的集合，可以将它理解成数据链表或字符串的形式，区别在于流中的数据并不能立即可用，这里又可以将其理解成水流。你可以通过流来操作大量数据，而无需将它们全部放入内存中。

在 Node.js 中，流是一个 EventEmitter，这意味着它可以发出事件。当流中有新数据可用时，它会发出 data 事件。当流结束时，它会发出 end 事件。

流的类型

在 Node.js 中，有三种类型的流：

可读流（Readable Stream）：可读流允许您从流中读取数据。例如，您可以使用文件流来读取文件中的数据。
可写流（Writable Stream）：可写流允许您将数据写入流。例如，您可以使用文件流来将数据写入文件。
双工流（Duplex Stream）：双工流既是可读的，也是可写的。例如，您可以使用网络流来在两个网络连接之间发送和接收数据。

如何创建和使用流

要创建流，可以使用 Node.js 的 stream 模块。以下是一个创建可读流的示例：

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.');
});

这个脚本将创建一个可读流，该流将从名为 file.txt 的文件中读取数据。当流中有新数据可用时，它将发出 data 事件，并将在控制台打印数据。当流结束时，它将发出 end 事件，并在控制台打印一条消息。

要创建可写流，可以使用 Node.js 的 stream 模块。以下是一个创建可写流的示例：

const fs = require('fs');

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

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

writableStream.end();

这个脚本将创建一个可写流，该流将把数据写入名为 file.txt 的文件。它将把字符串 Hello, world! 写入流，然后结束流。

要创建双工流，可以使用 Node.js 的 stream 模块。以下是一个创建双工流的示例：

const net = require('net');

const socket = net.createConnection({
  host: 'localhost',
  port: 8080
});

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

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

socket.end();