C++ 同时接收 2 条或更多 UDP 消息

我正在尝试在我的main.cxx中接收UDP消息。我创建了一个UDP服务器方法getUdp（char *buffer）来监听while（true）无限循环中的传入UDP消息。

这是我面临的问题。此 UDP 服务器能够一次侦听一条消息。当两个或多个 UDP 消息同时出现时，它不会排队进入缓冲区。我想这是因为每次在无限循环中调用该方法时，getUdp（） 方法都会打开一个套接字，获取消息并关闭套接字，导致服务器无法对消息进行排队。

如何调整此代码以接收 2 条或更多 UDP 消息？感谢任何建议。

谢谢。

UdpServer.cpp

#include <stdio.h>
#include <iostream>
#include <sstream>
#include <stdlib.h>
#include <string.h>
#include <winsock.h>
#include <time.h>
#include "UdpServer.h"
#include "stdafx.h"
using namespace std;
#pragma comment(lib, "ws2_32.lib")
#define BUFFER_SIZE 4096
void getUDP(char *buffer);
void UDPServer::MyUDP::getUDP(char *buffer)
{
    WSADATA w;                          /* Used to open windows connection */
    int client_length;                  /* Length of client struct */
    int bytes_received;                 /* Bytes received from client */
    SOCKET sd;                          /* Socket descriptor of server */
    struct sockaddr_in server;          /* Information about the server */
    struct sockaddr_in client;          /* Information about the client */
    struct hostent *hp;                 /* Information about this computer */
    char host_name[256];                /* Name of the server */
    time_t current_time;                /* Current time */
    /* Open windows connection */
    if (WSAStartup(0x0101, &w) != 0)
    {
        fprintf(stderr, "Could not open Windows connection.n");
    }
    /* Open a datagram socket */
    sd = socket(AF_INET, SOCK_DGRAM, 0);
    if (sd == INVALID_SOCKET)
    {
        fprintf(stderr, "Could not create socket.n");
        WSACleanup();
    }
    /* Clear out server struct */
    memset((void *)&server, '', sizeof(struct sockaddr_in));
    /* Set family and port */
    server.sin_family = AF_INET;
    server.sin_port = htons(11000);
    /* Set address automatically if desired */
    /* Get host name of this computer */
    gethostname(host_name, sizeof(host_name));
    hp = gethostbyname(host_name);
    /* Check for NULL pointer */
    if (hp == NULL)
    {
        fprintf(stderr, "Could not get host name.n");
        closesocket(sd);
        WSACleanup();
    }
    unsigned int a = 127;
    unsigned int b = 0;
    unsigned int c = 0;
    unsigned int d = 1;
    /* Assign the address */
    server.sin_addr.S_un.S_un_b.s_b1 = a;
    server.sin_addr.S_un.S_un_b.s_b2 = b;
    server.sin_addr.S_un.S_un_b.s_b3 = c;
    server.sin_addr.S_un.S_un_b.s_b4 = d;
    /* Bind address to socket */
    if (bind(sd, (struct sockaddr *)&server, sizeof(struct sockaddr_in)) == -1)
    {
        fprintf(stderr, "Could not bind name to socket.n");
        closesocket(sd);
        WSACleanup();
    }
    /* Print out server information */
    printf("Server running on %u.%u.%u.%un", (unsigned char)server.sin_addr.S_un.S_un_b.s_b1,
                                                (unsigned char)server.sin_addr.S_un.S_un_b.s_b2,
                                                (unsigned char)server.sin_addr.S_un.S_un_b.s_b3,
                                                (unsigned char)server.sin_addr.S_un.S_un_b.s_b4);
    printf("Press CTRL + C to quitn");
    /* Loop and get data from clients */
    client_length = (int)sizeof(struct sockaddr_in);
    /* Receive bytes from client */
    bytes_received = recvfrom(sd, buffer, BUFFER_SIZE, 0, (struct sockaddr *)&client, &client_length);
    if (bytes_received < 0)
    {
        fprintf(stderr, "Could not receive datagram.n");
        closesocket(sd);
        WSACleanup();
    }
    current_time = time(NULL);
    closesocket(sd);
    WSACleanup();
}

主.cxx

int main(int argc, char** argv)
{
    while(true)
    {
        //! wait for UDP message
        UDPServer::MyUDP myudp;
        myudp.getUDP(buffer);
        if(buffer[0] != 0)
        {
            string udpMsg(buffer);
            if(udpMsg == "ProcessThisMessage")
            {
                memset(&buffer[0], 0, sizeof(buffer));
                cout << "UDP Message: " + udpMsg;
            }
            ...
        }
    }
}