名前付きパイプを双方向通信にしたい

Question

前提・実現したいこと

https://qa.atmarkit.co.jp/q/3331
のコードを元にクライアント<=>サーバーの双方向通信に変更したい

ここに質問の内容を詳しく書いてください。

上記HPのコードを元に双方向に変更してみたのですが、サーバー側でのメッセージ受信後の
メッセージ送信時に「パイプが壊れています。」となり動作しません。

よろしくお願いします。

該当のソースコード

**サーバ側**
ThreadState s = ThreadState.Stopped;
        String pipeServerName = "pipeServerName";

        private void button1_Click(object sender, EventArgs e)
        {
            Thread t = new Thread(new ThreadStart(Method1));
            s = ThreadState.Running;
            t.Start();
        }

        private void Method1()
        {
            List<string> listInputDatas = new List<string>();
            string inputData = String.Empty;

            while (true)
            {
                using (var pipeServer = new NamedPipeServerStream(pipeServerName, PipeDirection.InOut))
                {
                    using (var sr = new StreamReader(pipeServer))
                    using (var sw = new StreamWriter(pipeServer))
                    {
                        try
                        {
                            if (pipeServer.IsConnected == false)
                            {
                                pipeServer.WaitForConnection();
                            }

                            //信号受信
                            inputData = sr.ReadLine();
                            listInputDatas.Add((inputData));
                            System.Diagnostics.Debug.Print(inputData);
                        }
                        catch (Exception Ex)
                        {
                            string ex = Ex.Message;
                        }

                        try
                        {
                            if (pipeServer.IsConnected == false)
                            {
                                pipeServer.WaitForConnection();
                            }

                            sw.AutoFlush = true;
                            sw.Write("OK:" + inputData);　//ここで例外発生「パイプが壊れています。」
                            sw.Flush();
                            pipeServer.WaitForPipeDrain();
                        }
                        catch(Exception Ex)
                        {
                            string ex = Ex.Message;
                        }
                    }
                }
                // その他終了判定など
                if (s == ThreadState.Stopped) return;
            }
        }

クライアント側
// 名前かえました
        String pipeServerName = "pipeServerName";

        private void btnStart_Click(object sender, EventArgs e)
        {
            var sb = new StringBuilder();

            // PIPEで送信する
            using (var pipeClient = new NamedPipeClientStream("localhost", pipeServerName, PipeDirection.InOut, PipeOptions.None, System.Security.Principal.TokenImpersonationLevel.Impersonation))
            {
                string inputData = String.Empty;

                sb.AppendLine(DateTime.Now.ToString() + "\t" + textBox1.Text);

                try
                {
                    pipeClient.Connect();
                }
                catch (Exception Ex)
                {

                }

                using (var sw = new StreamWriter(pipeClient))
                {
                    sw.AutoFlush = true;
                    sw.Write(sb);
                    //sw.Flush();
                    pipeClient.WaitForPipeDrain();
                }


                using (var sr = new StreamReader(pipeClient))
                {
                    inputData = sr.ReadLine();
                }

            }
        }

補足情報（FW/ツールのバージョンなど）

VS2017
.net3.5
ここにより詳細な情報を記載してください。

Answer 1

おそらくですが、問題の原因が分かりました。
どうやら、プロセス浮きが原因で正常にパイプが接続できなかった模様です。
使用していたサーバー側のコードでは、常に次のメッセージを受信しているので
強制終了した際に、プロセスが浮く状態となっていました。

そのため、次の接続の際も、同じ接続用パイプ名で接続される状態のため
変な動きとなっていた模様です。

Answer 2

                using (var sw = new StreamWriter(pipeClient))
                {
                    sw.AutoFlush = true;
                    sw.Write(sb);
                    //sw.Flush();
                    pipeClient.WaitForPipeDrain();
                }

                // ここでパイプ閉じていないか？

                using (var sr = new StreamReader(pipeClient))
                {
                    inputData = sr.ReadLine();
                }

クライアント側が using ブロックを2回に分けているので、
書き込んだあとブロックから抜ける時に、pipeClient.Dispose()が呼ばれて
パイプを閉じちゃっている気がします。（未確認です）

Comments

[trons]

ご回答ありがとうございます。
指摘の内容を反映してみましたが、今度は同じように変更したクライアント側で同じ「パイプが壊れています。」が発生するようになってしまいました。

そもそも論にはなりますが、usingブロックでStreamを開放した場合、NamedPipeClientStreamなどの通信路側のStreamも一緒に閉じてしまうものなのでしょうか？
ご存じであればおしえてください。

サーバー側
try
{
using (NamedPipeServerStream pipeServer = new NamedPipeServerStream(pipeServerName))
{
pipeServer.WaitForConnection();

using (StreamReader sr = new StreamReader(pipeServer))
{
using (StreamWriter sw = new StreamWriter(pipeServer))
{
sw.AutoFlush = true;

//信号受信
inputData = sr.ReadLine();
listInputDatas.Add((inputData));
System.Diagnostics.Debug.Print(inputData);

sw.Write("OK:" + inputData);
}
}

}
}
catch(Exception Ex)
{
string ex = Ex.Message;
}

クライアント側
try
{

using (NamedPipeClientStream namedPipeClientStream = new NamedPipeClientStream(pipeServerName))
{
namedPipeClientStream.Connect();

using (StreamReader streamReader = new StreamReader(namedPipeClientStream))
{
using (StreamWriter streamWriter = new StreamWriter(namedPipeClientStream))
{
streamWriter.AutoFlush = true;

streamWriter.WriteLine("aaaatest");

string inputData = streamReader.ReadLine();
Debug.WriteLine("\t\t\t◆◆◆◆◆◆" + inputData);
MessageBox.Show(inputData);
}
}
}
}
catch (Exception Ex)
{
string ex = Ex.Message;
}

[daisuke7]

例外はどこで発生したのでしょうか？

StreamReader/StreamWriterのDispose()は、自分が使用しているstreamの
Close()を呼び出すはずです。
ちょっと探したら逆コンパイル結果を挙げている情報を見つけました。

https://stackoverflow.com/questions/7524903/should-i-call-close-or-dispose-for-stream-objects

[trons]

StreamWriterのusingを超えたのちに発生しております。

>StreamReader/StreamWriterのDispose()は、自分が使用しているstreamの
>Close()を呼び出すはずです。
そうですか・・・。
ただそうすると、サーバー側で同じように例外が発生しないのが謎です。

参考HP
https://ichiroku11.hatenablog.jp/entry/2016/07/28/204859
http://info-i.net/csharp-named-pipe

また上記のusingで処理しているケースが多々ありますがusingを抜けた時点で
同じように例外が発生することになってしまうと思うのですが・・・

ちなみに、StreamReaderとStreamWriterのusingを削除して実行したところ
例外が発生しなくなりました。

よろしくお願いします。

[daisuke7]

うーん、確かに。私が勘違いしているだけかもしれません。
そうであったらごめんなさい。

あともう一点気になったのは、sw.Write("OK:" + inputData); ではなく
sw.WriteLine("OK:" + inputData); ではないか？ってあたりです。