Node.js 设计模式：使用流进行编码

2024-02-02 16:17:56

利用流增强 Node.js 应用程序：实现编码、解码及构建健壮系统

流：Node.js 中的数据传输管道

流在 Node.js 中扮演着数据传输的关键角色，它们可以生成或消费数据，并表示各种数据源，如文件、网络连接或内存缓冲区。这种抽象概念为处理数据提供了强大的工具，可用于执行读取、写入、转换和过滤等操作。

利用流进行编码和解码

流的强大功能在编码和解码任务中得到了充分体现。编码涉及将文件或数据转换为可通过网络传输的压缩格式。我们可以使用 Node.js 内置的流和压缩模块，如 zlib，轻松实现这一过程。

对文件进行编码：

const fs = require('fs');
const zlib = require('zlib');

const readStream = fs.createReadStream('input.txt');
const gzipStream = zlib.createGzip();
readStream.pipe(gzipStream).pipe(fs.createWriteStream('output.gz'));

对数据进行解码：

const zlib = require('zlib');

const inputData = Buffer.from('...');
const gunzipStream = zlib.createGunzip();
gunzipStream.pipe(fs.createWriteStream('output.txt'));
gunzipStream.write(inputData);
gunzipStream.end();

构建健壮且可扩展的 Node.js 应用程序

流不仅仅是处理数据流的工具。它们还可以帮助构建更健壮、更可扩展的 Node.js 应用程序，尤其是在需要处理大量并发请求或数据密集型任务的情况下。

构建 Web 服务器：

const http = require('http');
const stream = require('stream');

const server = http.createServer((req, res) => {
  const duplexStream = new stream.Duplex();
  req.pipe(duplexStream).pipe(res);
});

server.listen(8080);

构建数据处理应用程序：

const stream = require('stream');
const fs = require('fs');

const transformStream = new stream.Transform();
const readStream = fs.createReadStream('input.txt');
const writeStream = fs.createWriteStream('output.txt');

readStream.pipe(transformStream).pipe(writeStream);