Node.js：将可读流管道拆分为多个顺序可写流

解决方法@H_502_19@

在寻找相关问题的答案时,我碰到了这个问题.如何解析文件并将其行拆分为单独的文件,具体取决于行中的某些类别值.

我尽力改变我的代码,使其与您的问题更相关.然而,这很快就适应了.没有测试过.将其视为伪代码.

var fs = require('fs'),through = require('through');

 var destCount = 0,dest,size = 0,MAX_SIZE = 1000;

readableStream
  .on('data',function(data) {
    var out = data.toString() + "\n";
    size += out.length;
    if(size > MAX_SIZE) {
      dest.emit("end");
      dest = null;
      size = 0;
    }
    if(!dest) {
      // option 1. manipulate data before saving them.
      dest = through();
      dest.pipe(fs.createWriteStream("log" + destCount))
      // option 2. write directly to file
      // dest = fs.createWriteStream("log" + destCount);
    }
    dest.emit("data",out);
  })
  .on('end',function() {
    dest.emit('end');
  });