Socket Server 简单实现

《Socket Server 简单实现》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。

1、一、基本原理有时候我们需要实现一个公共的模块，需要对多个其他的模块提供服务，最常用的方式就是实现一个SocketServer，接受客户的请求，并返回给客户结果。这经常涉及到如果管理多个连接及如何多线程的提供服务的问题，常用的方式就是连接池和线程池，基本流程如下：首先服务器端有一个监听线程，不断监听来自客户端的连接。当一个客户端连接到监听线程后，便建立了一个新的连接。监听线程将新建立的连接放入连接池进行管理，然后继续监听新来的连接。线程池中有多个服务线程，每个线程都监听一个任务队列，一个建立的连接对应一个服务任务，当服务线程发现有新的任务的时候，便用此连接向客户端提供服务。一个SocketSer

2、ver所能够提供的连接数可配置，如果超过配置的个数则拒绝新的连接。当服务线程完成服务的时候，客户端关闭连接，服务线程关闭连接，空闲并等待处理新的任务。连接池的监控线程清除其中关闭的连接对象，从而可以建立新的连接。二、对Socket的封装Socket的调用主要包含以下的步骤：调用比较复杂，我们首先区分两类Socket，一类是ListeningSocket，一类是ConnectedSocket.ListeningSocket由MySocketServer负责，一旦accept，则生成一个ConnectedSocket，又MySocket负责。MySocket主要实现的方法如下：intMySocke

3、t::write(constchar*buf,intlength){       intret=0;       intleft=length;       intindex=0;       while(left>0)       {               ret=send(m_socket,buf+index,left,0);               if(ret==0)                       break;               elseif(ret==-1)               {                       break;  

4、             }               left-=ret;               index+=ret;       }       if(left>0)               return-1;       return0;}intMySocket::read(char*buf,intlength){       intret=0;       intleft=length;       intindex=0;       while(left>0)       {               ret=recv(m_socket,buf+index,left,

5、0);               if(ret==0)                       break;               elseif(ret==-1)                       return-1;               left-=ret;               index+=ret;       }       returnindex;}intMySocket::status(){       intstatus;       intret;       fd_setcheckset;       structtimevaltimeout

6、;       FD_ZERO(&checkset);       FD_SET(m_socket,&checkset);       timeout.tv_sec=10;       timeout.tv_usec=0;       status=select((int)m_socket+1,&checkset,0,0,&timeout);       if(status<0)               ret=-1;       elseif(status==0)               ret=0;       else               ret=0;       ret

7、urnret;}intMySocket::close(){       structlingerlin;       lin.l_onoff=1;       lin.l_linger=0;       setsockopt(m_socket,SOL_SOCKET,SO_LINGER,(constchar*)&lin,sizeof(lin));       ::close(m_socket);