node js 二进制流

const fs = require('fs');

// 创建一个可读流
const readStream = fs.createReadStream('input.txt');

// 创建一个可写流
const writeStream = fs.createWriteStream('output.txt');

// 当有数据可读时触发
readStream.on('data', (chunk) => {
  console.log(`Received ${chunk.length} bytes of data.`);
  // 将数据写入到可写流中
  writeStream.write(chunk);
});

// 当所有数据已被写入到底层系统时触发
writeStream.on('finish', () => {
  console.log('All data has been written to output.txt');
});

// 当读取流结束时触发
readStream.on('end', () => {
  console.log('Finished reading from input.txt');
  // 结束写入流
  writeStream.end();
});

const fs = require('fs');

const readStream = fs.createReadStream('largefile.bin', { highWaterMark: 1024 * 1024 }); // 每次读取1MB

readStream.on('data', (chunk) => {
  // 处理每个数据块
  processChunk(chunk);
});

readStream.on('end', () => {
  console.log('Finished reading the file.');
});

function processChunk(chunk) {
  // 处理数据块的逻辑
}