探索 Node.js 可读流：数据处理的新视角

2023-12-07 23:25:59

Node.js 中的流：处理流数据的利器

在 Node.js 中，流是一种抽象接口，用于处理连续的数据流。它提供了一个基础的 API，让开发人员可以轻松地构建实现流接口的对象。Node.js 中有许多内置的流对象，如 HTTP 请求和进程文件，供开发人员灵活使用。

流的类型

Node.js 中的流根据其功能和特性分为四种类型：

可读流 (Readable Stream)： 从流中读取数据的流，如从文件读取数据或从网络接收数据。

const fs = require('fs');

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

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

可写流 (Writable Stream)： 向流中写入数据的流，如将数据写入文件或发送数据到网络。

const fs = require('fs');

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

writableStream.write('Hello world!');

双工流 (Duplex Stream)： 既是可读流又是可写流，允许同时读取和写入数据，如网络套接字。

const net = require('net');

const duplexStream = net.createServer();

duplexStream.on('connection', (socket) => {
  socket.on('data', (data) => {
    socket.write(data);
  });
});

转换流 (Transform Stream)： 在读取数据的同时对数据进行转换的流，如对数据进行加密或压缩。

const crypto = require('crypto');

const transformStream = crypto.createCipher('aes-256-cbc', 'mysecretkey');

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

流的创建

Node.js 中的流可以通过多种方式创建，最常见的方法是使用 stream 模块中的类：

可读流：require('stream').Readable()
可写流：require('stream').Writable()
双工流：require('stream').Duplex()
转换流：require('stream').Transform()

除了这些类，Node.js 还有一些内置的流对象：

HTTP 请求：http.request()
进程文件：fs.createReadStream() 和 fs.createWriteStream()
网络套接字：net.createServer()

流的操作

创建流对象后，可以使用以下方法对流进行操作：

可读流：
- read()：从流中读取数据。
- pause()：暂停从流中读取数据。
- resume()：继续从流中读取数据。
- pipe()：将流的数据管道到另一个流。
可写流：
- write()：向流中写入数据。
- end()：结束向流中写入数据。
- cork()：暂时停止向流中写入数据。
- uncork()：继续向流中写入数据。
双工流：同时支持可读流和可写流的操作。
转换流：
- _transform()：在读取数据的同时对数据进行转换。
- _flush()：在流结束时对剩余的数据进行转换。