VC++ 多线程读取多个文件并上传到服务器的示例代码

源码资源网

VC++ 多线程读取多个文件并上传到服务器的示例代码
一个使用 VC++ 多线程读取多个文件并上传到服务器的示例代码。我们将使用 C++ 的线程库来实现多线程，并使用 WinSock 库进行网络上传。
### 步骤概述
1. **打开多个文件**：使用文件流打开需要上传的多个文件。
2. **多线程处理**：为每个文件启动一个线程，负责读取文件并上传。
3. **上传到服务器**：每个线程读取完文件后，将数据上传到服务器。

1. ### 示例代码
   
2. #include <iostream>
   
3. #include <fstream>
   
4. #include <thread>
   
5. #include <vector>
   
6. #include <winsock2.h>
   
7. #pragma comment(lib, "ws2_32.lib")
   
8. // 定义上传函数
   
9. void uploadFile(const std::string& filePath, const std::string& serverIP, int port) {
   
10.     // 创建套接字
    
11.     SOCKET sock = socket(AF_INET, SOCK_STREAM, 0);
    
12.     if (sock == INVALID_SOCKET) {
    
13.         std::cerr << "Socket creation failed!" << std::endl;
    
14.         return;
    
15.     }
    
16.      // 设置服务器地址
    
17.     sockaddr_in serverAddr;
    
18.     serverAddr.sin_family = AF_INET;
    
19.     serverAddr.sin_port = htons(port);
    
20.     inet_pton(AF_INET, serverIP.c_str(), &serverAddr.sin_addr);
    
21.      // 连接到服务器
    
22.     if (connect(sock, (sockaddr*)&serverAddr, sizeof(serverAddr)) == SOCKET_ERROR) {
    
23.         std::cerr << "Connection to server failed!" << std::endl;
    
24.         closesocket(sock);
    
25.         return;
    
26.     }
    
27.      // 打开文件
    
28.     std::ifstream file(filePath, std::ios::binary);
    
29.     if (!file) {
    
30.         std::cerr << "Failed to open file: " << filePath << std::endl;
    
31.         closesocket(sock);
    
32.         return;
    
33.     }
    
34.      // 读取文件内容并上传
    
35.     std::vector<char> buffer((std::istreambuf_iterator<char>(file)), std::istreambuf_iterator<char>());
    
36.     send(sock, buffer.data(), buffer.size(), 0);
    
37.      // 关闭套接字
    
38.     closesocket(sock);
    
39.     std::cout << "File uploaded: " << filePath << std::endl;
    
40. }
    
41. // 多线程读取多个文件并上传
    
42. int main() {
    
43.     const std::string serverIP = "127.0.0.1"; // 服务器IP
    
44.     const int port = 8080; // 服务器端口
    
45.      // 要上传的文件列表
    
46.     std::vector<std::string> filesToUpload = {
    
47.         "path/to/your/file1.txt",
    
48.         "path/to/your/file2.txt",
    
49.         "path/to/your/file3.txt"
    
50.     };
    
51.      // 启动多个线程读取文件并上传
    
52.     std::vector<std::thread> threads;
    
53.     for (const auto& filePath : filesToUpload) {
    
54.         threads.emplace_back(uploadFile, filePath, serverIP, port);
    
55.     }
    
56.      // 等待所有线程完成
    
57.     for (auto& t : threads) {
    
58.         t.join();
    
59.     }
    
60.      std::cout << "All files have been uploaded!" << std::endl;
    
61.     return 0;
    
62. }

复制代码

### 代码说明
1. **uploadFile**：该函数负责打开指定文件，读取文件内容并上传到指定的服务器。
2. **main**：在主函数中，定义要上传的文件列表，并为每个文件启动一个线程，调用  `uploadFile`  函数进行上传。
3. **多线程处理**：使用  `std::thread`  来处理每个文件的上传，确保能够同时处理多个文件。
### 注意事项
- 确保在使用 WinSock 之前调用  `WSAStartup` ，并在程序结束时调用  `WSACleanup` 。
- 处理网络错误和异常情况，以确保程序的健壮性。
- 根据实际需求调整要上传的文件列表和服务器信息。
这个示例提供了一个基本的多线程文件上传的实现，你可以根据具体需求进行扩展和优化。