使用ffmpeg向express服务流转ytdl音频时出现Output stream closed错误

核心错误原因 #

• 路由定义API误用：app.set()是Express用于设置全局配置的接口，定义GET路由需使用app.get()，错误的方法调用导致请求处理逻辑异常
• 不必要的await操作：ytdl()直接返回可读流对象，并非Promise，添加await不会等待拉流完成，反而会干扰流的初始状态
• 缺少异常兜底逻辑：没有监听流错误、客户端断开事件，当客户端提前中断请求、拉流转码失败时，ffmpeg仍在向已关闭的响应流写入数据，就会触发Output stream closed报错

修复后完整代码 #

const express = require('express')
const ffmpeg = require('fluent-ffmpeg')
const ytdl = require('ytdl-core')

const app = express()

app.get('/:id', (req, res) => {
    // 配置响应头，提升浏览器兼容性
    res.set({
        'Content-Type': 'audio/mp3',
        'Content-Disposition': `inline; filename="${req.params.id}.mp3"`
    })

    // 初始化ytdl音频流
    const audioStream = ytdl(req.params.id, { 
        format: 'audioonly', 
        quality: 'highestaudio' 
    })

    // 初始化ffmpeg转码进程
    const ffmpegProcess = ffmpeg(audioStream)
        .toFormat('mp3')
        .audioQuality(2) // 对应MP3 VBR最高音质配置
        .on('error', (err) => {
            console.error('处理失败：', err)
            // 异常时主动结束响应，避免请求挂起
            if (!res.headersSent) res.sendStatus(500)
            res.end()
        })

    // 监听客户端断开事件，主动销毁资源避免报错
    res.on('close', () => {
        ffmpegProcess.kill('SIGKILL')
        audioStream.destroy()
    })

    // 转码结果输出到响应流
    ffmpegProcess.pipe(res, { end: true })
})

// 启动服务监听3000端口
app.listen(3000, () => console.log('服务运行在 http://localhost:3000'))

关键修改说明 #

1. 修正路由定义方法，替换app.set为app.get
2. 移除ytdl前的await，直接传入流对象到ffmpeg
3. 新增ffmpeg错误监听，出现异常时主动结束响应
4. 新增响应流close事件监听，客户端提前断开时主动杀掉ffmpeg进程、销毁音频流，从根源避免输出流已关闭的报错
5. 补充mp3音质配置和响应头，提升服务兼容性

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