创建可读流

首先，我们使用 fs.createReadStream 方法创建一个指向二进制文件的可读流。这个方法接收一个文件路径作为参数，并返回一个 ReadStream 对象。

const readStream = fs.createReadStream('example.bin');

这行代码会打开 example.bin 文件，并准备从中读取数据。ReadStream 对象是一个可读流，它实现了 Node.js 中的 stream.Readable 接口。

监听数据事件

接下来，我们监听 ReadStream 对象的 data 事件。这个事件会在流读取到数据块时触发。

readStream.on('data', (chunk) => {// 处理二进制数据块console.log('读取到数据块：', chunk);
});

当 data 事件触发时，它的回调函数会接收一个参数 chunk，这是一个 Buffer 对象，包含了读取到的二进制数据块。在这个回调函数中，你可以处理这些数据，比如将它们写入到另一个文件、发送到网络客户端、或者进行解析和转换。

处理 Buffer 对象

Buffer 对象是 Node.js 中用来处理二进制数据的类。它提供了一系列的方法来操作二进制数据，比如读取和写入特定类型的数据（如整数、浮点数、字符串等）、进行缓冲区的切片、复制、拼接等操作。

在上面的示例中，chunk 就是一个 Buffer 对象。你可以使用 Buffer 类的方法来处理它，比如使用 chunk.toString() 方法将二进制数据转换为字符串（如果你知道数据的编码）。

监听结束和错误事件

除了 data 事件，我们还监听了 end 和 error 事件。

readStream.on('end', () => {console.log('读取完成。');
});readStream.on('error', (error) => {console.error('读取文件时发生错误：', error);
});

当没有更多数据可读时，end 事件会被触发，这时你可以执行一些清理工作，比如关闭文件、释放资源等。

如果在读取过程中发生错误，比如文件不存在、权限不足等，error 事件会被触发，并且它的回调函数会接收一个 Error 对象作为参数，你可以使用这个对象来获取错误信息并进行处理。

总结

通过使用 Node.js 中的流和 Buffer 类，你可以高效地处理二进制数据。流允许你分块地读取和写入数据，而不需要一次性将整个文件内容加载到内存中。Buffer 类则提供了丰富的方法来操作二进制数据。这种组合使得 Node.js 在处理大型文件和网络通信方面非常强大和高效。