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

windows网络编程实验4采用C++进行TCP通信之多线程文件传输

作者：我家自动化 | 2024-03-01 08:00:29

赞

踩

windows网络编程实验4采用C++进行TCP通信之多线程文件传输

实验要求：使服务器与多个客户端进行通信，同时接收多个客户端上传的文件。

服务端代码：

  1. #include"iostream"
  2. #include"afxmt.h"
  3. #include"process.h"
  4. #include"winsock2.h"
  5. #include"fstream"
  6. #include"WS2tcpip.h"
  7. #include"direct.h"
  8.  
  9.  
  10. #define PORT 65432
  11. #pragma comment(lib,"ws2_32.lib")
  12.  
  13. using namespace std;
  14. struct fileMessage
  15. {
  16. 	char fileName[256];
  17. 	long int fileSize;
  18. };
  19.  
  20.  
  21. /*主程序和线程函数共用的全局变量定义*/
  22. char fname[128] = { 0 };			//发送给客户端的无路径信息的文件名
  23. ifstream inFile;					//定义文件的输入流
  24. CMutex Section;						//创建互斥对象
  25. void rdFile(void* par);			//发送文件的线程函数声明
  26.  
  27. /*主函数*/
  28.  
  29. int main()
  30. {
  31. 	SOCKET sock_server;						//定义监听套接字
  32. 	struct sockaddr_in addr;
  33. 	struct sockaddr_in client_addr;	//存放本地地址和客户地址的变量
  34. 	SOCKET newsock;							//储存accept（）返回的套接字描述符
  35. 	/*初始化winsock DLL*/
  36. 	WSADATA wsaData;
  37. 	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
  38. 	{
  39. 		cout << "加载winSock动态链接库失败！\n";
  40. 		return 0;
  41. 	}
  42.  
  43. 	/*创建监听套接字*/
  44. 	if ((sock_server = socket(AF_INET, SOCK_STREAM, 0)) < 0)
  45. 	{
  46. 		cout << "创建套接字失败！\n";
  47. 		WSACleanup();
  48. 		return 0;
  49. 	}
  50.  
  51. 	/*绑定IP地址与端口*/
  52. 	memset((void*)&addr, 0, sizeof(addr));
  53. 	addr.sin_family = AF_INET;
  54. 	addr.sin_port = htons(65432);
  55. 	addr.sin_addr.s_addr = htonl(INADDR_ANY);
  56. 	if (bind(sock_server, (struct sockaddr*)&addr, sizeof(addr)) != 0)
  57. 	{
  58. 		cout << "绑定失败！\n";
  59. 		closesocket(sock_server);
  60. 		WSACleanup();
  61. 		return 0;
  62. 	}
  63. 	if (listen(sock_server, 5) != 0)
  64. 	{
  65. 		cout << "listen函数调用失败!\n";
  66. 		closesocket(sock_server);
  67. 		WSACleanup();
  68. 		return 0;
  69. 	}
  70. 	else
  71. 	{
  72. 		cout << "listenning.....\n";
  73. 	}
  74.  
  75. 	/*接收客户连接请求*/
  76. 	int addr_len = sizeof(struct sockaddr_in);
  77. 	while (true)
  78. 	{
  79. 		newsock = accept(sock_server, (LPSOCKADDR)&client_addr, &addr_len);
  80. 		if (newsock != INVALID_SOCKET)
  81. 		{
  82. 			cout << "一个客户连接成功！" << endl;
  83. 			_beginthread(rdFile, 0, (LPVOID)newsock);
  84.  
  85. 		}
  86. 		else
  87. 		{
  88. 			break;
  89. 		}
  90.  
  91. 	}
  92.  
  93. 	closesocket(newsock);
  94. 	closesocket(sock_server);
  95. 	WSACleanup();
  96. 	return 0;
  97.  
  98. }
  99.  
  100. void rdFile(void* par)
  101. {
  102. 	/*定义文件传输所需变量*/
  103. 	struct fileMessage fileMsg;
  104. 	SOCKET sock = (SOCKET)par;
  105. 	long int filelen;
  106. 	char filename[500] = "C:\\Users\\86152\\source\\repos\\textfile"; //指定文件的保存目录
  107. 	char ok[3] = "OK";
  108. 	char fileBuffer[1000];		//接收文件数据的缓冲区
  109. 	_mkdir(filename);		//_mkdir()用于创建文件夹，其声明包含在direct.h中
  110.  
  111. 	/*接收文件名及文件长度信息*/
  112. 	if ((filelen = recv(sock, (char*)&fileMsg, sizeof(fileMsg), 0)) <= 0)
  113. 	{
  114. 		cout << "未接收到文件名及文件长度！\n";
  115. 		closesocket(sock);
  116. 		WSACleanup();
  117. 		return;
  118. 	}
  119.  
  120. 	filelen = ntohl(fileMsg.fileSize);
  121. 	strcat_s(filename, fileMsg.fileName);
  122. 	ofstream outFile(filename, ios::out | ios::binary);		//创建文件对象
  123. 	if (!outFile.is_open())
  124. 	{
  125. 		cout << "Cannot open" << filename << endl;
  126. 		closesocket(sock);
  127. 		WSACleanup();
  128. 		return;										//文件打开失败则退出
  129. 	}
  130. 	send(sock, ok, sizeof(ok), 0);				//发送接收文件数据的确认信息
  131. 	int size = 0;
  132. 	do
  133. 	{
  134. 		size = recv(sock, fileBuffer, sizeof(fileBuffer), 0);
  135. 		if (size <= 0)break;
  136. 		outFile.write(fileBuffer, size);
  137. 		filelen -= size;
  138. 	} while (filelen > 0);
  139.  
  140. 	if (filelen == 0)
  141. 	{
  142. 		cout << "Transfer finished!\n";
  143. 	}
  144. 	else
  145. 	{
  146. 		cout << "Transfer Failed!\n";
  147. 	}
  148. 	outFile.close();
  149. 	closesocket(sock);
  150.  
  151. }

