#include <Windows.h>

#include <stdlib.h> // system("pause");

#include <stdio.h>

const char* const kPipeNameA = "\\\\.\\pipe\\MySimplePipe";

int main()

{

  // 1024バイトで余裕あるサイズとする

  char szReadBuf[1024];

  char szWriteBuf[1024];

  HANDLE hPipe;

  DWORD dwRead;

  DWORD dwWritten;

  BOOL bRead;

  BOOL bWritten;

  int count = 0;

  // ▼パイプの作成

  hPipe = CreateNamedPipeA(

    kPipeNameA,

    PIPE_ACCESS_DUPLEX, // 双方向パイプ

    0,    // パイプモード

    1,    // パイプに対する最大インスタンス

    1024, // 出力バッファ

    1024, // 入力バッファ

    0,    // ConnectNamedPipe関数を待つ、WaitNamedPipe関数のデフォルトタイムアウトミリ秒

    NULL);

  if (hPipe == INVALID_HANDLE_VALUE) {

    printf_s("パイプ作成に失敗しました\n");

    system("pause");

    return 0;

  }

  printf_s("パイプを作成しました。\n\n");

  while (1) // 外側のwhile文

  {

    // ▼接続待機

    printf_s("クライアントからの接続を待機します...\n");

    if (ConnectNamedPipe(hPipe, NULL) == 0)

    {

      printf_s("待機関数が失敗しました。\n");

      return 0;

    }

    printf_s("クライアントとの接続に成功しました。\n");

    while (1) // 内側のwhile文

    {

      count++;

      // ▼受信

      memset(szReadBuf, '\0', sizeof(szReadBuf));

      bRead = ReadFile(hPipe, szReadBuf, sizeof(szReadBuf), &dwRead, NULL);

      if (bRead == FALSE) {

        printf_s("読み取りに失敗しました。\n\n");

        break;

      }

      printf_s("受信文字列：%s\n", szReadBuf);

      // ▼送信

      // 受信文字列にカウントを付加する

      sprintf_s(szWriteBuf, "%d %s", count, szReadBuf);

      bWritten = WriteFile(hPipe, szWriteBuf, strlen(szWriteBuf), &dwWritten, NULL);

      if (bRead == FALSE) {

        printf_s("書き込みに失敗しました。\n\n");

        break;

      }

      printf_s("送信文字列：%s\n", szWriteBuf);

    } // while (1) // 内側のwhile文

    DisconnectNamedPipe(hPipe); // パイプの再利用

  } // while (1) // 外側のwhile文

  printf_s("ループを抜けました\n");

  CloseHandle(hPipe);

  system("pause");

  return 0;

}

using System;

using System.Text;

using System.IO.Pipes;

using System.IO;

namespace SimpleReplyPipeClient

{

  class Program

  {

    static void Main(string[] args)

    {

      // ▼起動 自動的にサーバーを立ち上げる。

      /*string serverDir = "C:\\Users";

      string serverNameWithoutExe = "SimpleReplyPipeServer";

      Process[] ps = Process.GetProcessesByName(serverNameWithoutExe);

      if (ps.Length > 0)

      {

        Console.WriteLine("サーバーは起動済みです。");

      }

      else

      {

        Process.Start(serverDir + "\\" + serverNameWithoutExe);

      }*/

      // ▼接続

      using (NamedPipeClientStream client = 

        new NamedPipeClientStream(".", "MySimplePipe", PipeDirection.InOut))

      {

        Console.WriteLine("サーバーへ接続中...");

        int timeOutMs = 1000;

        try

        {

          client.Connect(timeOutMs);

        }

        catch (TimeoutException)

        {

          Console.WriteLine("タイムアウトしました（" + timeOutMs + "ミリ秒）。");

          return;

        }

        catch (UnauthorizedAccessException)

        {

          // NamedPipeClientStreamデストラクタのPipeDirectionがサーバーと合わない場合発生する。

          // PIPE_ACCESS_INBOUND(1) もしくは PIPE_ACCESS_OUTBOUND(2) いずれかのみの場合。

          // サーバー側は、PIPE_ACCESS_DUPLEX(3)を指定すること

          Console.WriteLine("UnauthorizedAccessException（アクセス権がない）が発生しました。");

          return;

        }

        catch (IOException)

        {

          Console.WriteLine("サーバーが別のクライアントに接続されています。");

          return;

        }

        Console.WriteLine("サーバーに接続しました。\n");

        // エンコーダを作成

        Encoding sjisEncoding = Encoding.GetEncoding("Shift_JIS");

        for (int i = 0; i < 3; i++)

        {

          // ▼送信

          string sendString = "hoge";

          byte[] outBuffer = sjisEncoding.GetBytes(sendString);

          int len = outBuffer.Length;

          Console.WriteLine("送信文字列：{0}", sendString);

          try

          {

            client.Write(outBuffer, 0, len);

          }

          catch (IOException)

          {

            Console.WriteLine("サーバー停止中を含め、パイプ先が閉じられています。");

            return;

          }

          client.Flush();

          // ▼受信

          // バッファサイズは最大でも 1024 バイトにする

          const int kMaxBuffer = 1024;

          byte[] inBuffer = new byte[kMaxBuffer];

          int readedLength;

          try

          {

            readedLength = client.Read(inBuffer, 0, kMaxBuffer);

          }

          catch (IOException)

          {

            Console.WriteLine("サーバー停止中を含め、パイプ先が閉じられています。");

            return;

          }

          Array.Resize(ref inBuffer, readedLength);

          string receiveString = sjisEncoding.GetString(inBuffer);

          Console.WriteLine("受信文字列：{0}", receiveString);

        } // for

      }

      Console.WriteLine("\n何らかのキーを押すと終了します...");

      Console.ReadKey(true);

    }

  }

}

using (NamedPipeClientStream client = 

        new NamedPipeClientStream(".", "MySimplePipe", PipeDirection.InOut))

{

}