获取 .NET Process 对象以连续刷新输入流？

Question

我正在尝试更改与 Mercurial 命令行客户端对话的类库，1.9 客户端中的新功能是能够启动服务器并通过标准输入/输出管道与其对话。这确实很有希望，因为使用 Mercurial 命令行客户端的主要难题之一是，由于它是用 Python 编写的，因此即使只是询问其版本，也会有一些启动客户端的开销。

然而，有一个问题。到目前为止，我已经通过读取标准输出/错误从命令行客户端检索输出，并且当进程退出时，流刷新，我可以读取流的末尾。

然而，在这种新模式下，进程会将大量文本转储到标准错误/输出，然后等待下一个命令。非常适合减少开销，但很糟糕，因为 .NET 会缓冲这些流。

换句话说，由于进程没有退出，所以我不会得到该输出的最后部分，直到：

1. 我要求进程退出
2. 我发出另一个命令

有没有办法让我

1. 要求缓冲区刷新，这意味着我得到缓冲区中的内容是什么，即使它不足以使缓冲区自行刷新？
2. 如果不是，我可以将缓冲区大小设置为 1 个字符吗？
3. 我还能做些什么吗？

如果需要的话，我可以处理 P/Invoke。

这是一个 LINQPad 概念验证程序，它可以说明：

它的作用是启动命令提示符并向其提供 DIR命令，但请注意，直到循环内经过 10 秒后，程序才会输出“C:>”生成目录列表后立即输出命令提示符的提示。

换句话说，这就是命令提示符的作用：

1. 生成目录列表
2. 通过提示“C:>\”请求另一个命令

但是，这是下面的程序所看到的：

1. 生成目录列表
2. （等待 10 秒）
3. 关闭输入流

4. 查看提示

   无效主函数() { 字符串 clientExecutablePath = "cmd.exe";

   var psi = new ProcessStartInfo();
   psi.FileName = clientExecutablePath;
   psi.RedirectStandardError = true;
   psi.RedirectStandardInput = true;
   psi.RedirectStandardOutput = true;
   psi.CreateNoWindow = true;
   psi.WorkingDirectory = @"C:\";
   psi.WindowStyle = ProcessWindowStyle.Hidden;
   psi.UseShellExecute = false;
   psi.ErrorDialog = false;
   psi.StandardErrorEncoding = Encoding.GetEncoding("Windows-1252");
   psi.StandardOutputEncoding = Encoding.GetEncoding("Windows-1252");
   
   var p = Process.Start(psi);
   
   var 输入 = p.StandardInput;
   var 输出 = p.StandardOutput;
   var 错误 = p.StandardError;
   
   动作 reader = delegate(StreamReader StreamReader, 字符串前缀)
   {
       串线；
       while ((line = StreamReader.ReadLine()) != null)
       {
           Debug.WriteLine(前缀+行);
       }
   };
   
   IAsyncResult outputReader = reader.BeginInvoke(output, "o: ", null, null);
   IAsyncResult errorReader = reader.BeginInvoke(error, "e: ", null, null);
   
   输入.Write("目录\n");
   输入.Flush();
   
   while (!p.HasExited)
   {
       线程.睡眠(10000);
       输入.关闭();
   }
   
   reader.EndInvoke(outputReader);
   reader.EndInvoke(errorReader);
   

   }

Answer 1

我不认为有任何方法可以强制刷新，但是我有几个可能对您有帮助的替代方案：

1. 我注意到您正在使用 ReadLine() 来读取流。直到写入完整的输出行（包括 CRLF，或至少 LF）后才会返回。因此，您可能需要考虑使用 Read()，它只会读取单个字符。您可能会发现，如果服务器进程在退出之前没有在最后一行写入 CRLF，那么这会为您提供您要查找的最后一个输出块。
2. 您可以通过向 Process 上的 OutputDataReceived 和 ErrorDataReceived 事件添加处理程序来异步读取流，然后使用 BeginOutputReadLine 和 BeginErrorReadLine 开始接收数据。我不知道事件被调用的频率是多少：如果有任何数据可用，则定期调用，每当收到完整的数据行时，或者针对每个字符。

HTH，

巴特