devbox
繁依Fanyi0
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

C++Windows下用Winsock创建的Socket服务端和客户端_windows c++socket例子

作者：繁依Fanyi0 | 2024-02-26 21:07:44

赞

踩

windows c++socket例子

 服务端代码，由于recv和send用的是阻塞函数，考虑用多线程开两个子线程分别读写

服务端:

头文件Server.h

  1. #include <WinSock2.h>
  2. #include <iostream>
  3. #include <vector>
  4. #pragma comment(lib,"ws2_32.lib")
  5.  
  6. using namespace std;
  7.  
  8. #define PORT 7777
  9.  
  10. DWORD WINAPI SendMessage(LPVOID LParam)
  11. {
  12. 	SOCKET* sockClient = (SOCKET*)LParam;
  13.  
  14. 	//登录初始化
  15. 	char recvBuf[100];
  16. 	memset(recvBuf,0,sizeof(recvBuf));
  17. 	char sendbuf[] = "服务器连接成功！欢迎... ...\n输入bye退出";
  18. 	int ret = send(*sockClient,sendbuf,sizeof(sendbuf),0);
  19. 	if(ret == SOCKET_ERROR)
  20. 	{
  21. 		cout << "Send data failed ... ..." <<endl;
  22. 		return -1;
  23. 	}
  24.  
  25. 	while(strcmp(sendbuf,"bye")!=0)
  26. 	{
  27. 		//============== send() ==============
  28. 		memset(sendbuf,0,sizeof(sendbuf));
  29. 		cin >> sendbuf;
  30. 		ret = send(*sockClient,sendbuf,sizeof(sendbuf),0);
  31. 		if(ret == SOCKET_ERROR)
  32. 		{
  33. 			cout << "Send data failed ... ..." <<endl;
  34. 			return -2;
  35. 		}
  36. 	}
  37. 	return NULL;
  38. }
  39.  
  40. DWORD WINAPI ReceiveMessage(LPVOID LParam)
  41. {
  42. 	SOCKET* sockClient = (SOCKET*)LParam;
  43.  
  44. 	char receivebuf[2048];
  45. 	
  46.  
  47. 	int ret = 0;
  48. 	while(strcmp(receivebuf,"bye")!=0)
  49. 	{
  50. 		//============== recv() ==============
  51. 		memset(receivebuf,0,sizeof(receivebuf));
  52. 		ret = recv(*sockClient,receivebuf,sizeof(receivebuf),0);
  53. 		if(ret >=0 )
  54. 		{
  55. 			//cout << "########## receive data(" << ret << " byte) ##########" <<endl;
  56. 			cout << receivebuf <<endl;
  57. 		}
  58. 	}
  59. 	return NULL;
  60. }
  61.  
  62. class CServer
  63. {
  64. public:
  65. 	CServer(int nPort=PORT);
  66. 	~CServer();
  67.  
  68. 	int Socket();
  69. 	int Bind();
  70. 	int Listen();
  71. 	int Accept();
  72. 	int CreateConversation();
  73.  
  74. 	HANDLE GetSendHandle();
  75. 	HANDLE GetReceiveHandle();
  76.  
  77. protected:
  78. private:
  79. 	HANDLE m_hSendThread;
  80. 	HANDLE m_hReceiveThread;
  81. 	DWORD m_dSendThreadId;
  82. 	DWORD m_dReceiveThreadId;
  83. 	int m_nPort;
  84. 	SOCKET sockSrv;
  85. 	SOCKADDR_IN m_addrSrv;
  86.  
  87. 	//客户端信息
  88. 	SOCKET sockClient;
  89. 	SOCKADDR_IN m_addrClient;
  90. };

