C#长生命周期进程持续读取StdOut、多次交互输入输出的问题问询

认知纠正 #

你对StandardOutput的机制理解有误。重定向后的StandardOutput属于单向管道流，采用FIFO（先进先出）的读写逻辑：

• 子进程写入的新数据只会追加到管道末尾，不存在覆盖旧数据的情况
• 你读取过的数据会被自动从管道中移除，不需要手动操作指针
• 管道流本身不支持随机访问，无法调用Seek()是正常特性，不属于故障

现有代码的核心问题 #

你当前的读取逻辑存在致命缺陷：

• OutputIsEmpty()中调用Peek()判断输出是否为空的逻辑完全不可靠：下发指令后子进程的输出存在延迟，你调用Peek时新输出可能还没写入管道，会直接返回-1终止读取，后续子进程输出的数据会滞留在管道中，导致下次读取时拿到的是上一次的遗留输出，逻辑完全错位。
• 未关闭子进程的输出缓冲：默认情况下Node.js会把StdOut的输出攒满缓冲区才会批量吐出，你在C#侧会迟迟读不到实时输出。

推荐解决方案（异步事件监听，稳定可靠） #

通过.NET内置的输出事件异步监听子进程输出，不需要自己轮询管道，配合线程安全队列缓存输出，完美适配多次交互的场景：

using System.Collections.Concurrent;
using System.Diagnostics;
using System.Text;

Process simulator;
// 线程安全队列，存储子进程所有输出行
ConcurrentQueue<string> _outputQueue = new ConcurrentQueue<string>();

void Start()
{
    try
    {
        simulator = new Process
        {
            StartInfo = new ProcessStartInfo
            {
                FileName = NODE_PATH,
                // 加--unbuffered参数关闭Node.js输出缓冲，保证输出实时推送
                Arguments = $"--unbuffered \"{ARG_PATH}\" \"command-to-open-interactive-process\"",
                UseShellExecute = false,
                RedirectStandardOutput = true,
                RedirectStandardInput = true,
                RedirectStandardError = true,
                CreateNoWindow = true,
                // 统一编码避免乱码，可根据子进程实际编码调整
                StandardOutputEncoding = Encoding.UTF8,
                StandardErrorEncoding = Encoding.UTF8
            }
        };
        // 绑定输出事件，子进程每输出一行就会触发一次
        simulator.OutputDataReceived += (sender, e) =>
        {
            if (!string.IsNullOrEmpty(e.Data))
            {
                _outputQueue.Enqueue(e.Data);
            }
        };
        // 可选：绑定错误输出事件，统一收集错误日志
        simulator.ErrorDataReceived += (sender, e) =>
        {
            if (!string.IsNullOrEmpty(e.Data))
            {
                _outputQueue.Enqueue($"[ERROR] {e.Data}");
            }
        };
        simulator.Start();
        // 启动异步监听，不需要自己手动读流
        simulator.BeginOutputReadLine();
        simulator.BeginErrorReadLine();
        
        // 测试交互
        EvokeResponse("command1");
        EvokeResponse("command2");
    }
    catch (Exception e)
    {
        UnityEngine.Debug.Log(e.Message);
    }
}

public string EvokeResponse(string s, int timeoutMs = 3000)
{
    FeedInput(s);
    StringBuilder response = new StringBuilder();
    var endTime = DateTime.Now.AddMilliseconds(timeoutMs);
    while (DateTime.Now < endTime)
    {
        if (_outputQueue.TryDequeue(out var line))
        {
            response.AppendLine(line);
            // 优化项：如果你知道子进程输出的结束标记（比如交互式程序的提示符>、$等），读到标记就直接返回，不需要等超时
            // if (line.TrimEnd() == ">") break;
        }
        else
        {
            // 无输出时休眠10ms，避免CPU空转
            System.Threading.Thread.Sleep(10);
        }
    }
    return response.ToString();
}

private void FeedInput(string s)
{
    simulator.StandardInput.WriteLine(s);
    // 强制刷新输入缓冲区，保证指令立刻发送给子进程
    simulator.StandardInput.Flush();
}

额外注意事项 #

• 如果是其他语言的子进程，也需要对应关闭输出缓冲：比如Python启动加-u参数，C/C++程序需要调用fflush(stdout)或者设置setbuf(stdout, NULL)
• 主程序退出时记得调用simulator.CancelOutputRead()、simulator.CancelErrorRead()和simulator.Dispose()释放资源，避免内存泄漏

内容的提问来源于stack exchange，提问作者OGSuperSand