Named Pipe 간단한 예제

sharememory 2010. 12. 24. 17:37

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

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

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;
}

실행 결과

저작자표시 (새창열림)