0

C＃サーバーとC++間のデュプレックス通信を機能させるのに問題があります。

目的は、パイプを作成し、クライアントから何かを読み取り、何かを書き戻すことです。クライアントから読み取りを行っている場合、またはクライアントに書き込みを行っている場合は、すべて正常に機能していますが、両方を次々に実行することはできません。

これが私のC＃サーバーです：

// Create a name pipe
 using (NamedPipeServerStream pipeStream = new NamedPipeServerStream("TestPipe"))
 {
   Console.WriteLine("[Server] Pipe created {0}", pipeStream.GetHashCode());

   // Wait for a connection
   pipeStream.WaitForConnection();
   Console.WriteLine("[Server] Pipe connection established");

   //Reading Part
   using (StreamReader sr = new StreamReader(pipeStream))
   {
      string temp;
      while ((temp = sr.ReadLine()) != null)
      {
         Console.WriteLine("{0}: {1}", DateTime.Now, temp);
       }
     }

     //Writing Part
     using (StreamWriter sw = new StreamWriter(pipeStream))
     {
        sw.AutoFlush = true;
        String st = "send Back\0";
        sw.WriteLine(st);
     }
 }

そして、これがC++クライアントです。

HANDLE hFile;
BOOL flg;
DWORD dwWrite;
char szPipeUpdate[200];
hFile = CreateFile(L"\\\\.\\pipe\\TestPipe", GENERIC_WRITE|GENERIC_READ,
                           0, NULL, OPEN_EXISTING,
                           0, NULL);


 strcpy(szPipeUpdate,"Sending some data from client to server!");
 if(hFile == INVALID_HANDLE_VALUE)
  { 
        DWORD dw = GetLastError();
        printf("CreateFile failed for Named Pipe client\n:" );
  }
  else
  {
      flg = WriteFile(hFile, szPipeUpdate, strlen(szPipeUpdate), &dwWrite, NULL);
      if (FALSE == flg)
      {
         printf("WriteFile failed for Named Pipe client\n");
      }
      else
      {
         printf("WriteFile succeeded for Named Pipe client\n");
      }
  }

  printf("Let's read!\n");
  //Read the datas sent by the server
  BOOL fFinishRead = FALSE;
  do
    {
        char chResponse[200];
        DWORD cbResponse, cbRead;
        cbResponse = sizeof(chResponse);

        fFinishRead = ReadFile(
            hFile,                  // Handle of the pipe
            chResponse,             // Buffer to receive the reply
            cbResponse,             // Size of buffer in bytes
            &cbRead,                // Number of bytes read 
            NULL                    // Not overlapped 
            );

        if (!fFinishRead && ERROR_MORE_DATA != GetLastError())
        {
            DWORD  dwError = GetLastError();
            wprintf(L"ReadFile from pipe failed w/err 0x%08lx\n", dwError);
            break;
        }
        std::cout << chResponse;

    } while (!fFinishRead); // Repeat loop if ERROR_MORE_DATA
 CloseHandle(hFile);
4

1 に答える 1

1

サーバーとクライアントのNamedPipeStreamsを使用する場合は、接続の少なくとも一方の端が常に読み取りを試みていることを確認する必要があります。そうしないと、書き込みが失敗します。これは、リッスン/書き込みを行っているクライアントとサーバー間のタイミングの問題だと思います。この動作についても説明している簡単なブログ投稿があります。

クライアントとサーバーで2つのストリームを使用することをお勧めします。どちらも、同じパイプからの読み取り/書き込みです。

于 2012-08-28T17:12:30.177 に答える