server：

#include <stdio.h>
#include <conio.h>  
#include <tchar.h>
#include <Windows.h>
#include <process.h>
#include <stdlib.h>
#include <iostream>
const char *pStrPipeNameGet = "\\\\.\\pipe\\recv_data_pipe";// 注意命名管道的規則：\\servername\pipe\pipename，如果是本地管道則servername可以使用點“.”
HANDLE hSemaphore;

void RecvDataThread(PVOID p) 
{
	printf("管道伺服器已經啟動，等待連線...\n");

	// 建立一個命名管道
	HANDLE hPipe = CreateNamedPipe(pStrPipeNameGet, // 管道的名稱
		                           PIPE_ACCESS_DUPLEX,// 管道的開啟模式
		                           PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,// 管道的使用模式
		                           PIPE_UNLIMITED_INSTANCES, // 管道可以接收的最大客戶量
		                           0, // 輸出緩衝區長度；零表示用預設設定
		                           0, // 輸入緩衝區長度；零表示用預設設定
		                           NMPWAIT_WAIT_FOREVER, // 管道的預設等待超時
		                          NULL);// 安全屬性結構
	
	const int BUFFER_MAX_LEN = 1024;
	DWORD dwRecvDataLen;
	char buf[BUFFER_MAX_LEN];
	// 等待客戶端管道的連線
	if (ConnectNamedPipe(hPipe, NULL) != NULL)  
	{
		printf("連線成功，開始接收資料\n");
		while (true)
		{
			// 接收客戶端傳送的資料  
			if (!ReadFile(hPipe, buf, BUFFER_MAX_LEN, &dwRecvDataLen, NULL))
				break;
			printf("接收到來自客戶端的資料長度為%d位元組\n", dwRecvDataLen);
			printf("具體資料內容如下：");
			std::cout << buf << std::endl;
		}
	}
	else
	{
		printf("連線失敗\n");
	}

	// 斷開所有與命名管道上的連線
	DisconnectNamedPipe(hPipe);

	// 關閉命名管道
	CloseHandle(hPipe);

	ReleaseSemaphore(hSemaphore, 1, NULL);
}

int _tmain(int argc, _TCHAR* argv[])
{
	hSemaphore = CreateSemaphore(NULL, 0, 1, TEXT("my_semaphore"));
	_beginthread(RecvDataThread, NULL, NULL);
	WaitForSingleObject(hSemaphore, INFINITE);

	std::cout << "按任意鍵退出." << std::endl;
	std::cin.get();
	return 0;
}
 

#include <stdio.h>
#include <tchar.h>
#include <Windows.h>
#include <conio.h>  
#include <iostream>
const char *pStrPipeName = "\\\\.\\pipe\\recv_data_pipe";
const int BUFFER_MAX_LEN = 1024;
char buf[BUFFER_MAX_LEN];

int _tmain(int argc, _TCHAR* argv[])
{
	printf("等待管道伺服器......\r\n");
	if (!WaitNamedPipe(pStrPipeName, 100000))
	{
		printf("連線管道伺服器失敗.\r\n");
		std::cin.get();
		return 0;
	}
	HANDLE hPipe = CreateFile(pStrPipeName, GENERIC_WRITE, 0, NULL, OPEN_EXISTING, FILE_ATTRIBUTE_NORMAL, NULL);
	while (true)
	{
		printf("請輸入要向服務端傳送的資料，回車鍵結束，最大1024個位元組\r\n");
		DWORD dwLen = 0;
		int bufSize;
		std::cin >> buf;
		bufSize = strlen(buf)+1;
		buf[bufSize] = '\0';
		//向服務端傳送資料  
		if (WriteFile(hPipe, buf, bufSize, &dwLen, NULL)) {
			printf("資料寫入完畢共%d位元組\r\n", dwLen);
		}
		else
		{
			printf("資料寫入失敗\n");
		}
		if (strcmp(buf, "exit") == 0)
			break;
	}
	CloseHandle(hPipe);
	return 0;
}