用Node流拼接音频文件

const fs = require('fs');
const { Readable, Writable } = require('stream');

const file1 = fs.createReadStream('file1.mp3');
const file2 = fs.createReadStream('file2.mp3');

const outputFile = fs.createWriteStream('output.mp3');

class ConcatStream extends Writable {
  constructor(options) {
    super(options);
  }
  
  _write(chunk, encoding, callback) {
    this.emit('data', chunk);
    callback();
  }
}

const concatStream = new ConcatStream();
concatStream.on('data', (chunk) => {
  outputFile.write(chunk);
});

file1.pipe(concatStream);
file2.pipe(concatStream);

file2.on('end', () => {
  outputFile.end();
});