Named Pipe 간단한 예제

 머리가 나빠서 공부는 해놨지만 하도 않쓰니 까먹게 되는군요.. =_=

그냥 기억 날겸 간단한 예제 하나 작성했습니다.

Named Pipe Server Source Code

#include <stdio.h> #include <Windows.h> #include <tchar.h> #define PIPE_NAME "\\\\.\\pipe\\test_pipe" int ConnectClient(HANDLE hNamePipe) { TCHAR recvMessage[100]; TCHAR sendMessage[100]; DWORD recvSize; DWORD sendSize; while(1) { _tprintf(_T("Input Send Message : ")); _tscanf(_T("%s"),sendMessage); //sendSize -> NULL 포함한 바이트 수 if(!(WriteFile( hNamePipe, sendMessage, (_tcslen(sendMessage)+1)*sizeof(TCHAR), &sendSize, NULL ))) { _tprintf(_T("WriteFile error! \n")); return -1; } FlushFileBuffers(hNamePipe); //recvSize -> NULL 포함한 바이트 수 if(!(ReadFile( hNamePipe, recvMessage, sizeof(recvMessage)-sizeof(TCHAR)*1, &recvSize, NULL ))) { printf("ReadFile error! \n"); return -1; } recvMessage[recvSize/sizeof(TCHAR)-1] = _T('\x00'); _tprintf(_T("Recv Message : %s \n"),recvMessage); } return 1; } int _tmain(int argc,TCHAR* argv[]) { HANDLE hNamePipe; TCHAR pipe_name[] = _T(PIPE_NAME); _tprintf(_T("==== Server ==== \n")); //NamedPipe 생성 hNamePipe = CreateNamedPipe( pipe_name, PIPE_ACCESS_DUPLEX, PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT, PIPE_UNLIMITED_INSTANCES, 0, 0, 20000, NULL ); if(hNamePipe == INVALID_HANDLE_VALUE) { printf("CreateNamePipe error! \n"); return -1; } while(1) { //생성한 Named Pipe의 핸들을 누군가 얻어갈 때까지 대기.. if(!(ConnectNamedPipe(hNamePipe,NULL))) { CloseHandle(hNamePipe); return -1; } else { if(ConnectClient(hNamePipe) == -1) break; } } DisconnectNamedPipe(hNamePipe); CloseHandle(hNamePipe); _tprintf(_T("Program exit! \n")); return 1; }

Named Pipe Client Source Code

#include <stdio.h> #include <stdlib.h> #include <Windows.h> #include <tchar.h> #define PIPE_NAME "\\\\.\\pipe\\test_pipe" int ConnectServer(HANDLE hNamePipe) { TCHAR recvMessage[100]; TCHAR sendMessage[100]; DWORD recvSize; DWORD sendSize; while(1) { if(!(ReadFile( hNamePipe, recvMessage, sizeof(recvMessage)-sizeof(TCHAR)*1, &recvSize, NULL ))) { _tprintf(_T("ReadFile error! \n")); return -1; } recvMessage[recvSize/sizeof(TCHAR)-1] = _T('\x00'); _tprintf(_T("Recv Message : %s \n"),recvMessage); _tprintf(_T("Input Send Message : ")); _tscanf(_T("%s"),sendMessage); if(!(WriteFile( hNamePipe, sendMessage, (_tcslen(sendMessage)+1)*sizeof(TCHAR), &sendSize, NULL ))) { _tprintf(_T("WriteFile error! \n")); return -1; } FlushFileBuffers(hNamePipe); } return 1; } int _tmain(int argc, TCHAR* argv[]) { TCHAR pipe_name[] = _T(PIPE_NAME); HANDLE hNamePipe; _tprintf(_T("==== Client ==== \n")); while(1) { hNamePipe = CreateFile(pipe_name,GENERIC_READ | GENERIC_WRITE, 0,NULL,OPEN_EXISTING,0,NULL); if(hNamePipe == INVALID_HANDLE_VALUE) { _tprintf(_T("CreateFile error! \n")); return -1; } DWORD pipeMode = PIPE_READMODE_MESSAGE | PIPE_WAIT; if(!(SetNamedPipeHandleState(hNamePipe,&pipeMode,NULL,NULL))) { _tprintf(_T("SetNamedPipeHandleState error! \n")); CloseHandle(hNamePipe); return -1; } else { if(ConnectServer(hNamePipe) == -1) break; } } CloseHandle(hNamePipe); return 0; }

실행 결과