C# と VB.NET の質問掲示板

[OS]WinXP
[VB]2003/2005

お世話になっております。
今回は表題の通り、ProcessのStandardOutputを逐次読み取りたいというものです

わかりやすいとこで言うとPINGコマンド等、処理の間にもプロンプトに
順次表示されるものを、呼び出し元で奪ってしまおうと思ったのですが
当初書いた以下のコードでは当然ながら最終的な出力結果がまとめて返ってきます

Dim proc As Process

proc = New Process

With proc.StartInfo
    .FileName = "PING"
    .Argument = "xxx.xxx.xx.xx"     'IPは伏せます
    .RedirectStandardOutput = True
    .WindowStyle = ProcessWindowStyle.Hidden
    .CreateNoWindow = True
    .UseShellExecute = False
End With

proc.Start()
Debug.WriteLine(proc.StandardOutput.ReadToEnd())
proc.WaitForExit(10000)

proc.Close()
proc.Dispose()
proc = Nothing


タイマーでReadToEndとも考えたのですが良く考えればStartで固まるので
意味ありませんでした。
マルチスレッド使わずに標準出力のリアルタイム取得を実現できる方法があれば
ご教示願いたいと思います（マルチスレッド使って実現できるかどうかも未確認ですが）

■No19072 (鶏唐揚 さん) に返信

マルチスレッドでなく、という要件を満たすかどうかわかりませんが
（非同期読み取りは内部的にマルチスレッドなので）、こんなコードでできました。
構文的には C# 3.0、フレームワーク的にも .NET Framework 2.0 のを使っちゃってますけど。

using (Process p = new Process())
{
    p.StartInfo.FileName = "ping.exe";
    p.StartInfo.Arguments = "127.0.0.1";
    p.StartInfo.RedirectStandardOutput = true;
    p.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
    p.StartInfo.CreateNoWindow = true;
    p.StartInfo.UseShellExecute = false;
    p.OutputDataReceived += (sender, e) =>
    {
        if( ! string.IsNullOrEmpty(e.Data) )
        {
            Console.WriteLine(e.Data);
        }
    };

    p.Start();
    p.BeginOutputReadLine();
    p.WaitForExit();
}

Console.WriteLine();
Console.WriteLine("Complete");

が、DataReceivedEventArgs.Data には時折空文字列が来るようで、
string.IsNullOrEmpty を外すと、数行の空行が出てしまいますが、
排除すると、コマンドプロンプトから叩いた時の出るべき空行も排除してしまうので、
そのままの出力を再現することはできませんでした。

他にも方法はあるかと思います。

■No19076 (シャノン さん) に返信
> （非同期読み取りは内部的にマルチスレッドなので）、こんなコードでできました。

どこまで考えるかによりますが、
ユーザーモードの範囲内なら非同期読み取りはマルチスレッドでないものもありますよ。
特にストリームは。

> 他にも方法はあるかと思います。

