阅读量:0
recvfrom() 是一个用于接收来自指定套接字上的数据报的函数，通常用于无连接的UDP协议
以下是一个简单的示例，展示了如何在多线程环境中使用 recvfrom() 函数：
#include<iostream> #include<thread> #include <sys/socket.h> #include <arpa/inet.h> #include <unistd.h> #include <cstring> const int BUFFER_SIZE = 1024; const int PORT = 8080; void receive_data(int sockfd) { char buffer[BUFFER_SIZE]; struct sockaddr_in client_addr; socklen_t client_addr_size = sizeof(client_addr); while (true) { ssize_t received = recvfrom(sockfd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&client_addr, &client_addr_size); if (received > 0) { std::cout << "Received message from client: " << inet_ntoa(client_addr.sin_addr) << ":" << ntohs(client_addr.sin_port)<< std::endl; std::cout << "Message: "<< buffer<< std::endl; } else { std::cerr << "Error receiving data"<< std::endl; break; } } } int main() { int sockfd = socket(AF_INET, SOCK_DGRAM, 0); if (sockfd == -1) { std::cerr << "Error creating socket"<< std::endl; return 1; } struct sockaddr_in server_addr; memset(&server_addr, 0, sizeof(server_addr)); server_addr.sin_family = AF_INET; server_addr.sin_addr.s_addr = htonl(INADDR_ANY); server_addr.sin_port = htons(PORT); if (bind(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) { std::cerr << "Error binding socket"<< std::endl; close(sockfd); return 1; } // 创建一个线程来处理接收到的数据报 std::thread receiver_thread(receive_data, sockfd); // 主线程可以执行其他任务，例如发送数据报或等待用户输入 // ... // 等待接收线程完成 receiver_thread.join(); close(sockfd); return 0; } 这个示例中，我们创建了一个线程来处理接收到的数据报。主线程可以执行其他任务，例如发送数据报或等待用户输入。当主线程完成其任务时，它会等待接收线程完成，然后关闭套接字并退出程序。
请注意，这个示例仅用于演示目的，实际应用中可能需要根据需求进行更复杂的错误处理和资源管理。
