Question

c++简单服务器接收数据，下面是我代码，现在我的情况是

下面是我代码，现在我的情况是，每连接一个客户端就开一个线程，然后线程里面接收数据，但是接收数据会使线程假死，不能干其他东西，所以现在我想开一条线程接受全部的客户端发来的数据，如果这样不好，还有什么好的想法给我参考一下，如果有大大不介意可以微微改一下代码给我参考一下

#include "stdafx.h"
#include <iostream>
#include "ODSocket.h"
#include "pthread.h"
#include <string>
using namespace std;

pthread_t pidrun;

ODSocket m_pServerSocket;
static void* th_run(void *r)
{
ODSocket* ss = (ODSocket*)r;
cout<<"启动sb线程"<<endl;
while(1)
{
int aa = 512;
char* buff = new char[aa];
int num = ss->Recv(buff,aa);//收到数据
if( num <= 0 )
{
delete[] buff;
break;
}
//打印数据
for(int i=0;i<num;i++)
{
cout<<buff[i];
}
cout<<"\n"<<"-----我是万恶的分割线,关键我还是垃圾服务器--------"<<endl;
delete [] buff;
}

return NULL;
}

int main(int argc, _TCHAR* argv[])
{

if ( m_pServerSocket.Init() ) {
printf("init server failed\n");
}
if ( !m_pServerSocket.Create(AF_INET, SOCK_STREAM) ) {
printf("create server failed\n");
}
if ( !m_pServerSocket.Bind(4444) ) {
printf("bind server failed\n");
}
if ( !m_pServerSocket.Listen() ) {
printf("listen server failed\n");
}
cout<<"垃圾服务器开启成功"<<endl;
while ( 1 ) {
ODSocket* clientSocket = new ODSocket();
if ( ! m_pServerSocket.Accept(*clientSocket) )
{
clientSocket->Close();
cout<<"lose"<<endl;
continue;
}
else
{
cout<<"成功进来了一个小偷客户端"<<endl;
//pthread_mutex_init(&mutex,NULL);
pthread_create(&pidrun,NULL,th_run,clientSocket);//启动线程
}
}
return 0;
}

Answer 1

一个线程处理所有客户端的receive操作是很常用的方法。
FreeBSD下的KQueue，Linux下的epoll，Windows下的完成例程模型，以及三个系统下都能用的select、前两个系统下可以用的poll，都是一个线程处理多个套接字。
三个系统下socket可以设置为非阻塞方式，此时如果调用recv需要等待数据来，那么就会直接返回错误而不是在那边等；只有数据已经来了，调用recv才会成功。如果程序没事做，正确的方法也不是死循环去轮训这些套接字，而是将这些套接字填入一个“集合”（FDSET），然后用select函数在这个集合上面等待，这个集合中有套接字能收数据了，等待就结束。
这里select的等待就类似你那里面的recv的等待。只不过recv在一个套接字上等待的时候线程就会停止运行，而select可以在一堆套接字上同时等待。