Server.cpp

  1. #include "Server.h"
  2. #include <Windows.h>
  3.  
  4.  
  5. DWORD WINAPI CONNECT_POOLING(LPVOID lpParam)
  6. {
  7. 	return 0;
  8. }
  9.  
  10. CServer::CServer(int nPort)
  11. {
  12. 	m_nPort = nPort;
  13. 	m_hSendThread = NULL;
  14. 	m_hReceiveThread = NULL;
  15.  
  16. 	//初始化IP和port
  17. 	m_addrSrv.sin_family = AF_INET;
  18. 	m_addrSrv.sin_port = htons(m_nPort);//1024以上端口号
  19. 	m_addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
  20. }
  21.  
  22. CServer::~CServer()
  23. {
  24. 	m_nPort = 0;
  25. 	CloseHandle(m_hSendThread);
  26. 	CloseHandle(m_hReceiveThread);
  27. 	closesocket(sockClient);
  28. 	closesocket(sockSrv);
  29. 	WSACleanup();
  30. }
  31.  
  32. int CServer::Socket()
  33. {
  34. 	WSADATA data;
  35. 	int ret = WSAStartup(MAKEWORD(2,2),&data);
  36. 	//Debug
  37. 	/*cout << "Initialization return " << ret << endl;*/
  38.  
  39. 	if(ret)
  40. 	{
  41. 		cout << "Socket initialization failed: " << WSAGetLastError() << "... ..." << endl;
  42. 		return -1;
  43. 	}
  44.  
  45. 	sockSrv = socket(AF_INET,SOCK_STREAM,0);
  46. 	if (SOCKET_ERROR == sockSrv)
  47. 	{
  48. 		cout << "Socket create failed: " << WSAGetLastError() << "... ..." << endl;
  49. 		return -2;
  50. 	}
  51. 	return ret;
  52. }
  53.  
  54. int CServer::Bind()
  55. {
  56. 	//SOCKET sock = sockSrv;
  57. 	//============== bind() ==============
  58. 	int ret = bind(sockSrv,(LPSOCKADDR)&m_addrSrv,sizeof(SOCKADDR_IN));
  59. 	
  60. 	//Debug
  61. 	/*cout << "bind return " << ret << endl;*/
  62.  
  63. 	if(ret)
  64. 	{
  65. 		cout << "Socket bind failed: " << WSAGetLastError() << "... ..." << endl;
  66. 		return -2;
  67. 	}
  68. 	else
  69. 	{
  70. 		cout << "Socket bind succeed! " << endl;
  71. 	}
  72.  
  73. 	return ret;
  74. }
  75.  
  76. int CServer::Listen()
  77. {
  78. 	//============== listen() ==============
  79. 	int ret = listen(sockSrv,10);
  80. 	
  81. 	if(ret == SOCKET_ERROR)
  82. 	{
  83. 		cout << "Socket listen failed: " << WSAGetLastError() << "... ..." << endl;
  84. 		return -3;
  85. 	}
  86.  
  87. 	//begin to listen
  88. 	cout << "Server start successfully ... ... Begin listening on "<< m_nPort << endl;
  89.  
  90. 	return ret;
  91. }
  92.  
  93. int CServer::Accept()
  94. {
  95. 	int len = sizeof(SOCKADDR);
  96. 	//等待客户端connect请求
  97. 	//============== accept() ==============
  98. 	sockClient = accept(sockSrv,(LPSOCKADDR)&m_addrClient,&len);
  99.  
  100. 	if (sockClient == SOCKET_ERROR)
  101. 	{
  102. 		cout << "Build connection failed: " << WSAGetLastError() << "... ..." << endl;
  103. 		return -1;
  104. 	}
  105. 	else
  106. 	{
  107. 		printf("Server(%s:%d) build connection with Client at %s:%d\n",
  108. 			inet_ntoa(m_addrSrv.sin_addr),htons(m_addrSrv.sin_port),
  109. 			inet_ntoa(m_addrClient.sin_addr),htons(m_addrClient.sin_port));
  110. 	}
  111. 	return 0;
  112. }
  113.  
  114. int CServer::CreateConversation()
  115. {
  116. 	m_hSendThread = CreateThread(NULL,0,SendMessage,&sockClient,0,&m_dSendThreadId);
  117. 	m_hReceiveThread = CreateThread(NULL,0,ReceiveMessage,&sockClient,0,&m_dReceiveThreadId);
  118. 	
  119. 	return 0;
  120. }
  121.  
  122. HANDLE CServer::GetSendHandle()
  123. {
  124. 	return m_hSendThread;
  125. }
  126.  
  127. HANDLE CServer::GetReceiveHandle()
  128. {
  129. 	return m_hReceiveThread;
  130. }
  131.  
  132.  
  133. int Initialize()
  134. {
  135. 	WSADATA data;
  136. 	int ret = WSAStartup(MAKEWORD(2,2),&data);
  137. 	//Debug
  138. 	/*cout << "Initialization return " << ret << endl;*/
  139.  
  140. 	if(ret)
  141. 	{
  142. 		cout << "Socket initialization failed: " << WSAGetLastError() << "... ..." << endl;
  143. 		return -1;
  144. 	}
  145. 	return 0;
  146. }
  147.  
  148. int Start_Server()
  149. {
  150. 	int ret = 0;
  151. 	//============== socket() ==============
  152. 	SOCKET sockSrv = socket(AF_INET,SOCK_STREAM,0);
  153. 	unsigned long pcmd = NULL;
  154.  
  155. 	//Debug
  156. 	/*ret = sockSrv;
  157. 	cout << "socket return " << ret << endl;
  158. 	if(SOCKET_ERROR == ret)
  159. 	{
  160. 		cout << "Socket create failed: " << WSAGetLastError() << "... ..." << endl;
  161. 	}*/
  162. 	
  163. 	//初始化IP和port
  164. 	SOCKADDR_IN addrSrv;
  165. 	addrSrv.sin_family = AF_INET;
  166. 	addrSrv.sin_port = htons(PORT);//1024以上端口号
  167. 	addrSrv.sin_addr.S_un.S_addr = htonl(INADDR_ANY);
  168.  
  169. 	//============== bind() ==============
  170. 	ret = bind(sockSrv,(LPSOCKADDR)&addrSrv,sizeof(SOCKADDR_IN));
  171. 	//Debug
  172. 	/*cout << "bind return " << ret << endl;*/
  173.  
  174. 	if(ret)
  175. 	{
  176. 		cout << "Socket bind failed: " << WSAGetLastError() << "... ..." << endl;
  177. 		return -2;
  178. 	}
  179.  
  180. 	//============== listen() ==============
  181. 	ret = listen(sockSrv,10);
  182. 	if(ret == SOCKET_ERROR)
  183. 	{
  184. 		cout << "Socket listen failed: " << WSAGetLastError() << "... ..." << endl;
  185. 		return -3;
  186. 	}
  187. 	//客户端信息
  188. 	SOCKADDR_IN addrClient;
  189. 	int len = sizeof(SOCKADDR);
  190. 	//begin to listen
  191. 	cout << "Server start successfully ... ... Begin listening" << endl;
  192. 	while(1)
  193. 	{
  194. 		//等待客户端connect请求
  195. 		//============== accept() ==============
  196. 		SOCKET sockConn = accept(sockSrv,(LPSOCKADDR)&addrClient,&len);
  197. 		//ioctlsocket(sockConn,FIONBIO,&pcmd);
  198. 		if (sockConn == SOCKET_ERROR)
  199. 		{
  200. 			cout << "Build connection failed: " << WSAGetLastError() << "... ..." << endl;
  201. 			break;
  202. 		}
  203. 		printf("Server(%s:%d) build connection with Client at %s:%d\n",
  204. 			inet_ntoa(addrSrv.sin_addr),htons(addrSrv.sin_port),
  205. 			inet_ntoa(addrClient.sin_addr),htons(addrClient.sin_port));
  206.  
  207. 		//登录初始化
  208. 		char recvBuf[100];
  209. 		memset(recvBuf,0,sizeof(recvBuf));
  210. 		char buf[] = "服务器连接成功！欢迎登录... ...\n";
  211. 		ret = send(sockConn,buf,sizeof(buf),0);
  212. 		if(ret == SOCKET_ERROR)
  213. 		{
  214. 			cout << "Send data failed ... ..." <<endl;
  215. 			break;
  216. 		}
  217.  
  218. 		while(recvBuf != "bye" || buf != "bye")
  219. 		{
  220. 			memset(recvBuf,0,sizeof(recvBuf));
  221. 			//============== send() ==============
  222. 			char buf[100];
  223. 			memset(buf,0,sizeof(buf));
  224. 			cin >> buf;
  225. 			ret = send(sockConn,buf,sizeof(buf),0);
  226. 			if(ret == SOCKET_ERROR)
  227. 			{
  228. 				cout << "Send data failed ... ..." <<endl;
  229. 				break;
  230. 			}
  231.  
  232.  
  233. 			//============== recv() ==============
  234. 			ret = recv(sockConn,recvBuf,sizeof(recvBuf),0);
  235. 			cout << "########## receive data(" << ret << " byte) ##########" <<endl;
  236. 			cout << recvBuf <<endl;
  237. 			
  238. 		}
  239.  
  240. 		//关闭用于和客户端收发数据而建立的socket
  241. 		//Linux下一切皆文件，直接用文件操作函数close()关闭socket即可
  242. 		//============== closesocket() ==============
  243. 		closesocket(sockConn);
  244. 	}
  245. 	//关闭用于监听客户端连接请求的socket
  246. 	//============== closesocket() ==============
  247. 	closesocket(sockSrv);
  248. 	WSACleanup();
  249.  
  250. 	cout << "Good Bye!" << endl;
  251.  
  252. 	return 0;
  253. }
  254.  
  255. int main()
  256. {
  257.  
  258. /*老版读写阻塞
  259. Initialize();
  261. Start_Server();
  263. system("pause");
  265. */
  266.  
  267.  
  268.  
  269. 	//Winsock服务初始化、创建套接字
  270. 	cout << "请输入服务器监听端口：" << endl;
  271. 	int nPort;
  272. 	cin >> nPort;
  273. 	CServer oServer = CServer(nPort);
  274. 	oServer.Socket();
  275.  
  276. 	//绑定套接字
  277. 	oServer.Bind();
  278.  
  279. 	//监听套接字
  280. 	oServer.Listen();
  281.  
  282. 	//等待连接
  283. 	oServer.Accept();
  284.  
  285. 	//建立会话	
  286. 	oServer.CreateConversation();
  287.  
  288. 	/*Initialize();
  289. 	Start_Server();*/
  290. 	WaitForSingleObject(oServer.GetSendHandle(),INFINITE);
  291. 	WaitForSingleObject(oServer.GetReceiveHandle(),INFINITE);
  292. 	//system("pause");
  293.  
  294. 	return 0;
  295. }