じゃあWindows.Formsで。
ただ、鶏唐揚さんが何をしたいのかいまいちよくわからないのですよね。
こんな簡単なのでいいのかしら？


    Dim proc As Process
    Dim ar As IAsyncResult
    Dim dlg As ReadLine
    Delegate Function ReadLine() As String

    Private Sub Button1_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Button1.Click
        If proc IsNot Nothing Then Exit Sub
        proc = New Process

        With proc.StartInfo
            .FileName = "PING"
            .Arguments = "192.168.68.1" '私のプライベートアドレスはこれ。
            .RedirectStandardOutput = True
            .WindowStyle = ProcessWindowStyle.Hidden
            .CreateNoWindow = True
            .UseShellExecute = False
        End With

        proc.Start()
        dlg = New ReadLine(AddressOf proc.StandardOutput.ReadLine)
        ar = dlg.BeginInvoke(Nothing, Nothing)
        Timer1.Start()
    End Sub

    Private Sub Timer1_Tick(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles Timer1.Tick
        If ar.IsCompleted Then
            Dim str As String
            str = dlg.EndInvoke(ar)
            If str Is Nothing Then
                Timer1.Stop()
                proc = Nothing
            Else
                Me.TextBox1.Text &= str & ControlChars.NewLine
                ar = dlg.BeginInvoke(Nothing, Nothing)
            End If
        End If
    End Sub

追記。

> Startで固まるというのは、PINGコマンドが完了するまでメインスレッドが待機して
> しまうということです。WaitForExitを外しても同様でした。

StartではなくReadToEndで固まってるのではないですか？

> コマンドプロンプトで単純に
> PING xxx.xxx.xx.xx
> と打つと、（PINGが通る場合は）通常は約1秒ごとにReply from...と
> 4回表示されると思いますが、これをそのままのタイミングで
> 標準出力を奪って表示したいということです。

とすると、ストリームの扱いに慣れていないのでしょう。
No18620 の投稿とかにちょっと書いたので参考に。

■No19103 (れい さん) に返信
> ■No19096 (シャノン さん) に返信
>>これバグくさいなー。
> 
> pingの、ですね。

そうなのかな？
コンソールアプリは出力時に \r\n ではなく \n を使うべし、というガイドラインはどこかにあったっけ？
例えばここ
http://www.atmarkit.co.jp/fdotnet/dotnettips/657redirectstdout/redirectstdout.html
では、出力を受ける側で \r\r\n に対応してるけど。

> >>GetDecoderしてDecoder取っておかないと、文字が化けちゃいます。
>>
>>え、そうなの？
> 
> OutputEncodingがUTF-16なときに
> 3バイトの読み込みで返ってきたりしたら切れちゃいますよ。
> 必ず偶数まで読む、なんて保証はないですから。

なるほど。勉強勉強。

>>StreamReader を使うというのは良くわからんが。
> StreamReaderに折角「改行まで読む」というメソッドがあるのに使わないのはもったいないというだけです。

あー、ReadLine を非同期で呼べと。
非同期デリゲートは使おうと思わなかったなぁ。

というわけでれいさんのをパクった非同期デリゲート版。

private delegate string ReadLine();
private static void Ping3()
{
    using (Process p = new Process())
    {
        p.StartInfo.FileName = "ping.exe";
        p.StartInfo.Arguments = "127.0.0.1";
        p.StartInfo.RedirectStandardOutput = true;
        p.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
        p.StartInfo.CreateNoWindow = true;
        p.StartInfo.UseShellExecute = false;

        p.Start();

        for(;;)
        {
            ReadLine ln = p.StandardOutput.ReadLine;
            IAsyncResult ar = ln.BeginInvoke(null, null);
            ar.AsyncWaitHandle.WaitOne();
            string line = ln.EndInvoke(ar);
            if (line == null)
            {
                break;
            }

            Console.WriteLine(line);
        }
    }

    Console.WriteLine();
    Console.WriteLine("Complete");
}

やっぱり改行が \r\r\n になるおまけつき。

■No19072 (鶏唐揚 さん) に返信

.NET Framework 1.1 でもできる範囲のコードで。

class AsyncArgument
{
    public Process process;
    public Stream stream;
    public byte[] buffer;
}

private static void Ping2()
{
    using (Process p = new Process())
    {
        p.StartInfo.FileName = "ping.exe";
        p.StartInfo.Arguments = "127.0.0.1";
        p.StartInfo.RedirectStandardOutput = true;
        p.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
        p.StartInfo.CreateNoWindow = true;
        p.StartInfo.UseShellExecute = false;

        p.Start();

        byte[] outputBuffer = new byte[1024];
        AsyncArgument aa = new AsyncArgument();
        aa.process = p;
        aa.stream = p.StandardOutput.BaseStream;
        aa.buffer = outputBuffer;

        aa.stream.BeginRead(outputBuffer, 0, 1024, StandardOutputCallback, aa);
        p.WaitForExit();
    }

    Console.WriteLine();
    Console.WriteLine("Complete");
}

static void StandardOutputCallback(IAsyncResult result)
{
    AsyncArgument aa = result.AsyncState as AsyncArgument;
    int count = aa.stream.EndRead(result);

    string output = Console.OutputEncoding.GetString(aa.buffer, 0, count);
    if (!string.IsNullOrEmpty(output))
    {
        Console.WriteLine(output);
    }

    if (!aa.process.HasExited)
    {
        aa.stream.BeginRead(aa.buffer, 0, 1024, StandardOutputCallback, aa);
    }
}

しかし出力は細切れになってしまう。