• win下命名管道通信压力测试实现（含c++示例代码）

    目录

    一、关于命名管道概述

    二、命名管道测试实现

    三、编译实现

    四、补充

    一、关于命名管道概述

           管道是一个有两端的对象。一个进程向管道写入信息，而另外一个进程从管道读取信息。进程可以从这个对象的一个端口写数据，从另一个端口读数据。创建管道的进程称为管道服务器(Pipe Server)，而连接到这个管道的进程称为管道客户端(Pipe Client)。
            在 Windows 系统中，存在两种类型的管道: “匿名管道”(Anonymous pipes)和“命名管道”(Named pipes)。匿名管道是基于字符和半双工的（即单向）；命名管道是面向消息和全双工的，同时还允许网络通信，用于创建客户端/服务器系统。

            匿名管道：单向通信，只能本地使用。由于匿名管道单向通信，且只能在本地使用的特性，一般用于程序输入输出的重定向，如一些后门程序获取 cmd 内容等等。

            命名管道是一个具有名称，可在同一台计算机的不同进程之间或在跨越一个网络的不同计算机的不同进程之间，支持可靠的、单向或双向的数据通信管道。命名管道的所有实例拥有相同的名称，但是每个实例都有其自己的缓冲区和句柄，用来为不同客户端提供独立的管道。任何进程都可以访问命名管道，并接受安全权限的检查，通过命名管道使相关的或不相关的进程之间的通讯变得异常简单。

    二、命名管道测试实现

            win c++标准函数中，已提供了CreateNamedPipe、ConnectNamedPipe、WriteFile、ReadFile、CloseHandle等创建、连接、使用、关闭的管道操作函数，本测试中，将建立进可能多的线程，对通一命名管道进行大量、快速的读写操作。

            本次测试将创建一个管道，并创建ipc服务端接收数据和ipc客户端发送数据，同时有300百个线程对管道进行数据写入及读取操作，测试完成10万次数据写入及读取操作，看看是否其管道通信效率如何。

            本文采用vs2010+cmake完成编译测试，测试代码目录结构如下：

    1. ipc_test
    2.     bin
    3.     build
    4.     ipc
    5.         ipcclient.h
    6.         ipcclient.cpp
    7.         ipcserver.h
    8.         ipcserver.cpp
    9.     src
    10.         main.cpp
    11.     CMakeLists.txt

            ipcclient.h

          

    1. #ifndef _IPC_CLIENT_H_
    2. #define _IPC_CLIENT_H_
    3.  
    4. #include 
    5.  
    6. class IPCClient
    7. {
    8. public:
    9. 	IPCClient(int n);
    10.     ~IPCClient();
    11.  
    12. 	int WriteInfo(char *, DWORD , DWORD* );
    13. 	int ReadInfo(char *, DWORD , DWORD* );
    14. private:
    15. 	bool Connect();
    16. private:
    17. 	int _nID;
    18.     HANDLE _hPipe;
    19. 	bool _bConnected;
    20. };
    21.  
    22. #endif // _IPC_CLIENT_H_

    ipcclient.cpp实现管道打开连接、数据写入操作，管道名称和服务端保持一致，例如"\\\\.\\pipe\\pyfree"。

    1. #include "ipcclient.h"
    2.  
    3. #include 
    4. #include 
    5.  
    6. IPCClient::IPCClient(int n) 
    7. 	: _nID(n)
    8. 	, _bConnected(false)
    9. 	, _hPipe(INVALID_HANDLE_VALUE)
    10. {
    11. 	Connect();
    12. }
    13.  
    14. IPCClient::~IPCClient()
    15. {
    16. 	if(_hPipe!=INVALID_HANDLE_VALUE){
    17. 		CloseHandle(_hPipe);
    18. 		_hPipe = INVALID_HANDLE_VALUE;
    19. 	}
    20. }
    21.  
    22. bool IPCClient::Connect()
    23. {
    24. 	if(_bConnected)
    25. 		return _bConnected;
    26. 	_bConnected = false;
    27. 	std::string path = "\\\\.\\pipe\\pyfree";
    28. 	path += std::to_string(long long(_nID));
    29. 	if (!WaitNamedPipe(path.c_str(), NMPWAIT_USE_DEFAULT_WAIT/* NMPWAIT_WAIT_FOREVER*/) == FALSE)
    30. 	{
    31. 		_hPipe = CreateFile(path.c_str(),
    32. 			GENERIC_READ|GENERIC_WRITE,
    33. 			0,
    34. 			NULL,
    35. 			OPEN_EXISTING,
    36. 			FILE_ATTRIBUTE_NORMAL/*|FILE_FLAG_OVERLAPPED*/,
    37. 			NULL);
    38. 		if(INVALID_HANDLE_VALUE != _hPipe)
    39. 			_bConnected = true;
    40. 	}
    41. 	return _bConnected;
    42. }
    43.  
    44.  
    45. int IPCClient::ReadInfo(char * buf, DWORD dwMaxLen, DWORD* pdwLen)
    46. {
    47. 	int nRet = 0;
    48. 	if(!Connect())
    49. 		return -1;
    50. 	if(!ReadFile(_hPipe,buf,dwMaxLen,pdwLen,NULL))
    51. 	{
    52. 		DWORD dwError = GetLastError();
    53. 		if(ERROR_IO_PENDING != dwError)
    54. 		{
    55. 			CloseHandle(_hPipe);
    56. 			_hPipe = INVALID_HANDLE_VALUE;
    57. 			_bConnected = false;
    58. 			nRet = 0 - dwError;
    59. 		}
    60. 	}
    61. 	return nRet;
    62. }
    63. int IPCClient::WriteInfo(char * buf, DWORD nMaxLen, DWORD* pdwLen)
    64. {
    65. 	int nRet = 0;
    66. 	if(!Connect())
    67. 		return -1;
    68. 	if(!WriteFile(_hPipe,buf,nMaxLen,pdwLen,NULL))
    69. 	{
    70. 		DWORD dwError = GetLastError();
    71. 		if(ERROR_IO_PENDING != dwError)
    72. 		{
    73. 			CloseHandle(_hPipe);
    74. 			_bConnected = false;
    75. 			_hPipe = INVALID_HANDLE_VALUE;
    76. 			nRet = 0 - dwError;
    77. 		}
    78. 	}
    79. 	return nRet;
    80. }

    ipcserver.h

    1. #ifndef _IPC_SERVER_H_
    2. #define _IPC_SERVER_H_
    3.  
    4. #include 
    5.  
    6. //const DWORD BUFSIZE = 1024*64;
    7. const DWORD BUFSIZE = 512;
    8. const DWORD PIPE_TIMEOUT = 3000;
    9.  
    10. class IPCServer
    11. {
    12. public:
    13. 	IPCServer(int n);
    14.     ~IPCServer();
    15. 	int ReadInfo(char *, DWORD , DWORD*);
    16. 	int WriteInfo(char *, DWORD , DWORD*);
    17. private:
    18.     bool Connect();
    19. 	bool DisConnect();
    20. private:
    21. 	int _nID;
    22.     HANDLE _hPipe;
    23. 	bool _bConnected;
    24. };
    25.  
    26. #endif // _IPC_SERVER_H_

    ipcserver.cpp实现管道创建、等待连接、数据读取等操作，管道名称和ipcclient保持一致，例如"\\\\.\\pipe\\pyfree"。

    1. #include "ipcserver.h"
    2.  
    3. #include 
    4. #include 
    5. #include 
    6.  
    7. IPCServer::IPCServer(int n) 
    8. 	: _nID(n)
    9. 	, _bConnected(false) 
    10. 	, _hPipe(INVALID_HANDLE_VALUE)
    11. {
    12. 	Connect();
    13. }
    14.  
    15. IPCServer::~IPCServer()
    16. {
    17.     CloseHandle(_hPipe);
    18. }
    19.  
    20. bool IPCServer::Connect()
    21. {
    22. 	if(_bConnected)
    23. 		return _bConnected;
    24. 	if(_hPipe == INVALID_HANDLE_VALUE)
    25. 	{
    26. 		std::string path = "\\\\.\\pipe\\pyfree";
    27. 		path += std::to_string(long long(_nID));
    28. 		_hPipe = CreateNamedPipe(path.c_str(),
    29. 			PIPE_ACCESS_DUPLEX|FILE_FLAG_OVERLAPPED,
    30. 			PIPE_TYPE_MESSAGE | PIPE_READMODE_MESSAGE | PIPE_WAIT,
    31. 			1,
    32. 			BUFSIZE,
    33. 			BUFSIZE,
    34. 			PIPE_TIMEOUT,
    35. 			NULL);
    36. 	}
    37. 	if (_hPipe == INVALID_HANDLE_VALUE) 
    38. 	{
    39. 		//std::cout << "CreatePipe Error" << std::endl;
    40. 		return _bConnected;
    41. 	}
    42. 	HANDLE hEvent;
    43. 	hEvent=CreateEvent(NULL,TRUE,FALSE,NULL);
    44. 	if (!hEvent)
    45. 	{
    46. 		CloseHandle(hEvent);
    47. 		//std::cout << "CreateEvent Error" << std::endl;
    48. 		return _bConnected;
    49. 	}
    50. 	OVERLAPPED olp;
    51. 	ZeroMemory(&olp,sizeof(OVERLAPPED));
    52. 	olp.hEvent=hEvent;
    53. 	if(!ConnectNamedPipe(_hPipe, &olp))
    54. 	{
    55. 		if(ERROR_IO_PENDING != GetLastError())//waitfor client link。
    56. 		{
    57. 			CloseHandle(_hPipe);
    58. 			CloseHandle(hEvent);
    59. 			_hPipe = INVALID_HANDLE_VALUE;
    60. 			//std::cout << "ConnectPipe Error" << std::endl;
    61. 			return _bConnected;
    62. 		}
    63. 	}
    64. 	DWORD waitforEvent = WaitForSingleObject(hEvent,INFINITE);
    65. 	if(WAIT_FAILED==waitforEvent||WAIT_TIMEOUT==waitforEvent)
    66. 	{
    67. 		CloseHandle(hEvent);	
    68. 		CloseHandle(_hPipe);
    69. 		_hPipe = INVALID_HANDLE_VALUE;
    70. 		//std::cout << "ConnectPipe1 Error" << std::endl;
    71. 		return _bConnected;
    72. 	}
    73. 	CloseHandle(hEvent);
    74. 	_bConnected = true;
    75. 	return _bConnected;
    76. }
    77.  
    78.  
    79. bool IPCServer::DisConnect()
    80. {
    81. 	if(_bConnected)
    82. 	{
    83. 		if(DisconnectNamedPipe(_hPipe))
    84. 		{
    85.  
    86. 		}
    87. 		CloseHandle(_hPipe);
    88. 	}
    89. 	_bConnected = false;
    90. 	_hPipe = INVALID_HANDLE_VALUE;
    91. 	return true;
    92. }
    93.  
    94.  
    95.  
    96. int IPCServer::ReadInfo(char *wbuf, DWORD dwMaxLen, DWORD* pdwLen)
    97. {
    98. 	if(!Connect())
    99. 		return -1;
    100. 	int nRet = 0;
    101. 	if(!ReadFile(_hPipe,wbuf,dwMaxLen,pdwLen,NULL))
    102. 	{
    103. 		DWORD dwError = GetLastError();
    104. 		if(ERROR_IO_PENDING != dwError)
    105. 		{
    106. 			DisConnect();
    107. 			nRet = 0 - dwError;
    108. 		}
    109. 	}
    110. 	return nRet;
    111. }
    112.  
    113. int IPCServer::WriteInfo(char *buf, DWORD dwMaxLen, DWORD* pdwLen)
    114. {
    115. 	int nRet = 0;
    116. 	if(!Connect())
    117. 		return -1;
    118. 	if(!WriteFile(_hPipe,buf,dwMaxLen,pdwLen,NULL))
    119. 	{
    120. 		DWORD dwError = GetLastError();
    121. 		if(ERROR_IO_PENDING != dwError)
    122. 		{
    123. 			DisConnect();
    124. 			nRet = 0 - dwError;
    125. 		}
    126. 	}
    127. 	return nRet;
    128. }

    main.cpp实现创建线程，调用管道客户端(ipcclient)、服务端(ipcserver)实现数据的逻辑发送和接收，可以通过调整线程数量、发送数据宽度等调节进行压力测试。

    1. // main.cpp
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6.  
    7. #include "ipcclient.h"
    8. #include "ipcserver.h"
    9.  
    10. #define _TotalFrame 100000	//帧数量
    11. #define _TotalThread 300	//线程数
    12. //#define _strWhith 1024*64	//发送信息长度
    13. #define _strWhith 512		//发送信息长度
    14.  
    15. int nErrorCnt[_TotalThread] = {0};
    16. int nCount[_TotalThread]={0};
    17. int nAllSendCount[_TotalThread] = {0};
    18. int nAllReciveCount[_TotalThread] = {0};
    19. int m_MaxMsec[_TotalThread][2] = {0};
    20. int nSendCount[_TotalThread] ={0};
    21.  
    22. unsigned __stdcall Sender( void* parg )
    23. {
    24. 	int n = (int ) parg;		//线程编号
    25. 	char buf[_strWhith] = {0};	//发送信息及初始化
    26. 	IPCClient h(n);
    27. 	int msec=0;					//开始标记
    28. 	for(int i=0;i<_TotalFrame;) 
    29. 	{
    30. 		nAllSendCount[n]++;
    31. 		int *p = (int *)buf;
    32. 		p[0] = n;				//线程编号加入发送信息
    33. 		p[1] = i;				//发送次数加入发送信息
    34.  
    35. 		buf[_strWhith-1] = 'N';
    36. 		DWORD wlen=0;			//实际发送长度标记
    37. 		DWORD dwBegin = GetTickCount();
    38. 		int ret = h.WriteInfo(buf, _strWhith/4, &wlen);	//发送四分之一长度数据
    39. 		msec = GetTickCount() - dwBegin;
    40.  
    41. 		if(msec > m_MaxMsec[n][0]){
    42. 			m_MaxMsec[n][0] = msec;
    43. 			m_MaxMsec[n][1] = ret;
    44. 		}
    45. 		if(3==ret){
    46. 			std::cout << "error: info too long!" << std::endl;
    47. 		}
    48. 		if( ret == 0&&_strWhith/4==wlen)
    49. 		{
    50. 			i++;
    51. 			nCount[n] = i;
    52. 		}		
    53. 		::Sleep(1);
    54. 	}
    55. 	return 1;
    56. }
    57. unsigned __stdcall Receiver( void* parg )
    58. {
    59. 	int n = (int ) parg;		//线程编号
    60. 	char buf[_strWhith] = {0};	//接收信息及初始化
    61. 	IPCServer h(n);
    62. 	int msec = 0;
    63. 	int want = 0;
    64. 	for(int i=0;i<_TotalFrame;)
    65. 	{
    66. 		nAllReciveCount[n]++;
    67. 		int *p = (int *) buf;
    68. 		int nRet = 0;
    69. 		DWORD rlen = 0;
    70. 		DWORD dwBegin = GetTickCount();
    71. 		nRet = h.ReadInfo(buf, _strWhith,&rlen);
    72. 		msec = GetTickCount() - dwBegin;
    73. 		if(msec > m_MaxMsec[n][0]){
    74. 			m_MaxMsec[n][0] = msec;	
    75. 			m_MaxMsec[n][1] = nRet;
    76. 		}
    77. 		//实际接收数据长度不是四分之一,说明缓存过多，对管道的数据读取效率到了极限
    78. 		if(nRet == 0&&_strWhith/4!=rlen){
    79. 			if(n<10)
    80. 				std::cout << "Thread " << n << " received " << rlen <<  " string , send order:" << p[1] << std::endl;
    81.  
    82. 			int a=0;
    83. 			if(_strWhith/2==rlen)
    84. 			{
    85. 				a=2;
    86. 			}
    87. 			else if(3*_strWhith/4==rlen)
    88. 			{
    89. 				a=3;
    90. 			}
    91. 			else if(_strWhith==rlen)
    92. 			{
    93. 				a=4;
    94. 			}
    95. 			if(p[1] != want)
    96. 			{
    97. 				if(n<10)
    98. 					std::cout << "thread " << n << " want " << want <<  " , actual:" << p[1] << std::endl;
    99. 				nErrorCnt[n] = nErrorCnt[n] + 2;
    100. 			}
    101. 			nCount[n] = nCount[n] + a;
    102. 			want = p[1] + a;
    103. 			i=i+a;
    104. 		}
    105. 		//实际接收数据长度就是四分之一,即每次发送都能及时完全读取
    106. 		if(nRet == 0&&_strWhith/4==rlen)
    107. 		{
    108. 			if(p[1] != want)
    109. 			{
    110. 				if(n<1)
    111. 					std::cout << "Thread " << n << " want " << want <<  " , actual:" << p[1] << std::endl;
    112. 				nErrorCnt[n] ++;
    113. 			}
    114. 			nCount[n] ++;
    115. 			want = p[1] + 1;
    116. 			i++;
    117. 		}
    118. 		::Sleep(1);
    119. 	}
    120. 	return 1;
    121. }
    122.  
    123. int _tmain(int argc, _TCHAR* argv[])
    124. {
    125. 	unsigned  nThreadID[2][_TotalThread];	//两种线程句柄,一组用于发送、一组用于接收
    126. 	int bSender = 0;
    127. 	std::cout << "0: Receiver, 1: Sender" << std::endl;
    128. 	int ch = _getch();	//本次启动用于发送或接收选择
    129. 	if(ch == '1')
    130. 	{
    131. 		bSender = 1;
    132. 	}
    133.  
    134. 	std::cout <<(bSender?"Start Sending":"Start Receiving") << std::endl;
    135. 	for(int i=0;i<_TotalThread;i++)
    136. 	{
    137. 		HANDLE   hThread;  
    138. 		if(bSender)
    139. 			hThread = (HANDLE)_beginthreadex(NULL, 0 , Sender, (void *)i, 0, nThreadID[0] + i);
    140. 		else
    141. 			hThread = (HANDLE)_beginthreadex(NULL, 0 , Receiver, (void *)i, 0, nThreadID[1] + i);
    142. 		if( 0 == hThread ){
    143.              std::cout << "create thread : " <<(bSender?nThreadID[0][i]:nThreadID[1][i])<< " error! " << std::endl;
    144. 		}
    145. 	}
    146. 	bool bExit = false;
    147. 	for(;!bExit;)
    148. 	{
    149. 		::Sleep(1);
    150. 		if(_kbhit())
    151. 		{
    152. 			int ch = _getch();
    153. 			switch(ch)
    154. 			{
    155. 			case 'q':
    156. 				bExit = true;
    157. 				break;
    158. 			case 'd':
    159. 				std::cout << " ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ " << std::endl;
    160. 				for(int i=0;i<_TotalThread;i++){
    161. 					//if(m_MaxMsec[i][0]>20 || nErrorCnt[i])
    162. 					{
    163. 						std::cout << (bSender?"Sender ":"Reciever ") 
    164. 							<< i << /*" ,Max is:" << nMaxmsec <<*/" Error: " 
    165. 							<< nErrorCnt[i] << " Success : "<
    166. 							<< (bSender?" STotal: ":" RTotal: ") << (bSender?nAllSendCount[i]:nAllReciveCount[i])
    167. 							<< " maxTime: "<< m_MaxMsec[i][0]
    168. 							<< " type: " << m_MaxMsec[i][1]
    169. 							<< std::endl;
    170. 					}
    171. 				}
    172. 				break;
    173. 			}
    174. 		}
    175. 	}
    176. 	return 0;
    177. }
    178.

    三、编译实现

            CMakeLists.txt内容，本文给出Debug版本的。

    1. # CMake 最低版本号要求
    2. cmake_minimum_required(VERSION 2.8)
    3. # 项目信息
    4. project(ipc_test)
    5. #
    6. message(STATUS "windows compiling...")
    7. add_definitions(-D_PLATFORM_IS_WINDOWS_)
    8. #set(CMAKE_CXX_FLAGS_RELEASE "${CMAKE_CXX_FLAGS_RELEASE} /MT")
    9. set(CMAKE_CXX_FLAGS_DEBUG "${CMAKE_CXX_FLAGS_DEBUG} /MTd")
    10. set(WIN_OS true)
    11. #
    12. set(EXECUTABLE_OUTPUT_PATH ${PROJECT_SOURCE_DIR}/bin)
    13.  
    14. # 指定源文件的目录,并将名称保存到变量
    15. SET(source_h
    16.     #
    17. 	${PROJECT_SOURCE_DIR}/ipc/ipcclient.h
    18. 	${PROJECT_SOURCE_DIR}/ipc/ipcserver.h
    19.   )
    20.   
    21. SET(source_cpp
    22.     #
    23. 	${PROJECT_SOURCE_DIR}/ipc/ipcclient.cpp
    24. 	${PROJECT_SOURCE_DIR}/ipc/ipcserver.cpp
    25. 	${PROJECT_SOURCE_DIR}/src/main.cpp
    26.   )
    27.   
    28. #头文件目录
    29. include_directories(${PROJECT_SOURCE_DIR}/ipc)
    30.  
    31. set(CMAKE_RUNTIME_OUTPUT_DIRECTORY_DEBUG ${PROJECT_SOURCE_DIR}/bin)
    32. # 指定生成目标
    33. add_executable(ipc_testd ${source_h} ${source_cpp})

    打开vs2010 command prompt命令工具

    1. cmake -G "Visual Studio 10 2010 Win64" ..
    2. msbuild ipc_test.sln /p:Platform="x64"

    编译过程如下：

    1. D:\workForMy\workspace\ipc_test\build>cmake -G "Visual Studio 10 2010 Win64" ..
    2. -- The C compiler identification is MSVC 16.0.40219.1
    3. -- The CXX compiler identification is MSVC 16.0.40219.1
    4. -- Check for working C compiler: d:/Program Files (x86)/Microsoft Visual Studio 10.0/VC/bin/x86_amd64/cl.exe
    5. -- Check for working C compiler: d:/Program Files (x86)/Microsoft Visual Studio 10.0/VC/bin/x86_amd64/cl.exe -- works
    6. -- Detecting C compiler ABI info
    7. -- Detecting C compiler ABI info - done
    8. -- Check for working CXX compiler: d:/Program Files (x86)/Microsoft Visual Studio 10.0/VC/bin/x86_amd64/cl.exe
    9. -- Check for working CXX compiler: d:/Program Files (x86)/Microsoft Visual Studio 10.0/VC/bin/x86_amd64/cl.exe -- works
    10. -- Detecting CXX compiler ABI info
    11. -- Detecting CXX compiler ABI info - done
    12. -- Detecting CXX compile features
    13. -- Detecting CXX compile features - done
    14. -- windows compiling...
    15. -- Configuring done
    16. -- Generating done
    17. -- Build files have been written to: D:/workForMy/workspace/ipc_test/build
    19. D:\workForMy\workspace\ipc_test\build>msbuild ipc_test.sln /p:Platform="x64"
    20. Microsoft(R) 生成引擎版本 4.8.4084.0
    21. [Microsoft .NET Framework 版本 4.0.30319.42000]
    22. 版权所有 (C) Microsoft Corporation。保留所有权利。
    23.  
    24. 在此解决方案中一次生成一个项目。若要启用并行生成，请添加“/m”开关。
    25. 生成启动时间为 2022/9/11 15:34:14。
    26. 节点 1 上的项目“D:\workForMy\workspace\ipc_test\build\ipc_test.sln”(默认目标)。
    27. ValidateSolutionConfiguration:
    28.   正在生成解决方案配置“Debug|x64”。
    29. ValidateProjects:
    30.   在解决方案配置“Debug|x64”中未选定生成项目“ALL_BUILD”。
    31. 项目“D:\workForMy\workspace\ipc_test\build\ipc_test.sln”(1)正在节点 1 上生成“D:\workForMy\workspace\ipc_test\build\ZERO_CHECK.vc
    32. xproj”(2) (默认目标)。
    33. PrepareForBuild:
    34.   正在创建目录“x64\Debug\ZERO_CHECK\”。
    35. InitializeBuildStatus:
    36.   正在创建“x64\Debug\ZERO_CHECK\ZERO_CHECK.unsuccessfulbuild”，因为已指定“AlwaysCreate”。
    37. CustomBuild:
    38.   Checking Build System
    39.   CMake does not need to re-run because D:/workForMy/workspace/ipc_test/build/CMakeFiles/generate.stamp is up-to-date.
    40. FinalizeBuildStatus:
    41.   正在删除文件“x64\Debug\ZERO_CHECK\ZERO_CHECK.unsuccessfulbuild”。
    42.   正在对“x64\Debug\ZERO_CHECK\ZERO_CHECK.lastbuildstate”执行 Touch 任务。
    43. 已完成生成项目“D:\workForMy\workspace\ipc_test\build\ZERO_CHECK.vcxproj”(默认目标)的操作。
    44.  
    45. 项目“D:\workForMy\workspace\ipc_test\build\ipc_test.sln”(1)正在节点 1 上生成“D:\workForMy\workspace\ipc_test\build\ipc_testd.vcx
    46. proj.metaproj”(3) (默认目标)。
    47. 项目“D:\workForMy\workspace\ipc_test\build\ipc_testd.vcxproj.metaproj”(3)正在节点 1 上生成“D:\workForMy\workspace\ipc_test\build
    48. \ipc_testd.vcxproj”(4) (默认目标)。
    49. PrepareForBuild:
    50.   正在创建目录“ipc_testd.dir\Debug\”。
    51. InitializeBuildStatus:
    52.   正在创建“ipc_testd.dir\Debug\ipc_testd.unsuccessfulbuild”，因为已指定“AlwaysCreate”。
    53. CustomBuild:
    54.   Building Custom Rule D:/workForMy/workspace/ipc_test/CMakeLists.txt
    55.   CMake does not need to re-run because D:/workForMy/workspace/ipc_test/build/CMakeFiles/generate.stamp is up-to-date.
    56. MakeDirsForCl:
    57.   正在创建目录“D:\workForMy\workspace\ipc_test\build\Debug”。
    58. ClCompile:
    59.   d:\Program Files (x86)\Microsoft Visual Studio 10.0\VC\bin\x86_amd64\CL.exe /c /ID:\workForMy\workspace\ipc_test\ipc
    60.   /I"D:\workForSoftware\Visual Leak Detector\include" /Zi /nologo /W3 /WX- /Od /Ob0 /D WIN32 /D _WINDOWS /D _PLATFORM_I
    61.   S_WINDOWS_ /D "CMAKE_INTDIR=\"Debug\"" /D _MBCS /Gm- /EHsc /RTC1 /MTd /GS /fp:precise /Zc:wchar_t /Zc:forScope /GR /F
    62.   o"ipc_testd.dir\Debug\\" /Fd"ipc_testd.dir\Debug\vc100.pdb" /Gd /TP /errorReport:queue ..\ipc\ipcclient.cpp ..\ipc\ip
    63.   cserver.cpp ..\src\main.cpp
    64.   ipcclient.cpp
    65.   ipcserver.cpp
    66.   main.cpp
    67.   Generating Code...
    68. ManifestResourceCompile:
    69.   C:\Program Files (x86)\Microsoft SDKs\Windows\v7.0A\bin\rc.exe /nologo /fo"ipc_testd.dir\Debug\ipc_testd.exe.embed.ma
    70.   nifest.res" ipc_testd.dir\Debug\ipc_testd_manifest.rc
    71. Link:
    72.   d:\Program Files (x86)\Microsoft Visual Studio 10.0\VC\bin\x86_amd64\link.exe /ERRORREPORT:QUEUE /OUT:"D:\workForMy\w
    73.   orkspace\ipc_test\bin\ipc_testd.exe" /INCREMENTAL /NOLOGO /LIBPATH:"D:\workForSoftware\Visual Leak Detector\lib\Win64
    74.   " kernel32.lib user32.lib gdi32.lib winspool.lib shell32.lib ole32.lib oleaut32.lib uuid.lib comdlg32.lib advapi32.li
    75.   b /MANIFEST /ManifestFile:"ipc_testd.dir\Debug\ipc_testd.exe.intermediate.manifest" /MANIFESTUAC:"level='asInvoker' u
    76.   iAccess='false'" /DEBUG /PDB:"D:/workForMy/workspace/ipc_test/bin/ipc_testd.pdb" /SUBSYSTEM:CONSOLE /TLBID:1 /DYNAMIC
    77.   BASE /NXCOMPAT /IMPLIB:"D:/workForMy/workspace/ipc_test/bin/Debug/ipc_testd.lib" /MACHINE:X64 ipc_testd.dir\Debug\ipc
    78.   _testd.exe.embed.manifest.res
    79.   ipc_testd.dir\Debug\ipcclient.obj
    80.   ipc_testd.dir\Debug\ipcserver.obj
    81.   ipc_testd.dir\Debug\main.obj   /machine:x64
    82.   ipc_testd.vcxproj -> D:\workForMy\workspace\ipc_test\bin\ipc_testd.exe
    83. Manifest:
    84.   C:\Program Files (x86)\Microsoft SDKs\Windows\v7.0A\bin\mt.exe /nologo /verbose /out:"ipc_testd.dir\Debug\ipc_testd.e
    85.   xe.embed.manifest" /manifest ipc_testd.dir\Debug\ipc_testd.exe.intermediate.manifest
    86.   C:\Program Files (x86)\Microsoft SDKs\Windows\v7.0A\bin\rc.exe /nologo /fo"ipc_testd.dir\Debug\ipc_testd.exe.embed.ma
    87.   nifest.res" ipc_testd.dir\Debug\ipc_testd_manifest.rc
    88. LinkEmbedManifest:
    89.   d:\Program Files (x86)\Microsoft Visual Studio 10.0\VC\bin\x86_amd64\link.exe /ERRORREPORT:QUEUE /OUT:"D:\workForMy\w
    90.   orkspace\ipc_test\bin\ipc_testd.exe" /INCREMENTAL /NOLOGO /LIBPATH:"D:\workForSoftware\Visual Leak Detector\lib\Win64
    91.   " kernel32.lib user32.lib gdi32.lib winspool.lib shell32.lib ole32.lib oleaut32.lib uuid.lib comdlg32.lib advapi32.li
    92.   b /MANIFEST /ManifestFile:"ipc_testd.dir\Debug\ipc_testd.exe.intermediate.manifest" /MANIFESTUAC:"level='asInvoker' u
    93.   iAccess='false'" /DEBUG /PDB:"D:/workForMy/workspace/ipc_test/bin/ipc_testd.pdb" /SUBSYSTEM:CONSOLE /TLBID:1 /DYNAMIC
    94.   BASE /NXCOMPAT /IMPLIB:"D:/workForMy/workspace/ipc_test/bin/Debug/ipc_testd.lib" /MACHINE:X64 ipc_testd.dir\Debug\ipc
    95.   _testd.exe.embed.manifest.res
    96.   ipc_testd.dir\Debug\ipcclient.obj
    97.   ipc_testd.dir\Debug\ipcserver.obj
    98.   ipc_testd.dir\Debug\main.obj   /machine:x64
    99.   ipc_testd.vcxproj -> D:\workForMy\workspace\ipc_test\bin\ipc_testd.exe
    100. FinalizeBuildStatus:
    101.   正在删除文件“ipc_testd.dir\Debug\ipc_testd.unsuccessfulbuild”。
    102.   正在对“ipc_testd.dir\Debug\ipc_testd.lastbuildstate”执行 Touch 任务。
    103. 已完成生成项目“D:\workForMy\workspace\ipc_test\build\ipc_testd.vcxproj”(默认目标)的操作。
    105. 已完成生成项目“D:\workForMy\workspace\ipc_test\build\ipc_testd.vcxproj.metaproj”(默认目标)的操作。
    107. 已完成生成项目“D:\workForMy\workspace\ipc_test\build\ipc_test.sln”(默认目标)的操作。
    110. 已成功生成。
    111.     0 个警告
    112.     0 个错误
    114. 已用时间 00:00:02.99
    116. D:\workForMy\workspace\ipc_test\build>

    启动测试：

     本文测试了多次,程序启动后大概执行近2分钟后，按“d”输出打印结果，最终是所有线程、所有数据的写入及读取逻辑顺序都是正确的

    四、补充

    应部分读者要求，完整代码已经上传CSDN：

    win下命名管道通信压力测试实现的完整c++示例代码-C++文档类资源-CSDN下载

  • 相关阅读:
    ROS2入门之基本介绍
    AppCube视角浅析： 艾瑞咨询《2022年中国低代码行业研究报告》
    探索Python中的装饰器
    前端进击笔记第二十一节 如何搭建前端监控体系为业务排忧解难？
    旁边的同事突然晋升阿里P7，只因偷偷学习了这份JVM笔记？
    笔试强训48天——day16
    C# 图解教程 第5版 —— 第5章 类的基本概念
    基于粒子群优化算法的微型燃气轮机冷热电联供系统优化调度（Matlab代码实现）
    流程控制.
    螺杆支撑座大作用
  • 原文地址：https://blog.csdn.net/py8105/article/details/126805147