从进程读取，StreamReader.Peek() 未按预期工作

Question

请参阅下面的类，我使用它来读取添加到它的任何进程的输出。目前我正在启动一个 Jar，它充当 C# 应用程序和 JMS 消息传递代理之间的通道适配器。唯一的问题是，当从进程的StandardOutput 读取时，线程会阻塞reader.Peek() 调用。

经过一些调试，我发现只有在没有输出写入进程的StandardOutput 流时才会发生这种情况。我已经使用即时窗口进行了一些尝试，以确定是否可以找到一种方法来确定底层流是否为空。但到目前为止，所有对 Stream.CanRead 或 FileStream.Length 等属性的调用都会抛出 InvalidOperationExceptions 或返回无法用于检查这种情况的输出。

此外，我还尝试使用 OutputDataReceived 和 ErrorDataReceived 事件，但由于某种原因，它们似乎从未触发。

所以我的问题是；有什么方法可以用来干净地读取进程的输出，因为它变得可用？

读取输出的类：

namespace ReparatieSysteem.Lib
{
    internal delegate void NewOutputLineEvent(Process process, int port, string line);

    class ProcessListener
    {
        private static readonly Dictionary<int, Process> processes;
        private static readonly Thread thread;

        static ProcessListener()
        {
            processes = new Dictionary<int, Process>();
            thread = new Thread(RunThread);
            thread.Start();
        }

        private static void PollProcesses()
        {
            foreach (var item in processes.Where(p => p.Value.HasExited).ToList())
            {
                processes.Remove(item.Key);
            }

            foreach (var item in processes)
            {
                SendLines(item.Value, item.Key, ReadReader(item.Value.StandardError));
                SendLines(item.Value, item.Key, ReadReader(item.Value.StandardOutput));
            }

        }

        private static void SendLines(Process process, int port, IEnumerable<String> lines)
        {
            foreach(var line in lines)
            {
                if (OnNewOutput != null)
                {
                    OnNewOutput(process, port, line);
                }
            }
        }

        private static IEnumerable<string> ReadReader(StreamReader reader)
        {
            while (reader.Peek() >= 0)
            {
                yield return reader.ReadLine();
            }
        }

        private static void RunThread()
        {
            while(true)
            {
                if (processes.Count > 0)
                {
                    PollProcesses();
                }

                Thread.Sleep(200);
            }
        }

        public static void AddProcess(int port, Process process)
        {
            processes.Add(port, process);
        }

        public static event NewOutputLineEvent OnNewOutput;
    }
}

创建进程的代码：

var procStartInfo = new ProcessStartInfo("java", 
            string.Format("-jar {0} {1} {2} {3}", JarPath, ConnectionName, _listenQueue, _listenPort))
        {
            RedirectStandardOutput = true,
            RedirectStandardError = true,
            UseShellExecute = false,
            CreateNoWindow = true
        };

        _brokerProcess = new Process { StartInfo = procStartInfo };

        _brokerProcess.Start();

        ShutdownListener.OnApplicationQuit += _brokerProcess.Kill;

        ProcessListener.AddProcess(_listenPort, _brokerProcess);

Answer 1

似乎这是StreamReader 实现中的一个已知错误，正如this answer 中所建议的那样。在您的情况下，解决方法是使用异步流方法，例如 StreamReader.ReadAsync 或 StreamReader.ReadLineAsync。