本文共 1202 字，大约阅读时间需要 4 分钟。

EventEmitter 和 管道流（Stream） 是 Node.js 中处理数据流的核心技术，广泛应用于文件读写、网络通信等场景。以下将从基础概念到实用案例详细阐述。

1. EventEmitter 的基础

EventEmitter 是 Node.js 官方提供的事件发射器模块，主要用于管理和触发事件。其核心功能包括：

• 定义自定义事件
• 注册事件监听器
• 操作事件上下文

事件驱动编程是一种灵活的编程范式，适用于I/O操作、数据处理等场景。例如，文件操作常常涉及异步性，而EventEmitter 提供了一个统一的方式来处理这些异步操作。

2. 文件流操作的管道流

在实际应用中，文件流（Stream） 是处理大文件读写的高效方法。通过将读取流（ReadableStream）与写入流（WriteableStream）之间建立管道（Pipe），可以实现数据的无阻塞传输。

实现步骤

3. 实用案例：文件复制

以下是通过管道流实现文件内容复制的完整代码示例：

const fs = require('fs');// 读取源文件const readStream = fs.createReadStream('./package.json');// 写入目标文件const writeStream = fs.createWriteStream('./copy.json');// 建立管道连接readStream.pipe(writeStream);// 处理读取完成事件readStream.on('end', () => {    console.log('读取完成，准备写入');});// 处理写入完成事件writeStream.on('finish', () => {    console.log('写入完成');});// 处理错误事件readStream.on('error', (err) => {    console.error('读取错误:', err);});writeStream.on('error', (err) => {    console.error('写入错误:', err);});

4. 总结

EventEmitter 和 管道流 技术为 Node.js 应用提供了高效的数据处理方式。通过合理配置事件监听器和建立数据流连接，可以实现文件读写、网络通信等任务的高效处理。这种模式不仅提升了处理效率，还大大减少了内存占用，使得在处理大规模数据时表现出色。