客户端代码：

  1. #include<iostream>
  2. #include"fstream"
  3. #include"winsock2.h"
  4. #include"WS2tcpip.h"
  5. #include"direct.h"
  6. #pragma comment(lib,"ws2_32.lib")
  7.  
  8. using namespace std;
  9. struct fileMessage			//定义存储文件信息的结构体
  10. {
  11. 	char fileName[256];
  12. 	long int fileSize;
  13.  
  14. };
  15.  
  16. int main()
  17. {
  18. 	/*定义网络连接的相关变量*/
  19. 	int sock_client;					//定义套接字
  20. 	struct sockaddr_in server_addr;			//用于存放服务器地址的变量
  21. 	int addr_len = sizeof(struct sockaddr_in);		//地址长度
  22. 	/*初始化winsock DLL*/
  23. 	WSADATA wsaData;
  24. 	if (WSAStartup(MAKEWORD(2, 2), &wsaData) != 0)
  25. 	{
  26. 		cout << "加载winsock动态链接库失败！\n";
  27. 		return 0;
  28. 	}
  29.  
  30. 	char filename[500];						//用于存储要传输的文件的文件路径
  31. 	cout << "输入要输入的文件路径：";
  32. 	cin.getline(filename, 500);
  33.  
  34. 	/*创建套接字*/
  35. 	if ((sock_client = socket(AF_INET, SOCK_STREAM, 0)) < 0)
  36. 	{
  37. 		cout << "创建套接字失败！\n";
  38. 		WSACleanup();
  39. 		return 0;
  40. 	}
  41.  
  42. 	/*输入服务器IP地址及端口号*/
  43. 	char IP[20];
  44. 	//	unsigned short port;
  45. 	in_addr a;
  46. 	cout << "请输入服务器IP地址：";
  47. 	cin >> IP;
  48. 	inet_pton(AF_INET, IP, &a);
  49. 	memset((void*)&server_addr, 0, addr_len);
  50. 	server_addr.sin_family = AF_INET;
  51. 	server_addr.sin_port = htons(65432);
  52. 	server_addr.sin_addr.s_addr = a.S_un.S_addr;
  53. 	if (connect(sock_client, (struct sockaddr*)&server_addr, addr_len) != 0)
  54. 	{
  55. 		cout << "连接失败！\n";
  56. 		closesocket(sock_client);
  57. 		WSACleanup();
  58. 		return 0;
  59. 	}
  60.  
  61.  
  62.  
  63. 	char OK[3], fileBuffer[1000];						//定义接收“OK”的缓冲区和发送缓冲区
  64. 	struct fileMessage fileMsg;							//定义保存文件名及文件长度的结构变量
  65. 	ifstream inFile(filename, ios::in | ios::binary);	//定义文件对象并打开文件
  66. 	if (!inFile.is_open())
  67. 	{
  68. 		cout << "CAnnot open" << filename << endl;
  69. 		closesocket(sock_client);
  70. 		WSACleanup();
  71. 		return 0;										//文件打开失败则退出
  72. 	}
  73.  
  74. 	/*从文件路径中提取文件名保存到结构变量fileMsg中*/
  75. 	unsigned int size = strlen(filename);
  76. 	while (filename[size] != '\\' && size > 0)size--;
  77. 	strcpy_s(fileMsg.fileName, filename + size);
  78.  
  79. 	/*获取文件长度并存入结构变量fileMsg中*/
  80. 	inFile.seekg(0, ios::end);							//将文件的位置指针移到文件末尾
  81. 	size = inFile.tellg();								//获取当前文件位置指针值
  82. 	fileMsg.fileSize = htonl(size);						//将文件长度存入结构变量fileMeg
  83. 	send(sock_client, (char*)&fileMsg, sizeof(fileMsg), 0);//发送fileMeg
  84. 	if (recv(sock_client, OK, sizeof(OK), 0) <= 0)				//接收对方发来的OK信息
  85. 	{
  86. 		cout << "接收OK失败，程序退出！\n";
  87. 		closesocket(sock_client);
  88. 		WSACleanup();
  89. 		return 0;
  90.  
  91. 	}
  92. 	if (strcmp(OK, "OK") == 0)							//如果对方已准备好接收则发送文件内容
  93. 	{
  94. 		inFile.seekg(0, ios::beg);					//将文件的位置指针返回到文件头
  95. 		while (!inFile.eof())
  96. 		{
  97. 			inFile.read(fileBuffer, sizeof(fileBuffer));
  98. 			size = inFile.gcount();					//读取实际读取的字节数
  99. 			send(sock_client, fileBuffer, size, 0);
  100.  
  101. 		}
  102. 		cout << "File Transfer Finished!\n";
  103. 		inFile.close();								//关闭文件
  104. 	}
  105. 	else
  106. 	{
  107. 		cout << "对方无法接收文件！";
  108. 	}
  109. 	closesocket(sock_client);
  110. 	WSACleanup();
  111. 	return 0;
  112.  
  113.  
  114. }

