告别命令行！用C#和FFMpegCore给你的视频批量加水印和转码

用C#和FFMpegCore打造企业级视频处理流水线每次看到团队里的小伙伴手动用FFmpeg命令行处理上百个视频文件时我都忍不住想——这简直是在浪费生命。作为经历过这种痛苦的技术负责人我深知自动化视频处理对于内容团队的重要性。今天我将分享如何用C#和FFMpegCore构建一个完整的视频处理系统从基础配置到高级功能实现帮你彻底告别重复劳动。1. 环境搭建与核心配置在开始编码前我们需要搭建好开发环境。不同于简单的控制台应用企业级视频处理系统需要考虑跨平台兼容性和部署便利性。首先通过NuGet安装FFMpegCoredotnet add package FFMpegCore关键配置要点将FFmpeg二进制文件放在项目Resources目录下开发环境与生产环境采用不同路径策略为临时文件设置专用目录避免磁盘碎片推荐使用以下配置方式// 在Program.cs或启动类中初始化全局配置 GlobalFFOptions.Configure(new FFOptions { BinaryFolder RuntimeInformation.IsOSPlatform(OSPlatform.Windows) ? C:\ffmpeg\bin : /usr/local/bin, TemporaryFilesFolder Path.GetTempPath() });注意在Docker部署时建议将FFmpeg作为基础镜像的一部分安装而非随应用打包。2. 构建视频处理基础组件2.1 智能文件处理器创建一个基础文件处理类封装常见操作public class VideoProcessor { private readonly string _outputDir; public VideoProcessor(string outputDir) { _outputDir outputDir; Directory.CreateDirectory(outputDir); } public async TaskMediaAnalysis AnalyzeVideoAsync(string inputPath) { return await FFProbe.AnalyseAsync(inputPath); } public async Taskstring ConvertFormatAsync( string inputPath, VideoCodec videoCodec VideoCodec.LibX264, AudioCodec audioCodec AudioCodec.Aac) { var outputPath Path.Combine(_outputDir, ${Path.GetFileNameWithoutExtension(inputPath)}_converted.mp4); await FFMpegArguments .FromFileInput(inputPath) .OutputToFile(outputPath, false, options options .WithVideoCodec(videoCodec) .WithAudioCodec(audioCodec) .WithFastStart()) .ProcessAsynchronously(); return outputPath; } }2.2 水印添加策略实现可配置的水印添加方案public enum WatermarkPosition { TopLeft, TopRight, BottomLeft, BottomRight, Center } public async Taskstring AddWatermarkAsync( string inputPath, string watermarkPath, WatermarkPosition position, int margin 20) { var positionMap new DictionaryWatermarkPosition, string { [WatermarkPosition.TopLeft] ${margin}:{margin}, [WatermarkPosition.TopRight] $main_w-overlay_w-{margin}:{margin}, // 其他位置映射... }; var outputPath Path.Combine(_outputDir, ${Path.GetFileNameWithoutExtension(inputPath)}_watermarked.mp4); await FFMpegArguments .FromFileInput(inputPath) .AddFileInput(watermarkPath) .OutputToFile(outputPath, false, options options .WithVideoFilters(filterOptions filterOptions .Overlay(positionMap[position])) .WithFastStart()) .ProcessAsynchronously(); return outputPath; }3. 实现批量处理流水线3.1 任务队列设计使用Channel构建高效处理队列public class VideoProcessingQueue { private readonly ChannelVideoTask _queue; private readonly ILoggerVideoProcessingQueue _logger; public VideoProcessingQueue(ILoggerVideoProcessingQueue logger) { _logger logger; _queue Channel.CreateBoundedVideoTask(new BoundedChannelOptions(1000) { FullMode BoundedChannelFullMode.Wait, SingleReader true, SingleWriter false }); } public async ValueTask EnqueueAsync(VideoTask task) { await _queue.Writer.WriteAsync(task); } public async Task ProcessQueueAsync(CancellationToken cancellationToken) { await foreach (var task in _queue.Reader.ReadAllAsync(cancellationToken)) { try { var processor new VideoProcessor(task.OutputDirectory); // 根据任务类型执行不同处理 switch(task.OperationType) { case OperationType.Convert: await processor.ConvertFormatAsync(task.InputPath); break; case OperationType.Watermark: await processor.AddWatermarkAsync( task.InputPath, task.WatermarkPath, task.WatermarkPosition); break; // 其他操作类型... } task.CompletionSource.SetResult(true); } catch (Exception ex) { _logger.LogError(ex, $处理视频失败: {task.InputPath}); task.CompletionSource.SetException(ex); } } } }3.2 进度监控与错误处理实现实时进度反馈public class ProcessingProgress : IProgressProcessingProgressReport { private readonly ActionProcessingProgressReport _progressHandler; public ProcessingProgress(ActionProcessingProgressReport progressHandler) { _progressHandler progressHandler; } public void Report(ProcessingProgressReport value) { _progressHandler?.Invoke(value); } } public async Task ProcessWithProgressAsync( string inputPath, string outputPath, IProgressProcessingProgressReport progress) { var analysis await FFProbe.AnalyseAsync(inputPath); var duration analysis.Duration; await FFMpegArguments .FromFileInput(inputPath) .OutputToFile(outputPath, false, options options .WithVideoCodec(VideoCodec.LibX264) .WithAudioCodec(AudioCodec.Aac)) .NotifyOnProgress( (p) progress?.Report(new ProcessingProgressReport { Percentage p, EstimatedTimeRemaining TimeSpan.FromSeconds( duration.TotalSeconds * (100 - p) / 100) }), duration) .ProcessAsynchronously(); }4. 高级功能实现4.1 智能视频压缩根据内容类型自动选择最佳压缩参数public enum ContentType { Presentation, // 幻灯片类内容 TalkingHead, // 人物讲话 Action // 动作场景 } public async Taskstring SmartCompressAsync( string inputPath, ContentType contentType) { var outputPath Path.Combine(_outputDir, ${Path.GetFileNameWithoutExtension(inputPath)}_compressed.mp4); var args FFMpegArguments .FromFileInput(inputPath) .OutputToFile(outputPath, false, options { options.WithAudioCodec(AudioCodec.Aac); switch(contentType) { case ContentType.Presentation: options.WithVideoCodec(VideoCodec.LibX264) .WithConstantRateFactor(28) .WithPreset(FFMpegCore.Enums.Preset.Slow); break; case ContentType.TalkingHead: options.WithVideoCodec(VideoCodec.LibX264) .WithConstantRateFactor(23) .WithPreset(FFMpegCore.Enums.Preset.Medium); break; case ContentType.Action: options.WithVideoCodec(VideoCodec.LibX264) .WithConstantRateFactor(18) .WithPreset(FFMpegCore.Enums.Preset.Fast); break; } }); await args.ProcessAsynchronously(); return outputPath; }4.2 自动生成预览GIF为视频创建高质量的预览动画public async Taskstring GeneratePreviewGifAsync( string inputPath, TimeSpan start, TimeSpan duration, int width 480) { var outputPath Path.Combine(_outputDir, ${Path.GetFileNameWithoutExtension(inputPath)}_preview.gif); await FFMpegArguments .FromFileInput(inputPath, options options .Seek(start)) .OutputToFile(outputPath, false, options options .WithDuration(duration) .WithVideoFilters(filterOptions filterOptions .Scale(width: width, height: -1) .Fps(15)) .WithArgument(-loop, 0)) .ProcessAsynchronously(); return outputPath; }4.3 多任务并行处理利用Parallel.ForEach实现高效批量处理public async Task BatchProcessAsync( IEnumerablestring inputFiles, Funcstring, Task processAction, int maxDegreeOfParallelism 4) { var parallelOptions new ParallelOptions { MaxDegreeOfParallelism maxDegreeOfParallelism }; await Task.Run(() Parallel.ForEach(inputFiles, parallelOptions, file processAction(file).Wait())); }5. 系统集成与部署方案5.1 作为微服务部署创建ASP.NET Core Web API端点[ApiController] [Route(api/video)] public class VideoProcessingController : ControllerBase { private readonly VideoProcessingQueue _queue; public VideoProcessingController(VideoProcessingQueue queue) { _queue queue; } [HttpPost(process)] public async TaskIActionResult ProcessVideo([FromBody] VideoProcessingRequest request) { var task new VideoTask { InputPath request.InputPath, OperationType request.OperationType, OutputDirectory request.OutputDirectory }; await _queue.EnqueueAsync(task); return Accepted(new { TaskId task.TaskId }); } [HttpGet(status/{taskId})] public async TaskIActionResult GetStatus(Guid taskId) { // 实现状态查询逻辑 return Ok(); } }5.2 容器化部署示例Dockerfile配置FROM mcr.microsoft.com/dotnet/sdk:6.0 AS build WORKDIR /src COPY . . RUN dotnet publish -c Release -o /app FROM mcr.microsoft.com/dotnet/aspnet:6.0 WORKDIR /app COPY --frombuild /app . RUN apt-get update apt-get install -y ffmpeg ENTRYPOINT [dotnet, VideoProcessingService.dll]5.3 性能优化技巧关键参数对比表参数适用场景优点缺点-preset ultrafast实时处理编码速度快文件体积大-preset medium常规处理平衡速度与质量中等资源消耗-preset slow高质量输出最佳压缩率编码时间长-crf 18高质量需求几乎无损文件体积大-crf 23常规质量良好平衡轻微质量损失-crf 28低带宽极小文件明显质量损失// 示例优化后的处理参数 await FFMpegArguments .FromFileInput(inputPath) .OutputToFile(outputPath, false, options options .WithVideoCodec(VideoCodec.LibX264) .WithConstantRateFactor(23) .WithPreset(FFMpegCore.Enums.Preset.Slow) .WithThreads(Environment.ProcessorCount / 2)) .ProcessAsynchronously();