C++ recvfrom函数在多线程环境中的应用

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;}

这个示例中，我们创建了一个线程来处理接收到的数据报。主线程可以执行其他任务，例如发送数据报或等待用户输入。当主线程完成其任务时，它会等待接收线程完成，然后关闭套接字并退出程序。

请注意，这个示例仅用于演示目的，实际应用中可能需要根据需求进行更复杂的错误处理和资源管理。