实现效果：

 

实验要求：服务器同时向多个客户端发送文件

  1. #include<iostream>
  2. #include"fstream"
  3. #include"winsock2.h"
  4. #pragma comment(lib,"ws2_32.lib")
  5.  
  6. using namespace std;
  7. struct fileMessage			//定义存储文件信息的结构体
  8. {
  9. 	char fileName[256];
  10. 	long int fileSize;
  11.  
  12. };
  13.  
  14. int main()
  15. {
  16. 	SOCKET sock_server;						//定义监听套接字
  17. 	struct sockaddr_in addr;
  18. 	struct sockaddr_in client_addr;	//存放本地地址和客户地址的变量
  19. 	SOCKET newsock;							//储存accept（）返回的套接字描述符
  20. 	/*初始化winsock DLL*/
  21. 	WSADATA wsaData;
  22. 	if (WSAStartup(MAKEWORD(2,2),&wsaData)!=0)
  23. 	{
  24. 		cout << "加载winSock动态链接库失败！\n";
  25. 		return 0;
  26. 	}
  27.  
  28. 	char filename[500];						//用于存储要传输的文件的文件路径
  29. 	cout << "输入要输入的文件路径：";
  30. 	cin.getline(filename, 500);
  31.  
  32.  
  33. 	/*创建监听套接字*/
  34. 	if ((sock_server=socket(AF_INET,SOCK_STREAM,0))<0)
  35. 	{
  36. 		cout << "创建套接字失败！\n";
  37. 		WSACleanup();
  38. 		return 0;
  39. 	}
  40.  
  41. 	/*绑定IP地址与端口*/
  42. 	memset((void*)&addr, 0, sizeof(addr));
  43. 	addr.sin_family = AF_INET;
  44. 	addr.sin_port = htons(65432);
  45. 	addr.sin_addr.s_addr = htonl(INADDR_ANY);
  46. 	if (bind(sock_server,(struct sockaddr*)&addr,sizeof(addr))!=0)
  47. 	{
  48. 		cout << "绑定失败！\n";
  49. 		closesocket(sock_server);
  50. 		WSACleanup();
  51. 		return 0;
  52. 	}
  53. 	if (listen(sock_server,5)!=0)
  54. 	{
  55. 		cout << "listen函数调用失败!\n";
  56. 		closesocket(sock_server);
  57. 		WSACleanup();
  58. 		return 0;
  59. 	}
  60. 	else
  61. 	{
  62. 		cout << "listenning.....\n";
  63. 	}
  64.  
  65. 	/*接收客户连接请求*/
  66. 	int addr_len = sizeof(struct sockaddr_in);
  67. 	if ((newsock=accept(sock_server,(struct sockaddr*)&client_addr,&addr_len))==INVALID_SOCKET)
  68. 	{
  69. 		cout << "accept函数调用失败！\n";
  70. 		closesocket(sock_server);
  71. 		WSACleanup();
  72. 		return 0;
  73. 	}
  74. 	cout << "客户连接成功！" << endl;
  75. 	char OK[3], fileBuffer[1000];						//定义接收“OK”的缓冲区和发送缓冲区
  76. 	struct fileMessage fileMsg;							//定义保存文件名及文件长度的结构变量
  77. 	ifstream inFile(filename, ios::in | ios::binary);	//定义文件对象并打开文件
  78. 	if (!inFile.is_open())
  79. 	{
  80. 		cout << "CAnnot open" << filename << endl;
  81. 		closesocket(newsock);
  82. 		closesocket(sock_server);
  83. 		WSACleanup();
  84. 		return 0;										//文件打开失败则退出
  85. 	}
  86.  
  87. 	/*从文件路径中提取文件名保存到结构变量fileMsg中*/
  88. 	unsigned int size = strlen(filename);
  89. 	while (filename[size] !='\\' && size> 0)size--;
  90. 	strcpy_s(fileMsg.fileName, filename + size);
  91.  
  92. 	/*获取文件长度并存入结构变量fileMsg中*/
  93. 	inFile.seekg(0, ios::end);							//将文件的位置指针移到文件末尾
  94. 	size = inFile.tellg();								//获取当前文件位置指针值
  95. 	fileMsg.fileSize = htonl(size);						//将文件长度存入结构变量fileMeg
  96. 	send(newsock, (char*)&fileMsg, sizeof(fileMsg), 0);//发送fileMeg
  97. 	if (recv(newsock,OK,sizeof(OK),0)<=0)				//接收对方发来的OK信息
  98. 	{
  99. 		cout << "接收OK失败，程序退出！\n";
  100. 		closesocket(newsock);
  101. 		closesocket(sock_server);
  102. 		WSACleanup();
  103. 		return 0;
  104.  
  105. 	}
  106. 	if (strcmp(OK,"OK")==0)							//如果对方已准备好接收则发送文件内容
  107. 	{
  108. 		inFile.seekg(0, ios::beg);					//将文件的位置指针返回到文件头
  109. 		while (!inFile.eof())
  110. 		{
  111. 			inFile.read(fileBuffer, sizeof(fileBuffer));
  112. 			size = inFile.gcount();					//读取实际读取的字节数
  113. 			send(newsock, fileBuffer, size, 0);
  114.  
  115. 		}
  116. 		cout << "File Transfer Finished!\n";
  117. 		inFile.close();								//关闭文件
  118. 	}
  119. 	else
  120. 	{
  121. 		cout << "对方无法接收文件！";
  122. 	}
  123. 	closesocket(newsock);
  124. 	closesocket(sock_server);
  125. 	WSACleanup();
  126. 	return 0;
  127. }

 客户端代码：

  1. #include<iostream>
  2. #include"fstream"
  3. #include"winsock2.h"
  4. #include"WS2tcpip.h"
  5. #include"direct.h"
  6. #pragma comment(lib,"ws2_32.lib")
  7.  
  8. using namespace std;
  9. struct fileMessage
  10. {
  11. 	char fileName[256];
  12. 	long int fileSize;
  13. };
  14.  
  15. int main()
  16. {
  17. 	/*定义网络连接的相关变量*/
  18. 	int sock_client;					//定义套接字
  19. 	struct sockaddr_in server_addr;			//用于存放服务器地址的变量
  20. 	int addr_len = sizeof(struct sockaddr_in);		//地址长度
  21. 	/*初始化winsock DLL*/
  22. 	WSADATA wsaData;
  23. 	if (WSAStartup(MAKEWORD(2,2),&wsaData)!=0)
  24. 	{
  25. 		cout << "加载winsock动态链接库失败！\n";
  26. 		return 0;
  27. 	}
  28.  
  29. 	/*创建套接字*/
  30. 	if ((sock_client=socket(AF_INET,SOCK_STREAM,0))<0)
  31. 	{
  32. 		cout << "创建套接字失败！\n";
  33. 		WSACleanup();
  34. 		return 0;
  35. 	}
  36.  
  37. 	/*输入服务器IP地址及端口号*/
  38. 	char IP[20];
  39. //	unsigned short port;
  40. 	in_addr a;
  41. 	cout << "请输入服务器IP地址：";
  42. 	cin >> IP;
  43. 	inet_pton(AF_INET, IP, &a);
  44. 	memset((void*)&server_addr, 0, addr_len);
  45. 	server_addr.sin_family = AF_INET;
  46. 	server_addr.sin_port = htons(65432);
  47. 	server_addr.sin_addr.s_addr = a.S_un.S_addr;
  48. 	if (connect(sock_client, (struct sockaddr*)&server_addr, addr_len) != 0)
  49. 	{
  50. 		cout << "连接失败！\n";
  51. 		closesocket(sock_client);
  52. 		WSACleanup();
  53. 		return 0;
  54. 	}
  55.  
  56. 	/*定义文件传输所需变量*/
  57. 	struct fileMessage fileMsg;
  58. 	long int filelen;
  59. 	char filename[500] = "D:\\BaiduNetdiskDownload\\visualstudio\\vsfile\\transferfileclient"; //指定文件的保存目录
  60. 	char ok[3] = "OK";
  61. 	char fileBuffer[1000];		//接收文件数据的缓冲区
  62. 	_mkdir(filename);		//_mkdir()用于创建文件夹，其声明包含在direct.h中
  63.  
  64. 	/*接收文件名及文件长度信息*/
  65. 	if ((filelen=recv(sock_client,(char*)&fileMsg,sizeof(fileMsg),0))<=0)
  66. 	{
  67. 		cout << "未接收到文件名及文件长度！\n";
  68. 		closesocket(sock_client);
  69. 		WSACleanup();
  70. 		return 0;
  71. 	}
  72.  
  73. 	filelen = ntohl(fileMsg.fileSize);
  74. 	strcat_s(filename, fileMsg.fileName);
  75. 	ofstream outFile(filename, ios::out | ios::binary);		//创建文件对象
  76. 	if (!outFile.is_open())
  77. 	{
  78. 		cout << "Cannot open" << filename << endl;
  79. 		closesocket(sock_client);
  80. 		WSACleanup();
  81. 		return 0;										//文件打开失败则退出
  82. 	}
  83. 	send(sock_client, ok, sizeof(ok), 0);				//发送接收文件数据的确认信息
  84. 	int size = 0;
  85. 	do
  86. 	{
  87. 		size = recv(sock_client, fileBuffer, sizeof(fileBuffer), 0);
  88. 		if (size <= 0)break;
  89. 		outFile.write(fileBuffer, size);
  90. 		filelen -= size;
  91. 	} while (filelen>0);
  92.  
  93. 	if (filelen==0)
  94. 	{
  95. 		cout << "Transfer finished!\n";
  96. 	}
  97. 	else
  98. 	{
  99. 		cout << "Transfer Failed!\n";
  100. 	}
  101. 	outFile.close();
  102. 	closesocket(sock_client);
  103. 	WSACleanup();
  104. 	return 0;
  105.  
  106. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/172151?site
推荐阅读
相关标签

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

  

闽ICP备14008679号