Node.js的fluent-ffmpeg能否异步处理Opus文件流并实时输出？

需求与现状 #

• 处理场景：加载大型Opus文件，用fluent-ffmpeg处理后实时输出流供后续使用
• 当前可运行代码（需替换文件路径）：

const fs = require('fs');
const fluentffmpeg = require('fluent-ffmpeg');
var stream=fs.createReadStream("d:/PD_maid/music_temp/YTTemp/How many times do we have to teach you this lesson old man! (Cafe de touhou 1-8 albums)[RY7FpB9BZH4].opus")
var ffmpeg_audio_stream_C = fluentffmpeg(stream)

var streamOpt;
ffmpeg_audio_stream_C
    .toFormat('hls')
    .audioChannels(2)
    .audioFrequency(48000)
    .audioBitrate('1536k');

ffmpeg_audio_stream_C.on("error", (error) => {
    console.log("ffmpegErr" + error);
});
streamOpt = ffmpeg_audio_stream_C.pipe();

stream.on("data", (c) => {
    console.log("inp got data")
})
streamOpt.on("data", (c) => {
    console.log("Opt got data")
})

streamOpt.pipe(fs.createWriteStream("d:/PD_maid/music_temp/YTTemp/How many times do we have to teach you this lesson old man! (Cafe de touhou 1-8 albums)[RY7FpB9BZH4].hls"))

问题现象 #

• 预期效果：控制台交替输出inp got data和Opt got data，输出文件随处理逐步增大
• 实际效果：先长时间批量输出inp got data，内存占用持续上涨，之后才一次性输出大量Opt got data；但处理WebM文件时完全符合预期

原因分析 #

Opus通常封装在Ogg容器中，ffmpeg需要读取足够的元数据或完整帧结构才能启动处理；而WebM容器支持流式解析，可边读边处理。另外Node.js默认的读流高水位线过高，加上ffmpeg的输入缓存机制，导致大量数据被预读到内存中。

解决方案 #

通过调整读流参数和ffmpeg输入选项，强制实现边读边处理：

修改后的代码：

const fs = require('fs');
const fluentffmpeg = require('fluent-ffmpeg');

// 降低读流高水位线，减少预读数据量
const stream = fs.createReadStream(
  "d:/PD_maid/music_temp/YTTemp/How many times do we have to teach you this lesson old man! (Cafe de touhou 1-8 albums)[RY7FpB9BZH4].opus",
  { highWaterMark: 64 * 1024 } // 设置为64KB，可按需调整
);

const ffmpeg_audio_stream_C = fluentffmpeg(stream)
  // 添加ffmpeg参数，跳过不必要的预分析，快速启动处理
  .addInputOption('-probesize', '32k') // 限制探测文件格式的数据量
  .addInputOption('-analyzeduration', '0') // 跳过流时长分析
  .toFormat('hls')
  .audioChannels(2)
  .audioFrequency(48000)
  .audioBitrate('1536k');

ffmpeg_audio_stream_C.on("error", (error) => {
  console.log("ffmpegErr" + error);
});

const streamOpt = ffmpeg_audio_stream_C.pipe();

stream.on("data", (c) => {
  console.log("inp got data")
})
streamOpt.on("data", (c) => {
  console.log("Opt got data")
})

streamOpt.pipe(fs.createWriteStream("d:/PD_maid/music_temp/YTTemp/How many times do we have to teach you this lesson old man! (Cafe de touhou 1-8 albums)[RY7FpB9BZH4].hls"))

关键调整说明 #

• highWaterMark: 64 * 1024：缩小Node.js读流每次读取的数据块，避免一次性加载大量数据到内存
• -probesize 32k：告诉ffmpeg仅用32KB数据探测文件格式，减少预读
• -analyzeduration 0：跳过对输入流的时长分析，让ffmpeg立即开始处理

调整后即可实现Opus文件的实时流式处理，达到和WebM一致的边读边输出效果。

内容的提问来源于stack exchange，提问作者DanielBUBU