一个基于长连接的命名管道Demo

#include <windows.h> #include <stdio.h> #include <iostream> #include <tchar.h> #include <strsafe.h> #define PIPE_TIMEOUT 5000 #define BUFSIZE 4096 typedef struct { OVERLAPPED oOverlap; HANDLE hPipeInst; TCHAR chRequest[BUFSIZE]; DWORD cbRead; TCHAR chReply[BUFSIZE]; DWORD cbToWrite; } PIPEINST, *LPPIPEINST; PIPEINST Pipe; HANDLE hEvent; VOID GetAnswerToRequest(LPPIPEINST pipe) { _tprintf( TEXT("[%d] %s\n"), pipe->hPipeInst, pipe->chRequest); memset(pipe->chRequest,0,sizeof(pipe->chRequest)*sizeof(TCHAR)); _tscanf(_T("%[^\n]"),pipe->chReply); fflush(stdin); pipe->cbToWrite = (lstrlen(pipe->chReply)+1)*sizeof(TCHAR); } int _tmain(VOID) { DWORD cbRet; BOOL fSuccess; LPTSTR lpszPipename = TEXT("\\\\.\\pipe\\mynamedpipe"); // Create an event object for this instance. hEvent = CreateEvent( NULL, // default security attribute TRUE, // manual-reset event TRUE, // initial state = signaled NULL); // unnamed event object if (hEvent == NULL) { return 0; } Pipe.oOverlap.hEvent = hEvent; Pipe.hPipeInst = CreateNamedPipe( lpszPipename, // pipe name PIPE_ACCESS_DUPLEX | // read/write access FILE_FLAG_OVERLAPPED, // overlapped mode PIPE_TYPE_MESSAGE | // message-type pipe PIPE_READMODE_MESSAGE | // message-read mode PIPE_WAIT, // blocking mode 1, // number of instances BUFSIZE*sizeof(TCHAR), // output buffer size BUFSIZE*sizeof(TCHAR), // input buffer size PIPE_TIMEOUT, // client time-out NULL); // default security attributes if (Pipe.hPipeInst == INVALID_HANDLE_VALUE) { return 0; } ConnectNamedPipe(Pipe.hPipeInst, &Pipe.oOverlap); WaitForSingleObject( hEvent,INFINITE); while (1) { fSuccess = ReadFile( Pipe.hPipeInst, Pipe.chRequest, BUFSIZE*sizeof(TCHAR), &Pipe.cbRead, &Pipe.oOverlap); if (_tcscmp(Pipe.chRequest,_T(""))!=0) { GetAnswerToRequest(&Pipe); fSuccess = WriteFile( Pipe.hPipeInst, Pipe.chReply, Pipe.cbToWrite, &cbRet, &Pipe.oOverlap); } else { Sleep(1); } } return 0; }