c# - .NET Process - 重定向 stdin 和 stdout 而不会导致死锁

Question

我正在尝试使用 FFmpeg 从我的程序生成的帧中对视频文件进行编码，然后将 FFmpeg 的输出重定向回我的程序以避免出现中间视频文件。

但是，在 System.Diagnostic.Process 中重定向输出时，我遇到了一个似乎相当普遍的问题，在文档的备注中提到 here , 即如果同步运行会导致死锁。

在为此焦头烂额一天，并尝试了网上找到的几种建议解决方案之后，我仍然找不到使它工作的方法。我得到了一些数据，但过程总是在完成之前卡住。

---

这是产生上述问题的代码片段:

static void Main(string[] args)
    {

        Process proc = new Process();

        proc.StartInfo.FileName = @"ffmpeg.exe";
        proc.StartInfo.Arguments = String.Format("-f rawvideo -vcodec rawvideo -s {0}x{1} -pix_fmt rgb24 -r {2} -i - -an -codec:v libx264 -preset veryfast -f mp4 -movflags frag_keyframe+empty_moov -",
            16, 9, 30);
        proc.StartInfo.UseShellExecute = false;
        proc.StartInfo.RedirectStandardInput = true;
        proc.StartInfo.RedirectStandardOutput = true;

        FileStream fs = new FileStream(@"out.mp4", FileMode.Create, FileAccess.Write);

        //read output asynchronously
        using (AutoResetEvent outputWaitHandle = new AutoResetEvent(false))
        {
            proc.OutputDataReceived += (sender, e) =>
            {
                if (e.Data == null)
                {
                    outputWaitHandle.Set();
                }
                else
                {
                    string str = e.Data;
                    byte[] bytes = new byte[str.Length * sizeof(char)];
                    System.Buffer.BlockCopy(str.ToCharArray(), 0, bytes, 0, bytes.Length);
                    fs.Write(bytes, 0, bytes.Length);
                }
            };
        }


        proc.Start();
        proc.BeginOutputReadLine();

        //Generate frames and write to stdin
        for (int i = 0; i < 30*60*60; i++)
        {
            byte[] myArray = Enumerable.Repeat((byte)Math.Min(i,255), 9*16*3).ToArray();
            proc.StandardInput.BaseStream.Write(myArray, 0, myArray.Length);
        }

        proc.WaitForExit();
        fs.Close();
        Console.WriteLine("Done!");
        Console.ReadKey();

    }

目前我正在尝试将输出写入文件以进行调试，但这不是最终使用数据的方式。

如果有人知道解决方案，将不胜感激。

Answer 1

您的进程挂起是因为您从未告诉 ffmpeg 您已完成写入 StandardInput 流。所以它仍然坐在那里等待您向它发送更多数据。

就我个人而言，我认为使用常规文件作为 ffmpeg 的输入和输出选项(即命令中的 infile 和 outfile行参数)。然后你不需要重定向任何流。

但是，如果您确实想要或需要重定向自己——例如，您实际上正在生成独立于某个文件的输入数据，并且您正在以文件以外的其他方式使用输出数据——您可以得到它通过正确使用 Process 类及其属性来工作。

特别是，这意味着几件事:

1. 当程序为流生成原始字节数据时，您不能将输出数据视为字符。
2. 您必须在完成后关闭输入流，以便程序知道已经到达输入流的末尾。

这是您的程序的实际工作版本:

static void Main(string[] args)
{
    Process proc = new Process();

    proc.StartInfo.FileName = @"ffmpeg.exe";
    proc.StartInfo.Arguments = String.Format("-f rawvideo -vcodec rawvideo -s {0}x{1} -pix_fmt rgb24 -r {2} -i - -an -codec:v libx264 -preset veryfast -f mp4 -movflags frag_keyframe+empty_moov -",
        16, 9, 30);
    proc.StartInfo.UseShellExecute = false;
    proc.StartInfo.RedirectStandardInput = true;
    proc.StartInfo.RedirectStandardOutput = true;

    FileStream fs = new FileStream(@"out.mp4", FileMode.Create, FileAccess.Write);

    proc.Start();
    var readTask = _ConsumeOutputAsync(fs, proc.StandardOutput.BaseStream);

    //Generate frames and write to stdin
    for (int i = 0; i < 30 * 60 * 60; i++)
    {
        byte[] myArray = Enumerable.Repeat((byte)Math.Min(i, 255), 9 * 16 * 3).ToArray();
        proc.StandardInput.BaseStream.Write(myArray, 0, myArray.Length);
    }

    proc.StandardInput.BaseStream.Close();

    readTask.Wait();
    fs.Close();
    Console.WriteLine("Done!");
    Console.ReadKey();
}

private static async Task _ConsumeOutputAsync(FileStream fs, Stream baseStream)
{
    int cb;
    byte[] rgb = new byte[4096];

    while ((cb = await baseStream.ReadAsync(rgb, 0, rgb.Length)) > 0)
    {
        fs.Write(rgb, 0, cb);
    }
}

请注意，即使您动态生成数据，您的示例也会显示将输出写入文件。如果你真的想要文件中的输出，那么我会绝对使用outfile命令行参数来指定输出文件而不是重定向StandardOutput你自己。当您运行的外部进程将为您处理所有工作时，为什么要在处理数据时插入您自己的代码？

我仍然不知道你试图用 AutoResetEvent 对象做什么，因为你从来没有等待过这个对象，而且你的实现被破坏了，因为你在你之前释放了这个对象开始使用它。因此，上述修改后的示例没有任何内容试图复制该行为。没有它也能正常工作。