客户端:

Client.h

  1. #include <stdio.h>
  2. #include <WinSock2.h>
  3. #include <iostream>
  4. #pragma comment(lib,"ws2_32.lib")
  5. using namespace std;
  6.  
  7. #define PORT 7777
  8.  
  9. DWORD WINAPI SendMessage(LPVOID LParam)
  10. {
  11. 	SOCKET* sockClient = (SOCKET*)LParam;
  12.  
  13. 	char sendbuf[2048];
  14. 	
  15. 	while(strcmp(sendbuf,"bye")!=0)
  16. 	{
  17. 		//========== send() ==========
  18. 		memset(sendbuf,0,sizeof(sendbuf));
  19. 		cin >> sendbuf;
  20. 		send(*sockClient,sendbuf,sizeof(sendbuf),0);
  21. 	}
  22. 	return NULL;
  23. }
  24. DWORD WINAPI ReceiveMessage(LPVOID LParam)
  25. {
  26. 	SOCKET* sockClient = (SOCKET*)LParam;
  27.  
  28. 	char receivebuf[2048];
  29. 	
  30. 	int ret = 0;
  31. 	while(strcmp(receivebuf,"bye")!=0)
  32. 	{
  33. 		//========== recv() ==========
  34. 		memset(receivebuf,0,sizeof(receivebuf));
  35. 		ret = recv(*sockClient,receivebuf,sizeof(receivebuf),0);
  36. 		if(ret >= 0)
  37. 		{
  38. 			//cout << "Receiving from the host " << ret << " bytes ... ..." <<endl;
  39. 			cout << receivebuf <<endl;
  40. 		}		
  41. 	}
  42. 	return NULL;
  43. }
  44.  
  45. class CClient
  46. {
  47. public:
  48. 	CClient(const char* ip = "127.0.0.1",int nPort = PORT);
  49. 	~CClient();
  50.  
  51. 	int Socket();
  52. 	int Connect();
  53. 	int CreateConversation();
  54. 	
  55. 	HANDLE GetSendHandle();
  56. 	HANDLE GetReceiveHandle();
  57.  
  58. 	int SetPort(int nPort);
  59. 	int GetPort();
  60.  
  61. 	int SetIP(char ip[]);
  62. 	const char* GetIP();
  63. 	
  64. protected:
  65. private:
  66. 	HANDLE m_hSendThread;
  67. 	HANDLE m_hReceiveThread;
  68. 	DWORD m_dSendThreadId;
  69. 	DWORD m_dReceiveThreadId;
  70. 	int m_nPort;
  71. 	const char* m_IP;
  72. 	SOCKET sockClient;
  73. 	SOCKADDR_IN m_sockAddr;
  74. };
  75.  
  76. //Winsock服务初始化
  77. int Initialize();
  78.  
  79. //建立、启动客户端
  80. int Start_Client();

