C#获取标准输入/输出/运行错误，而不是子进程

Question

我的问题很简单：如何获得未启动进程的标准输出/输入/错误？假设我有一些程序（不是我的）XYZ，它整天运行并将东西打印到标准输出。我希望能够启动我的 C# 应用程序并开始读取 XYZ 的输出。然后关闭我的 C# 应用程序并在 2 小时后重新启动它并继续读取输出（不一定是我停止的地方，但那将是一个加号）。

如果 XYZ 是我的子进程，我知道这可以实现

serverProcess = Process.Start(new ProcessStartInfo()
{
    RedirectStandardError = true,
    RedirectStandardInput = true,
    RedirectStandardOutput = true,
    WorkingDirectory = WorkingDir,
    Arguments = Args,
    FileName = "XYZ",
    UseShellExecute = false
});
serverProcess.OutputDataReceived += serverProcess_OutputDataReceived;
serverProcess.ErrorDataReceived += serverProcess_OutputDataReceived;
serverProcess.BeginOutputReadLine();
serverProcess.BeginErrorReadLine();

但情况并非如此，因为 XYZ 完全独立于我的应用程序，并且无论我对它做什么都需要继续运行。 值得注意的是（如果有帮助的话）我可以自己启动 XYZ（使用那些重定向参数）。只是我的生命周期需要完全独立于XYZ，并且我需要在我重新启动后能够“重新连接”。

我看到了一些使用 Get/SetStdHandle 的建议，但大多数都声称不起作用，而且我也不太明白如何应用它们。

感谢您的建议！

Answer 1

值得注意的是（如果有帮助的话）我可以自己启动 XYZ（使用那些重定向参数）。只是我的生命周期需要完全独立于XYZ，并且我需要在我重新启动后能够“重新连接”。

这是我在 cmets 中建议的简单实现（通过中间过程发布数据）。

样本基本上由三个主要部分组成

1.示例 XYZ 过程

在我们的例子中，它是一个简单的控制台应用程序，每秒从 XYZ 消息中发出 Hello。

    class Program
    {
        static void Main(string[] args)
        {
           var count = 0;
           while (true)
           {
               Console.WriteLine("Hello from XYZ "+count);
               count++;
               Thread.Sleep(1000);
           }
       }
    }

2。中间过程

应该启动 XYZ 并将其输出重定向到自身，然后通过它发布。对于发布部分，我们在这里使用ZeroMQ 库，可以从 nuget 轻松获得。

class Program
{
    private static Socket _pub;

    static void Main(string[] args)
    {
        using (var context = new Context())
        {
            _pub = context.Socket(SocketType.PUB);
            _pub.Bind("tcp://*:2550");

            StartXyz();

            Console.WriteLine("Press any key to close middle process...");
            Console.ReadKey();
        }
    }

    private static void StartXyz()
    {
         var serverProcess = Process.Start(new ProcessStartInfo
        {
            RedirectStandardError = true,
            RedirectStandardInput = true,
            RedirectStandardOutput = true,
            WorkingDirectory = AppDomain.CurrentDomain.BaseDirectory,
            Arguments = string.Empty,
            FileName = "XYZ.exe",
            UseShellExecute = false
        });
        serverProcess.OutputDataReceived += serverProcess_OutputDataReceived;
        serverProcess.ErrorDataReceived += serverProcess_OutputDataReceived;
        serverProcess.BeginOutputReadLine();
        serverProcess.BeginErrorReadLine();
    }

    private static void serverProcess_OutputDataReceived(object sender, DataReceivedEventArgs e)
    {
        _pub.Send(e.Data, Encoding.UTF8);
        Console.WriteLine(e.Data + " pushed.");
    }
}

3。消费者流程

最后我们有了我们的进程，它使用来自 XYZ 的重定向数据。

class Program
{
    static void Main(string[] args)
    {
        using (var context = new Context())
        {
            var sub = context.Socket(SocketType.SUB);
            sub.Connect("tcp://localhost:2550");
            sub.Subscribe(string.Empty, Encoding.UTF8);
            while (true)
            {
                var data = sub.Recv(Encoding.UTF8);
                Console.WriteLine(data);
            }
        }
    }
}