通过C++实现多线程并发服务器（UDP情况）

我使用“创建新线程方法”来处理新客户端并遇到了UDP中的问题。首先我使用主线程创建一个TCP线程来处理新的accept（）并创建一个UDP线程来处理新的recvfrom（）。（TCP案例都OK）一旦第一次recvfrom（）回调，我尝试将客户端传递给新的UDP线程，并保持当前的一个来处理下一个新的UDP客户端它应该是通过传递地址和new-创建数据报套接字到新线程继续执行recvfrom（），对不对？通过C++实现多线程并发服务器（UDP情况）

在实验过程中，我发现OLD UDP线程不断接收来自客户端的数据报，而新线程刚刚做while循环和recvfrom（）变为非阻塞方式并返回-1。

因此，我的代码的问题是什么....谢谢〜我是否理解错误的东西..？

PassToUDPThread是将typeof结构我传递给新的线程数据所做的：

typedef struct { 
    sockaddr_in ReceiverSocket; 
    SOCKET sendSocket; 
    char* recvbuf; 
    long packet_size; 

}PassToUDPThread;

这里是我的第一个UDP线程函数的代码（处理第一recvfrom的（）只）：

sockaddr_in *ReceiverSocket = new sockaddr_in; 

ReceiverSocket->sin_family = AF_INET; 
if (strcmp(recv_hostname, "INADDR_ANY") != 0) 
inet_pton(AF_INET, ip_addr_char, &ReceiverSocket->sin_addr.s_addr); 
else ReceiverSocket->sin_addr.s_addr = INADDR_ANY; 
ReceiverSocket->sin_port = htons((u_short)recv_port); 

//*** Create the socket 
SOCKET s; 

s = socket(AF_INET, SOCK_DGRAM, 0); 
printf("Receiver: Socket Created - UDP connection\n"); 
bind(s, (struct sockaddr *)ReceiverSocket, sizeof(struct sockaddr_in)); 

do 
{ 
    int fromlen = (int)sizeof(struct sockaddr_in); 
    retVal = recvfrom(s, recvbuf, packet_size, 0, (struct sockaddr*)ReceiverSocket, &fromlen); 
    std::cout << "UDP recv by MAIN "<<std::endl; 
    if (retVal == SOCKET_ERROR) { 
     std::cout << "UDP Socket error : " + WSAGetLastError()<<std::endl; 
     return 0; 
    } 
    else { 
     SOCKET sendSocket = socket(AF_INET, SOCK_DGRAM, 0); 
     PassToUDPThread _p; 
     PassToUDPThread *p = &_p; 
     p->sendSocket = sendSocket; 
     p->ReceiverSocket = *ReceiverSocket; 
     p->recvbuf = recvbuf; 
     p->packet_size = packet_size; 

     thrd_t UDPthread; 
     if (thrd_create(&UDPthread, ThreadUDPReceiver, (void*)p) == thrd_success) { 
      std::cout<<"success create new UDP thread"<<std::endl; 
          } 




    } 
    } while (retVal>0); 
    closesocket(s); 
    UDPReceiver(arg); 
    return 1; 
}

下面是对新创建的UDP线程函数的代码：

int ThreadUDPReceiver(void *arg) { 

    int retVal; 
    SOCKET s = ((PassToUDPThread*)arg)->sendSocket; 
    char* recvbuf = ((PassToUDPThread*)arg)->recvbuf; 
    long packet_size = ((PassToUDPThread*)arg)->packet_size; 
    sockaddr_in *ReceiverSocket = new sockaddr_in; 
    memcpy(ReceiverSocket, &(((PassToUDPThread*)arg)->ReceiverSocket), sizeof sockaddr_in); 

    bind(s, (struct sockaddr *)ReceiverSocket, sizeof(struct sockaddr_in)); 

    do { 
     int fromlen = (int)sizeof(struct sockaddr_in); 
     retVal = recvfrom(s, recvbuf, packet_size, 0, (struct sockaddr *)ReceiverSocket, &fromlen); 
     std::cout << "UDP recv by thread "<< std::endl; 
    } while (true); 

    return 0; 

    }

来源

2015-11-04 Wes Poon

使用线程池。
摆脱额外的UDP套接字。使用同一个发送请求到达的响应。这样也简化了客户端。

来源

2015-11-04 09:48:27 EJP

所以我需要抛出套接字s到新线程？ –

通过C++实现多线程并发服务器（UDP情况）

回答

相关问题