Client.cpp

  1. #include "Client.h"
  2.  
  3.  
  4. CClient::CClient(const char* ip,int nPort)
  5. {
  6. 	m_IP = ip;
  7. 	m_nPort = nPort;
  8. 	m_hSendThread = NULL;
  9. 	m_hReceiveThread = NULL;
  10.  
  11. 	//初始化IP和port
  12. 	m_sockAddr.sin_family = AF_INET;
  13. 	m_sockAddr.sin_port = htons(m_nPort);//1024以上端口号
  14. 	m_sockAddr.sin_addr.S_un.S_addr = inet_addr(m_IP);
  15. }
  16.  
  17. CClient::~CClient()
  18. {
  19. 	m_nPort = 0;
  20. 	CloseHandle(m_hSendThread);
  21. 	CloseHandle(m_hReceiveThread);
  22. 	closesocket(sockClient);
  23. 	WSACleanup();
  24. }
  25.  
  26. int CClient::Socket()
  27. {
  28. 	WSADATA data;
  29. 	int ret = WSAStartup(MAKEWORD(2,2),&data);
  30. 	//Debug
  31. 	/*cout << "Initialization return " << ret << endl;*/
  32.  
  33. 	if(ret)
  34. 	{
  35. 		cout << "Socket initialization failed: " << WSAGetLastError() << "... ..." << endl;
  36. 		return -1;
  37. 	}
  38.  
  39. 	sockClient = socket(AF_INET,SOCK_STREAM,0);
  40. 	if (SOCKET_ERROR == sockClient)
  41. 	{
  42. 		cout << "Socket create failed: " << WSAGetLastError() << "... ..." << endl;
  43. 		return -2;
  44. 	}
  45. 	return ret;
  46. }
  47.  
  48. int CClient::Connect()
  49. {
  50. 	int ret = connect(sockClient,(sockaddr *)&m_sockAddr,sizeof(m_sockAddr));
  51. 	if(ret == INVALID_SOCKET)
  52. 	{
  53. 		cout << "Connect to the host(" << this->GetIP() << ":" << this->GetPort() << ")failed: " << WSAGetLastError() << "... ..." << endl;
  54. 		return -3;
  55. 	}
  56. 	else
  57. 	{
  58. 		cout << "Connect to the host(" << this->GetIP() << ":" << this->GetPort() << ")succeed! " << endl;
  59. 	}
  60. 	return ret;
  61. }
  62.  
  63. int CClient::CreateConversation()
  64. {
  65. 	m_hReceiveThread = CreateThread(NULL,0,ReceiveMessage,&sockClient,0,&m_dReceiveThreadId);
  66. 	m_hSendThread = CreateThread(NULL,0,SendMessage,&sockClient,0,&m_dSendThreadId);
  67. 	return NULL;
  68. }
  69.  
  70. HANDLE CClient::GetSendHandle()
  71. {
  72. 	return m_hSendThread;
  73. }
  74.  
  75. HANDLE CClient::GetReceiveHandle()
  76. {
  77. 	return m_hReceiveThread;
  78. }
  79.  
  80. int CClient::SetPort(int nPort)
  81. {
  82. 	m_nPort = nPort;
  83. 	m_sockAddr.sin_port = htons(m_nPort);
  84. 	return m_nPort;
  85. }
  86.  
  87. int CClient::GetPort()
  88. {
  89. 	return m_nPort;
  90. }
  91.  
  92. int CClient::SetIP(char ip[])
  93. {
  94. 	m_IP = ip;
  95. 	m_sockAddr.sin_addr.S_un.S_addr = inet_addr(m_IP);
  96. 	return 0;
  97. }
  98.  
  99. const char* CClient::GetIP()
  100. {
  101. 	return m_IP;
  102. }
  103.  
  104. int Start_Client()
  105. {
  106. 	DWORD thread_id = 0;
  107. 	HANDLE hThread = CreateThread(NULL,0,SendMessage,NULL,0,&thread_id);
  108. 	CloseHandle(hThread);
  109.  
  110.  
  111. 	int ret = 0;
  112. 	char buff[2048];
  113. 	memset(buff,0,sizeof(buff));
  114.  
  115. 	//初始化IP和port
  116. 	SOCKADDR_IN addrSrv;
  117. 	addrSrv.sin_family = AF_INET;
  118. 	addrSrv.sin_port = htons(PORT);//1024以上端口号
  119. 	addrSrv.sin_addr.S_un.S_addr = inet_addr("127.0.0.1");
  120.  
  121. 	//========== socket() ==========
  122. 	SOCKET sockClient = socket(AF_INET,SOCK_STREAM,0);
  123. 	if (SOCKET_ERROR == sockClient)
  124. 	{
  125. 		cout << "Socket create failed: " << WSAGetLastError() << "... ..." << endl;
  126. 		return -2;
  127. 	}
  128. 	//========== connect() ==========
  129. 	ret = connect(sockClient,(sockaddr *)&addrSrv,sizeof(addrSrv));
  130. 	if(ret == INVALID_SOCKET)
  131. 	{
  132. 		cout << "Connect to the host failed: " << WSAGetLastError() << "... ..." << endl;
  133. 		return -3;
  134. 	}
  135. 	else
  136. 	{
  137. 		char buf[2048];
  138. 		memset(buf,0,sizeof(buf));
  139. 		while(buff != "bye" || buf != "bye")
  140. 		{
  141. 			memset(buf,0,sizeof(buf));
  142. 			memset(buff,0,sizeof(buff));
  143. 			//========== recv() ==========
  144. 			ret = recv(sockClient,buff,sizeof(buff),0);
  145. 			cout << "Receiving from the host " << ret << " bytes ... ..." <<endl;
  146. 			cout << buff <<endl;
  147. 			//========== send() ==========
  148. 			
  149. 			cin >> buf;
  150. 			send(sockClient,buf,sizeof(buf),0);
  151. 		}
  152. 	}
  153.  
  154. 	//关闭用于监听客户端连接请求的socket
  155. 	//============== closesocket() ==============
  156. 	closesocket(sockClient);
  157. 	WSACleanup();
  158.  
  159. 	return 0;
  160. }
  161.  
  162. int main()
  163. {
  164.  
  165. /*老板读写阻塞
  166. Initialize();
  168. Start_Client();
  169. */
  170.  
  171.  
  172. 	//Winsock服务初始化、创建套接字
  173. 	char ip[24];
  174. 	cout << "请输入远程服务器IP：" << endl;
  175. 	cin >> ip;
  176.  
  177. 	int nPort;
  178. 	cout << "请输入远程服务器端口：" << endl;
  179. 	cin >> nPort;
  180. 	CClient oClient = CClient(ip,nPort);
  181. 	oClient.Socket();
  182.  
  183. 	//建立连接
  184. 	while(oClient.Connect() != 0)
  185. 	{
  186. 		//连接失败重新建立连接
  187. 		cout << "连接失败，请确认IP地址及端口" << endl;
  188. 		cout << "IP地址：" << ip << "是否正确？" << endl;
  189.  
  190. 		char answer[8];
  191. 		memset(answer,0,sizeof(answer));
  192. 		while(strcmp(answer,"Y") != NULL && strcmp(answer,"N") != NULL && strcmp(answer,"y") != NULL && strcmp(answer,"n") != NULL)
  193. 		{
  194. 			memset(answer,0,sizeof(answer));
  195. 			cout << "Y/N?" << endl;
  196. 			cin >> answer;
  197. 			if(strcmp(answer,"Y") == NULL || strcmp(answer,"y") == NULL)
  198. 			{
  199. 				break;
  200. 			}
  201. 			else if(strcmp(answer,"N") == NULL || strcmp(answer,"n") == NULL)
  202. 			{
  203. 				cout << "请输入正确的IP:" << endl;
  204. 				cin >> ip;
  205. 				oClient.SetIP(ip);
  206. 			}	
  207. 		}
  208.  
  209. 		cout << "远程端口：" << nPort << "是否正确？" << endl;
  210. 		memset(answer,0,sizeof(answer));
  211. 		while(strcmp(answer,"Y") != 0 && strcmp(answer,"N") != 0 && strcmp(answer,"y") != 0 && strcmp(answer,"n") != 0)
  212. 		{
  213. 			memset(answer,0,sizeof(answer));
  214. 			cout << "Y/N?" << endl;
  215. 			cin >> answer;
  216. 			if(strcmp(answer,"Y") == NULL || strcmp(answer,"y") == NULL)
  217. 			{
  218. 				break;
  219. 			}
  220. 			else if(strcmp(answer,"N") == NULL || strcmp(answer,"n") == NULL)
  221. 			{
  222. 				cout << "请输入正确的端口:" << endl;
  223. 				cin >> nPort;
  224. 				oClient.SetPort(nPort);
  225. 			}
  226. 		}
  227. 	}
  228.  
  229. 	//建立会话	
  230. 	oClient.CreateConversation();
  231.  
  232. 	WaitForSingleObject(oClient.GetSendHandle(),INFINITE);
  233. 	WaitForSingleObject(oClient.GetReceiveHandle(),INFINITE);
  234.  
  235. 	//system("pause");
  236.  
  237. 	return 0;
  238. }

本地IP测试连接成功，但通过公网IP连不上，没有开端口映射，可以考虑在路由器上设置，以下采用nat123创建了内网穿透。

此方式建的p2p转发需要在客户端机子上再开一个访问者

域名和端口填上以后添加访问，等连接建立上就可以用客户端和服务端建立通讯了（因为是用别的公网服务器转发的，因此IP并非本机外网IP而是用上图的转发IP:127.15.83.54）

 

 

 

 

 

声明：本文内容由网友自发贡献，转载请注明出处：【wpsshop】
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号