多线程udp服务器

Question

我是个新手，如果你能给我建议的话，请告诉我。我有一个向客户端广播消息的服务器。然后客户端将回复发送回服务器。我想用单独的线程处理每个回复。每个回复都有mesage id和thread id。我如何用来自所有线程的信息填充一些结构，然后读取它

也从我的代码，它是正确地创建线程，而还是它存在某种方式来创建线程，只是如果我得到客户端的回复？

我是从正确的理解开始的吗？

int main(){

    while(1){

        sendto on broadcast IP 
        pthread_create(&cln_thread, NULL, msg_processing, (void *) &arg))

   }
}

msg_processing () {

     recvfrom client msg with id of packet and thread id
     how to write those informations and then read them in main when program finish

}

非常感谢。

Answer 1

您可以在Go lang中找到一个多线程UDP服务器的好例子，如下所示：https://gist.github.com/jtblin/18df559cf14438223f93

主要思想是完整地使用多核功能，以便每个线程在自己的CPU核心上工作，并将UDP数据读取到单个缓冲区中进行处理。

Answer 2

犯错误不，只需创建一个线程，仅一次，用于在一个套接字上接收数据报。在线程函数中，在while（true）循环中接收数据报。不要让此接收线程终止，也不要再创建任何接收线程。不断地创建/终止/销毁线程是低效的、危险的、不必要的、容易出错的、难以调试的，您应该尽最大努力避免这样做。

编辑：

只有一个接收线程-但您不必在那里进行处理。Malloc一个64K的缓冲区，接收数据，将缓冲区指针推到生产者-消费者队列上，推到一个线程池中，该线程池将进行处理，循环返回，然后Malloc再次重置指针，并为下一个数据报创建另一个缓冲区。处理完成后，释放池线程中的*缓冲区。当缓冲区处理并行运行时，接收线程将返回等待数据报。

如果您发现数据报到达得如此之快，以至于处理跟不上，随着队列中堆积越来越多的*缓冲区，内存使用将不受检查地增长。有几种方法可以解决这个问题。您可以使用一个有界队列，该队列在达到其容量时进行阻塞。您可以在启动时创建x缓冲区，并将其存储在接收线程弹出的另一个生产者-消费者“池队列”上（而不是malloc）-处理池线程可以将“使用”*缓冲区推回到池队列中重用。如果池用完，接收线程将阻塞池，直到返回*缓冲区。

我更喜欢池缓冲区方法，因为它限制了整个系统的内存使用，避免了连续的malloc/free和碎片问题等，避免了更复杂的有界队列，更容易调整（池级别在运行时很容易更改），更容易监控/调试-我通常转储池级别（即队列计数），使用计时器每秒显示一次。

无论哪种情况，数据报都可能丢失，但是，如果您的系统过载，以至于数据定期到达的速度快于处理速度，无论您如何设计，情况都会如此。

一个插座就可以了，那么为什么要复杂化呢？：）