Node.js中使用fluent-ffmpeg流式输出MP3时提示格式不可用问题

问题场景 #

在Node.js应用中使用fluent-ffmpeg截断并流式处理MP3音频文件时，出现以下异常：

• 直接将处理结果写入文件时一切正常
• 将输出收集到内存缓冲区时，fluent-ffmpeg抛出错误：Output format mp3 is not available

关键信息 #

• FFmpeg安装已包含libmp3lame编码器
• 仅流式输出到缓冲区时触发问题
• 已尝试用.format('mp3')显式设置格式，无效
• 相同参数在命令行运行FFmpeg无错误，问题出在fluent-ffmpeg的流式处理逻辑

问题代码 #

import { PassThrough } from 'stream';
import ffmpeg from 'fluent-ffmpeg';
import fs from 'fs';

function truncateAudioStream(inputStream, duration) {
  return new Promise((resolve, reject) => {
    let audioBuffer = Buffer.from([]);
    const passThrough = new PassThrough();

    ffmpeg(inputStream)
      .setFfmpegPath('C:\\Program Files\\FFmpeg\\bin\\ffmpeg.exe')
      .audioCodec('libmp3lame')
      .setDuration(duration)
      .on('end', () => resolve(audioBuffer))
      .on('error', reject)
      .on('data', (chunk) => {
        audioBuffer = Buffer.concat([audioBuffer, chunk]);
      })
      .pipe(passThrough);
  });
}

const inputAudioPath = 'path/to/input.mp3';
const inputStream = fs.createReadStream(inputAudioPath);
truncateAudioStream(inputStream, 25)
  .then((truncatedAudioBuffer) => {
    // Handling the buffer
  })
  .catch((error) => {
    console.error('Error truncating audio stream:', error);
  });

错误输出 #

Error truncating audio stream: Error: Output format mp3 is not available
at C:\path\to\fluent-ffmpeg\lib\capabilities.js:589:21
...

问题原因 #

1. 流式输出无格式推断：当输出到文件时，FFmpeg可通过文件名后缀推断格式；但流式输出时没有文件名，必须显式指定输出格式，仅设置音频编码器不足以让FFmpeg确定输出格式。
2. 事件监听错误：原代码监听了ffmpeg实例的data事件，该事件实际是FFmpeg进程的控制台输出，而非处理后的音频流数据，正确的做法是监听目标流（PassThrough）的data事件。

修复方案 #

修正后的代码 #

import { PassThrough } from 'stream';
import ffmpeg from 'fluent-ffmpeg';
import fs from 'fs';

function truncateAudioStream(inputStream, duration) {
  return new Promise((resolve, reject) => {
    let audioBuffer = Buffer.from([]);
    const outputStream = new PassThrough();

    // 监听输出流的data事件收集音频数据
    outputStream.on('data', (chunk) => {
      audioBuffer = Buffer.concat([audioBuffer, chunk]);
    });

    // 流结束时返回缓冲区
    outputStream.on('end', () => resolve(audioBuffer));

    ffmpeg(inputStream)
      .setFfmpegPath('C:\\Program Files\\FFmpeg\\bin\\ffmpeg.exe')
      .audioCodec('libmp3lame')
      .setDuration(duration)
      .outputFormat('mp3') // 显式指定输出格式（关键修复）
      .on('error', reject)
      .pipe(outputStream);
  });
}

// 调用示例
const inputAudioPath = 'path/to/input.mp3';
const inputStream = fs.createReadStream(inputAudioPath);
truncateAudioStream(inputStream, 25)
  .then((truncatedAudioBuffer) => {
    console.log('截断完成，缓冲区大小：', truncatedAudioBuffer.length);
    // 这里处理缓冲区逻辑
  })
  .catch((error) => {
    console.error('截断音频流出错:', error);
  });

核心修复点 #

• 使用.outputFormat('mp3')显式告诉FFmpeg输出格式，替代无效的.format('mp3')
• 将data事件监听从ffmpeg实例转移到目标PassThrough流，确保收集的是处理后的音频数据

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