本文介绍解决 Python 中使用两个命名管道（FIFO）向 FFmpeg 同时输入视频和音频流时进程阻塞的问题，核心在于避免 open() 调用因管道未被及时读取而挂起，推荐采用多线程分别写入音视频管道。
本文介绍解决 python 中使用两个命名管道（fifo）向 ffmpeg 同时输入视频和音频流时进程阻塞的问题，核心在于避免 `open()` 调用因管道未被及时读取而挂起，推荐采用多线程分别写入音视频管道。
在使用 FFmpeg 处理实时音视频流时，常需将独立生成的视频流与音频流通过命名管道（FIFO）并行输入。但直接按顺序执行 open(AUDIO_PIPE_NAME, 'wb') 会导致程序卡死——这是因为 Linux 命名管道默认采用同步阻塞语义：任一端（尤其是写端）在打开时，若无对应读端已就绪，调用将永久阻塞。而 FFmpeg 启动后虽会尝试读取两个输入，但由于其内部 I/O 调度顺序及缓冲机制，并不能保证两个 -i 对应的管道读取操作“同时就绪”，导致第二个 open() 无法返回。
✅ 正确做法是：将每个管道的写入操作置于独立线程中启动，确保两个 open() 调用几乎同时发生，使 FFmpeg 能在同一时刻检测到两个管道均有写端就绪，从而顺利建立双向通信。
以下为可运行的完整示例：
import os
import subprocess
import threading
import time
VIDEO_PIPE_NAME = "/tmp/ffmpeg_video_pipe"
AUDIO_PIPE_NAME = "/tmp/ffmpeg_audio_pipe"
# 创建命名管道
os.mkfifo(VIDEO_PIPE_NAME)
os.mkfifo(AUDIO_PIPE_NAME)
# 启动 FFmpeg 进程（注意：-listen 1 仅适用于 HTTP 输出，此处为流式 MP4 over HTTP）
ffmpeg_process = subprocess.Popen([
"ffmpeg",
"-i", VIDEO_PIPE_NAME,
"-i", AUDIO_PIPE_NAME,
"-c:v", "copy",
"-c:a", "copy",
"-f", "mp4",
"-movflags", "frag_keyframe+empty_moov",
"http://0.0.0.0:8081"
], stdin=subprocess.DEVNULL, stderr=subprocess.PIPE)
# 定义写入函数（模拟数据写入，实际中替换为你的 AV 数据源）
def write_to_pipe(pipe_path, data_generator, name):
try:
with open(pipe_path, 'wb') as pipe:
print(f"[{name}] 管道已打开，开始写入...")
for chunk in data_generator:
pipe.write(chunk)
pipe.flush()
time.sleep(0.01) # 模拟流控，避免过快压垮管道缓冲区
except BrokenPipeError:
print(f"[{name}] 写入中断：FFmpeg 可能已退出")
except Exception as e:
print(f"[{name}] 写入异常：{e}")
# 模拟音视频数据生成器（实际项目中应替换为真实帧数据）
def video_data():
# 示例：发送一个极简的 H.264 Annex B 格式 SPS（仅示意）
yield b'\x00\x00\x00\x01\x67\x42\x80\x1E\xDA\x02\x58\x00\x00\x07\xD0\x00\x00\x00\x01\x68\xCE\x38\x80'
def audio_data():
# 示例：发送一个 AAC ADTS 头（仅示意）
yield b'\xFF\xF1\x40\x40\x00\x00\x00\x00\x00\x00\x00\x00'
# 启动两个写入线程（关键！避免阻塞）
video_thread = threading.Thread(target=write_to_pipe, args=(VIDEO_PIPE_NAME, video_data(), "VIDEO"))
audio_thread = threading.Thread(target=write_to_pipe, args=(AUDIO_PIPE_NAME, audio_data(), "AUDIO"))
video_thread.start()
audio_thread.start()
# 可选：等待线程完成（或根据业务逻辑控制生命周期）
try:
video_thread.join()
audio_thread.join()
except KeyboardInterrupt:
print("\n正在关闭...")
finally:
ffmpeg_process.terminate()
ffmpeg_process.wait()
# 清理 FIFO
os.unlink(VIDEO_PIPE_NAME)
os.unlink(AUDIO_PIPE_NAME)
⚠️ 注意事项：
-
必须使用
threading.Thread并发打开两个管道，不可顺序调用open()； - FFmpeg 的
-listen 1仅对http://输出协议有效（启用 HTTP 服务器模式），若目标为本地文件或其它协议，请移除该参数； - 实际生产中，
video_data()和audio_data()应对接真实采集/解码模块（如 OpenCV、PyAV、GStreamer），并严格遵循时间戳对齐（PTS/DTS）； - 建议添加超时机制与异常重试逻辑，防止单侧流中断导致整体挂起；
- 若追求更高稳定性与抽象层级，可关注即将发布的
ffmpegiov0.19+ 版本，其已原生支持多输入管道的异步写入管理。
通过线程化解耦写入时机，即可彻底规避命名管道初始化阻塞问题，实现音视频双流稳定、低延迟地馈入 FFmpeg 处理管线。
Python免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 Python 的核心概念和高级技巧！
