阅读量:0
在C++中使用recv函数接收数据包时,需要注意数据包可能会被分成多个部分发送,因此需要对数据进行缓存和拼接,直到接收到完整的数据包为止。以下是一个示例代码,实现数据包的完整接收:
#include <iostream> #include <cstring> #include <sys/types.h> #include <sys/socket.h> #define BUFFER_SIZE 1024 int main() { int server_fd, new_socket; struct sockaddr_in address; int addrlen = sizeof(address); char buffer[BUFFER_SIZE] = {0}; // 创建socket if ((server_fd = socket(AF_INET, SOCK_STREAM, 0)) == 0) { perror("socket failed"); return -1; } // 绑定地址和端口 address.sin_family = AF_INET; address.sin_addr.s_addr = INADDR_ANY; address.sin_port = htons(8888); if (bind(server_fd, (struct sockaddr *)&address, sizeof(address)) < 0) { perror("bind failed"); return -1; } // 监听连接 if (listen(server_fd, 3) < 0) { perror("listen failed"); return -1; } // 接受连接 if ((new_socket = accept(server_fd, (struct sockaddr *)&address, (socklen_t*)&addrlen)) < 0) { perror("accept failed"); return -1; } // 接收数据包 std::string data; int bytes_received; do { bytes_received = recv(new_socket, buffer, BUFFER_SIZE, 0); if (bytes_received < 0) { perror("recv failed"); return -1; } data.append(buffer, bytes_received); } while (bytes_received > 0); // 处理接收到的完整数据包 std::cout << "Received data: " << data << std::endl; return 0; }
在上面的代码中,创建了一个服务器并监听连接,接收到新的连接后,使用recv函数接收数据包,直到接收到的字节数为0为止。接收到的数据会不断追加到一个字符串变量中,直到接收到完整的数据包。最后输出完整的接收到的数据包。