主页 / 问题 / 599952
Accepted
neo
Asked:2020-12-05 23:44:44 +0000 UTC2020-12-05 23:44:44 +0000 UTC

异步读/写到 C# .Net 3.5 进程

  • 772

我在这个过程中实现了异步读/写操作的功能。但是，不会执行提供给进程的命令。

创建一个进程并重定向必要的线程：

StringBuilder outputText = new StringBuilder();
StringBuilder outputError = new StringBuilder();
Process process = new Process();
ProcessStartInfo startInfo = new ProcessStartInfo
{
    FileName = "cmd.exe",
    RedirectStandardInput = true,
    RedirectStandardError = true,
    RedirectStandardOutput = true,
    CreateNoWindow = true,
    UseShellExecute = false,
    ErrorDialog = false,
    Arguments = "/cpython.exe"
};
process.StartInfo = startInfo;

AutoResetEvent outputWaitHandle = new AutoResetEvent(false);
AutoResetEvent errorWaitHandle = new AutoResetEvent(false);

process.OutputDataReceived += (sender, e) => 
{
    if (e.Data == null) { outputWaitHandle.Set();}
    else{ outputText.AppendLine(e.Data); }
}

process.ErrorDataReceived += (sender, e) => 
{
    if (e.Data == null) { errorWaitHandle.Set();}
    else{ outputError.AppendLine(e.Data); }
}

process.Start();
process.BeginOutputReadLine();
process.BeginErrorReadLine();

if (timeout > 0)
{
    if (process.WaitForExit(timeout) &&
        outputWaitHandle(timeout) && 
        errorWaitHandle.WaitOne(timeout))
    {
        // Do some work...
    }
}

异步写入流：

if (process.StandardInput.BaseStream.CanWrite)
{
    byte[] bytesToWrite = Encoding.ASCII.GetBytes("print 'Hello'");
    IAsyncResult handle = process.StandardInput.BaseStream.BeginWrite(bytesToWrite, 0, bytesToWrite.Length, EndWriteCallBack, process.StandardInput.BaseStream);

    if (handle.IsCompleted)
    {
        // Do smth ....
    }
    else
    {
         handle.AsyncWaitHandle.WaitOne();
    }
}

//Callback func
void EndWriteCallBack(IAsyncResult handle)
{
    process.StandardInput.BaseStream.EndWrite(handle);
}

在输出中，我希望我的异步输出将打印的字符串返回给我：

outputText = "print 'Hello'"

就像控制台一样。但是，输出始终为空。告诉我可能是什么问题？

PS：如果你删除输入流的重定向，一切正常。但我希望能够将多个命令发送到同一个控制台，因为这可以通过直接使用它来完成。

c#

1 个回答

  1. Best Answer

    在这里找到了我的问题的答案（感谢作者，++++ to karma！）：
    Asynchronous I/O to the console, a fully interactive program

    稍微更正了代码（添加了一个实现委托+注释的方法），我得到了这个：

    using System;
using System.Diagnostics;

public class СmdShell
{
    private Process shellProcess;

    //Делегат
    public delegate void onDataHandler(СmdShell sender, string e);
    //Событие "получение новых данных"
    public event onDataHandler onData;

    public СmdShell()
    {
        try
        {
            shellProcess = new Process();
            ProcessStartInfo si = new ProcessStartInfo("cmd.exe");

            //Если хотите оставить консоль живой после посланной вами команды
            //Можно ещё передать "/c" - выполнится команда с последующим завершением
            //Либо вообще ничего не передавать
            //Оставлю ссылку после кода на то, какие ещё входные параметры можно задать консоли
            si.Arguments = "/k";

            //Перенаправление всех потоков, чтобы можно было асинхронное читать выходные потоки
            //и писать во входной поток
            si.RedirectStandardInput = true;
            si.RedirectStandardOutput = true;
            si.RedirectStandardError = true;

            //Обязательно "false", иначе редиректы не будут работать
            si.UseShellExecute = false;

            //Чтобы не создавались лишние окошки консоли
            si.CreateNoWindow = true;

            //Знать, из какой директории запускаться
            si.WorkingDirectory = Environment.GetEnvironmentVariable("WINDIR");

            //Сообщаем процессу стартовую информацию
            shellProcess.StartInfo = si;

            //События обработки из потоков вывода
            shellProcess.OutputDataReceived += shellProcess_OutputDataReceived;
            shellProcess.ErrorDataReceived += shellProcess_ErrorDataReceived;

            //Стартуем процесс
            shellProcess.Start();

            //Начинаем читать выходные потоки
            shellProcess.BeginErrorReadLine();
            shellProcess.BeginOutputReadLine();
        }
        catch (Exception ex)
        {
            Trace.WriteLine(ex.Message);
        }
    }

    void shellProcess_ErrorDataReceived(object sender, DataReceivedEventArgs e)
    {
        doOnData(e.Data);
    }

    void shellProcess_OutputDataReceived(object sender, DataReceivedEventArgs e)
    {
        doOnData(e.Data);
    }

    private void doOnData(string data)
    {
        if (onData != null) onData(this, data);
    }

    public void write(string data)
    {
        try
        {
            shellProcess.StandardInput.WriteLine(data);
        }
        catch (Exception ex)
        {
            Trace.WriteLine(ex.Message);
        }
    }

    public void test_onData(СmdShell sender, string e)
    {
        Console.WriteLine(e);
    }
}

    测试程序：

    using System;
public class Program
{
    static void Main(string[] args)
    {
        CmdShell test = new CmdShell();
        test.onData += test.test_onData;

        while (true)
        {
            Console.WriteLine("Enter command:");
            string command = Console.ReadLine();
            test.write(command);
        }
    }
}

    注意，问题！

    将“python.exe”作为命令传递仍然不会返回输出。但是，如果您故意发送无效命令，则将返回 python 返回的错误。

    问题！ 你如何获得所有的 Python 输出？？？

    PS：链接到运行 cmd.exe 的参数：
    CMD - 启动 windows 命令解释器的新副本

    • 0

相关问题