Visual C++ Pipe Server/Client 통신 예제

Win32에서 IPC(Inter Process Communication)의 하나의 방법인 Pipe에 관한 간단한 Server/Client 예제이다.
파이프를 하나만 만들고 단방향 서버 클라이언트이다.
서버는 보내기만 하고, 클라이언트는 받기만 한다.

// PipeServer2.cpp : Defines the entry point for the console application.
//
#include "stdafx.h"

int _tmain(int argc, _TCHAR* argv[])
{
 // "\\\\.\\pipe\\RenToImaging"라는 이름의 파이프를 생성한다.
 // 파이프는 항상 \\.\pipe\(이름)에 생성 되어야 한다.
 HANDLE hPipe = ::CreateNamedPipe(L"\\\\.\\pipe\\RenToImaging",
  PIPE_ACCESS_DUPLEX, // 양방향
  PIPE_TYPE_BYTE, // 텍스트 모드
  255, // 최대 255개 인스턴스
  4096, // 출력 버퍼
  0, // 입력 버퍼
  1, // 타임아웃
  NULL);// 보안속성
 while(true)
 {
  // 이전에 연결된 파이프가 있는지 초기화 한다.
  ::DisconnectNamedPipe(hPipe);
  // 클라이언트가 연결되기를 기다린다.
  // 클라이언트가 연결되기 전에는 리턴되지 않는다.
  BOOL bCon = ::ConnectNamedPipe(hPipe, NULL);

  // bCon이 FALSE이고 GetLastError가 ERROR_PIPE_CONNECTED이면 정상 연결된 경우이므로 bCon을 TRUE로 해준다.
  if(bCon == FALSE && ::GetLastError() == ERROR_PIPE_CONNECTED)
   bCon = TRUE;
  // 정상 연결일 경우
  if(bCon == TRUE)
  {
   // WriteFile로 "Server"라는 문자열을 보내준다.
   DWORD written;
   BOOL bSuc = ::WriteFile(hPipe, L"Server", sizeof(wchar_t)*6, &written, NULL);
   ::wprintf(L"Connect\n");
   ::OutputDebugString(L"Connect\n");
   // 버퍼에 있는것을 비우고 파이프를 Disconnect한다.
   ::FlushFileBuffers(hPipe);
   ::DisconnectNamedPipe(hPipe);
  }
  else
  {
   // 연결이 실패한 경우이다.
   ::wprintf(L"Connect fail..\n");
   break;
  }
 }

 // 파이프를 닫아준다.
 ::CloseHandle(hPipe);
 return 0;
}


// PipeClient2.cpp : Defines the entry point for the console application.
//
#include "stdafx.h"

int _tmain(int argc, _TCHAR* argv[])
{
 while(true)
 {
  HANDLE hPipe = NULL;
  for(;;)
  {
   // 파이프가 연결될 수 있는 상태까지 대기한다.
   if(::WaitNamedPipe(L"\\\\.\\pipe\\RenToImaging", NMPWAIT_WAIT_FOREVER) == TRUE)
   {
    ::OutputDebugString(L"Wait\n");
    ::wprintf(L"Wait\n");
    // 파이프를 생성한다.
    // 일반 파일과 동일하게 읽는다.
    hPipe = ::CreateFile(L"\\\\.\\pipe\\RenToImaging", GENERIC_READ | GENERIC_WRITE, 0, NULL, OPEN_EXISTING, 0, NULL);
    if(hPipe != INVALID_HANDLE_VALUE)
     break;
   }
  }
  ::OutputDebugString(L"CreateFile\n");
  ::wprintf(L"CreateFile\n");
  wchar_t wszBuffer[512] = {0,};
  DWORD dwWritten;
  // 파이프로부터 데이터를 전송 받는다.
  BOOL bRet = ::ReadFile(hPipe, wszBuffer, 512, &dwWritten, NULL);
  BYTE* pBuffer = (BYTE*)wszBuffer;
  pBuffer += sizeof(size_t)*2;
  ::wprintf(L"%s\n", (wchar_t*)pBuffer);
  // 파이프를 닫는다.
  ::FlushFileBuffers(hPipe);
  ::CloseHandle(hPipe);
  // 잠시쉬고 다시 처음으로 돌아가 서버의 전송을 기다린다.
  ::Sleep(200);
 }
 return 0;
}