ZLMediaKit中FFmpegSource录制功能的多线程问题分析与修复

问题背景

在ZLMediaKit流媒体服务器项目中，FFmpegSource模块负责将外部媒体源通过FFmpeg拉流转发到服务器内部。该模块支持HLS和MP4录制功能，但在实际使用中发现当同时开启这两种录制时会出现线程安全问题。

问题现象

当用户通过API接口addFFmpegSource添加一个FFmpeg媒体源并同时开启HLS和MP4录制时，服务器会抛出异常。核心错误表现为在多线程环境下对媒体源的录制设置操作存在竞态条件。

技术分析

通过分析源码发现，问题出在FFmpegSource.cpp文件的onGetMediaSource方法中。该方法在获取到媒体源后会立即设置HLS和MP4录制，但这些操作是在FFmpeg的工作线程中执行的，而录制设置需要保证在媒体源所属的EventPoller线程中执行。

在ZLMediaKit的架构设计中：

1. 每个媒体源都有其所属的EventPoller线程
2. 所有对媒体源的操作必须在其所属线程中执行以保证线程安全
3. FFmpegSource的工作线程与媒体源的EventPoller线程通常是不同的

解决方案

修复方案是将录制设置操作通过async方法调度到媒体源所属的EventPoller线程中执行。具体修改如下：

1. 对于HLS录制设置：

src->getOwnerPoller()->async([=]() mutable {
    src->setupRecord(Recorder::type_hls, true, "", 0);
});

2. 对于MP4录制设置：

src->getOwnerPoller()->async([=]() mutable {
    src->setupRecord(Recorder::type_mp4, true, "", 0);
});

技术意义

这个修复不仅解决了当前的崩溃问题，更重要的是：

1. 遵循了ZLMediaKit的线程模型设计原则
2. 确保了多线程环境下媒体源操作的线程安全性
3. 为后续类似功能的开发提供了正确的编程范式

经验总结

在流媒体服务器开发中，正确处理多线程问题至关重要。特别是在涉及以下场景时：

• 跨线程操作媒体源
• 录制功能设置
• 异步事件处理

开发者需要清楚地了解每个对象的线程归属，并通过适当的线程调度机制确保线程安全。ZLMediaKit通过EventPoller机制提供了良好的线程模型基础，但开发者仍需在具体实现中正确应用这一模型。