NodeJS实现MKV转MP4实时流式传输遇问题求助

一、无转换流式无音频的原因及修复 #

直接将MKV文件以video/mp4的Content-Type流式传输，本质是欺骗浏览器识别容器，但MKV内部的音频编码可能不被MP4容器支持（比如MKV常用的Vorbis、FLAC编码，MP4原生只支持AAC、MP3等），所以浏览器无法解析音频流。

修复方案（分两种场景） #

1. 音视频编码兼容MP4的情况
   如果你的MKV文件本身是H.264视频 + AAC音频（可通过ffmpeg -i input.mkv查看编码信息），不需要转码，只做容器封装转换即可，速度极快：

const command = ffmpeg(filePath)
  .format('mp4')
  .videoCodec('copy') // 直接复制视频流，不转码
  .audioCodec('copy') // 直接复制音频流，不转码
  .outputOptions('-movflags frag_keyframe+empty_moov+default_base_moof') // 适配流式传输的MP4参数
  .on('error', (err) => {
    console.error('封装转换出错:', err.message);
    res.status(500).end();
  });

res.setHeader('Content-Type', 'video/mp4');
command.pipe(res, { end: true });

2. 编码不兼容的情况
   这种情况必须转码，直接跳转至下文FFmpeg转码方案。

二、FFmpeg转码时"Output stream closed"错误修复 #

这个错误通常是因为未处理浏览器的Range请求，或者FFmpeg参数不适配流式传输，导致响应流被提前关闭。以下是完整修复方案：

1. 兼容Range请求的流式转码实现 #

浏览器播放视频时会发送Range头请求分段内容，需要解析该请求并让FFmpeg对应输出分段流：

import { exec } from 'child_process';
import fs from 'fs';

public async streamById(req: Request, res: Response) {
  const movieId = req.params.id;
  const movie = await MovieModel.findById(movieId);
  if (!movie) return res.status(404).send({ message: 'Movie not found' });

  const filePath = movie.path;
  const stat = fs.statSync(filePath);
  const fileSize = stat.size;
  const range = req.headers.range;

  // 解析Range参数，默认取整个文件
  let start = 0;
  let end = fileSize - 1;
  if (range) {
    const parts = range.replace(/bytes=/, '').split('-');
    start = parseInt(parts[0], 10);
    end = parts[1] ? parseInt(parts[1], 10) : fileSize - 1;
  }

  // 获取视频总时长，用于FFmpeg计算分段时间
  const getDuration = () => {
    return new Promise<number>((resolve, reject) => {
      exec(`ffmpeg -i "${filePath}" 2>&1 | grep Duration`, (err, stdout) => {
        if (err) reject(err);
        const durationMatch = stdout.match(/Duration: (\d+):(\d+):(\d+\.\d+)/);
        if (!durationMatch) reject(new Error('无法获取视频时长'));
        const hours = parseInt(durationMatch[1], 10);
        const minutes = parseInt(durationMatch[2], 10);
        const seconds = parseFloat(durationMatch[3]);
        resolve(hours * 3600 + minutes * 60 + seconds);
      });
    });
  };

  try {
    const duration = await getDuration();
    const startSeconds = (start / fileSize) * duration;
    const durationSeconds = ((end - start + 1) / fileSize) * duration;

    // 设置正确的响应头，支持分段传输
    res.setHeader('Content-Type', 'video/mp4');
    res.setHeader('Accept-Ranges', 'bytes');
    res.setHeader('Content-Length', end - start + 1);
    res.setHeader('Content-Range', `bytes ${start}-${end}/${fileSize}`);
    res.statusCode = range ? 206 : 200;

    // FFmpeg转码参数，适配流式分段输出
    const ffmpegArgs = [
      '-ss', startSeconds.toString(), // 转码起始时间
      '-i', filePath,
      '-t', durationSeconds.toString(), // 转码持续时长
      '-c:v', 'libx264',
      '-c:a', 'aac',
      '-preset', 'veryfast', // 最快转码预设，平衡速度与质量
      '-movflags', 'frag_keyframe+empty_moov+default_base_moof', // 生成碎片化MP4，支持流式
      '-f', 'mp4',
      '-' // 输出到标准输出，直接pipe到响应
    ];

    const ffmpegProcess = exec(`ffmpeg ${ffmpegArgs.join(' ')}`);
    ffmpegProcess.stdout.pipe(res);

    // 捕获FFmpeg日志用于调试
    ffmpegProcess.stderr.on('data', (data) => {
      console.debug('FFmpeg运行日志:', data.toString());
    });

    ffmpegProcess.on('error', (err) => {
      console.error('转码出错:', err.message);
      if (!res.headersSent) res.status(500).end();
    });

    ffmpegProcess.on('exit', (code) => {
      if (code !== 0) console.error('FFmpeg异常退出，代码:', code);
      res.end();
    });
  } catch (err) {
    console.error('初始化转码失败:', err);
    res.status(500).send({ message: '转码服务出错' });
  }
}

2. 关键参数与注意事项 #

• -movflags frag_keyframe+empty_moov+default_base_moof：生成无需预先生成全量元数据的碎片化MP4，可立即开始输出，适配流式场景；
• 避免手动调用res.end()：FFmpeg输出流结束后会自动关闭响应，提前调用会导致流中断；
• 服务器资源检查：转码依赖CPU，veryfast是最快的转码预设，若服务器CPU过载需考虑限流或硬件加速；
• FFmpeg版本：确保服务器安装最新版FFmpeg，旧版本可能不支持部分流式参数。

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