windows socket编程中如何判断服务器端有数据发给客户端

Question

    现在我做一个客户端程序.这个客户端程序的一个功能就是创建一个监听线程,监听和服务器的网络连接,判断服务器是否有socket字符串发给客户端,如果有,就创建一个接收线程接收socket字符串并对其解析。但是我现在面临一个问题：我如何判断服务器端有socket字符串发给客户端呢？我想到调用CAsyncSocket::Receive函数，假如该函数返回值不为0，就表示有数据过来，但是又如何表示服务器和客户端程序处于连接状态，同时服务器并没有给客户端程序发消息呢？我感觉调用CAsyncSocket::Receive函数并不可靠。那该如何做呢？

Answer 1

用ACCEPT,如：
sockSrvr.Accept(recSo,(SOCKADDR *)&client,&iAddrSize);

Answer 2

     这个函数只能判断服务器端和客户端的连接是否正常.现在我要在监听线程做的是:
1.假如和服务器端连接断开,就提示用户重新连接2.假如服务器和客户端程序处于连接状态，同时服务器并没有给客户端程序发消息,就继续监听(监听线程在线程函数最后创建自己).3.假如服务器给客户端程序发送socket字符串,就创建接收线程(接收socket字符串并解析),同时继续监听.     我是问怎么区分2和3这两种情况,就是什么时候创建接收线程呢?

Answer 3

对于阻塞模式，Receive函数会等待接收数据，收到数据或出错才返回。
用CAsyncSocket可以自己从CAsyncSocket派生类，重载OnAccept、OnReceive函数，利用消息驱动方式来工作。

Answer 4

Receive返回值 >= 0就表示服务器和客户端处于连接状态啊,不然的话就返回-1了

Answer 5

用select函数可以判断是否有字符串来,有就建立接收线程啊

Answer 6

     大侠,照你的意思,我应该是先设置阻塞模式，然后连接服务器，创建监听线程。在监听线程只要和服务器处于连接状态，就直接调用Receive函数（不创建接收线程，因为是阻塞模式，Receive函数会等待接收数据，收到数据或出错才返回），然后继续监听，否则提示用户连接断开。我担心的是在监听线程里调用Receive函数会不会影响继续监听。这个阻塞模式会影响程序的继续执行吗？

Answer 7

      兄弟,请你看一下MSDN:
CAsyncSocket::Receive
virtual int Receive( void* lpBuf, int nBufLen, int nFlags = 0 );Return ValueIf no error occurs, Receive returns the number of bytes received. If the connection has been closed, it returns 0. Otherwise, a value of SOCKET_ERROR is returned, and a specific error code can be retrieved by calling GetLastError. 
      注意这一句:If the connection has been closed, it returns 0.

Answer 8

简述：   
      确定一个或多个套接口的状态，如需要则等待。   
    
      #include   <winsock.h>   
    
      int   PASCAL   FAR   select(   int   nfds,   fd_set   FAR*   readfds,   
      fd_set   FAR*   writefds,   fd_set   FAR*   exceptfds,   
      const   struct   timeval   FAR*   timeout);   
    
      nfds：本参数忽略，仅起到兼容作用。   
      readfds：（可选）指针，指向一组等待可读性检查的套接口。   
      writefds：（可选）指针，指向一组等待可写性检查的套接口。   
      exceptfds：（可选）指针，指向一组等待错误检查的套接口。   
      timeout：select()最多等待时间，对阻塞操作则为NULL。   
    
  注释：   
      本函数用于确定一个或多个套接口的状态。对每一个套接口，调用者可查询它的可读性、可写性及错误状态信息。用fd_set结构来表示一组等待检查的套接口。在调用返回时，这个结构存有满足一定条件的套接口组的子集，并且select()返回满足条件的套接口的数目。有一组宏可用于对fd_set的操作，这些宏与Berkeley   Unix软件中的兼容，但内部的表达是完全不同的。   
      readfds参数标识等待可读性检查的套接口。如果该套接口正处于监听listen()状态，则若有连接请求到达，该套接口便被标识为可读，这样一个accept()调用保证可以无阻塞完成。对其他套接口而言，可读性意味着有排队数据供读取。或者对于SOCK_STREAM类型套接口来说，相对于该套接口的虚套接口已关闭，于是recv()或recvfrom()操作均能无阻塞完成。如果虚电路被“优雅地”中止，则recv()不读取数据立即返回；如果虚电路被强制复位，则recv()将以WSAECONNRESET错误立即返回。如果SO_OOBINLINE选项被设置，则将检查带外数据是否存在（参见setsockopt()）。   
      writefds参数标识等待可写性检查的套接口。如果一个套接口正在connect()连接（非阻塞），可写性意味着连接顺利建立。如果套接口并未处于connect()调用中，可写性意味着send()和sendto()调用将无阻塞完成。〔但并未指出这个保证在多长时间内有效，特别是在多线程环境中〕。   
      exceptfds参数标识等待带外数据存在性或意味错误条件检查的套接口。请注意如果设置了SO_OOBINLINE选项为假FALSE，则只能用这种方法来检查带外数据的存在与否。对于SO_STREAM类型套接口，远端造成的连接中止和KEEPALIVE错误都将被作为意味出错。如果套接口正在进行连接connect()（非阻塞方式），则连接试图的失败将会表现在exceptfds参数中。   
      如果对readfds、writefds或exceptfds中任一个组类不感兴趣，可将它置为空NULL。   
      在winsock.h头文件中共定义了四个宏来操作描述字集。FD_SETSIZE变量用于确定一个集合中最多有多少描述字（FD_SETSIZE缺省值为64，可在包含winsock.h前用#define   FD_SETSIZE来改变该值）。对于内部表示，fd_set被表示成一个套接口的队列，最后一个有效元素的后续元素为INVAL_SOCKET。宏为：   
      FD_CLR(s,*set)：从集合set中删除描述字s。   
      FD_ISSET(s,*set)：若s为集合中一员，非零；否则为零。   
      FD_SET(s,*set)：向集合添加描述字s。   
      FD_ZERO(*set)：将set初始化为空集NULL。   
      timeout参数控制select()完成的时间。若timeout参数为空指针，则select()将一直阻塞到有一个描述字满足条件。否则的话，timeout指向一个timeval结构，其中指定了select()调用在返回前等待多长时间。如果timeval为{0,0}，则select()立即返回，这可用于探询所选套接口的状态。如果处于这种状态，则select()调用可认为是非阻塞的，且一切适用于非阻塞调用的假设都适用于它。举例来说，阻塞钩子函数不应被调用，且WINDOWS套接口实现不应yield。   
    
  返回值：   
      select()调用返回处于就绪状态并且已经包含在fd_set结构中的描述字总数；如果超时则返回0；否则的话，返回SOCKET_ERROR错误，应用程序可通过WSAGetLastError()获取相应错误代码。   
    
  错误代码：   
      WSANOTINITIALISED：在使用此API之前应首先成功地调用WSAStartup()。   
      WSAENETDOWN：WINDOWS套接口实现检测到网络子系统失效。   
      WSAEINVAL：超时时间值非法。   
      WSAEINTR：通过一个WSACancelBlockingCall()来取消一个（阻塞的）调用。   
      WSAEINPROGRESS：一个阻塞的WINDOWS套接口调用正在运行中。   
      WSAENOTSOCK：描述字集合中包含有非套接口的元素。   
    
  参见：   
      WSAAsyncSelect(),   accept(),   connect(),   recv(),   recvfrom(),   send().   
     看完整个说明,我都不知道这个函数如何判断是否有字符串来? 兄弟,你知道如何使用函数来判断是否有字符串吗?

Answer 9

socket默认就是阻塞的，不需要设置。
如果用CAsyncSocket，对于简单情况是不需要创建线程的，需要自己派生类。在主线程中构造对象，调用Create、Listen，然后线程执行消息循环。重载OnAccept函数，函数中用new构造一个新对象（建议另外派生一个类），调用this->Accept函数，第1参数给新对象。重载新对象类的OnReceive函数，用Receive来接收数据，可以把与接收有关的变量（例如已接收字节数等）定义为成员变量，以便多次接收。重载新对象类的OnClose函数，delete this。
如果用多线程，就不需要CAsyncSocket了，可以直接调用API，用一个线程listen，accept之后创建一个新线程来recv数据。

Answer 10

呵呵，我一般是直接封装API，MFC的socket封装类内置隐藏窗口，不太安全

Answer 11

     用一个线程listen，accept之后创建一个新线程来recv数据?     大侠,照你的意思只要客户端和服务器连接状态,客户端就必须不停的调用Receive函数,即使服务器没有给它发送socket消息。

Answer 12

       大侠,我按照你说的大致写了一些代码:// 手动连接服务器函数：
BOOL CMIConnectManager::ConnectServer(CString csIP,long lPort,HWND hParentWnd)
{……
// 创建监听线程，m_pClientSocket为CSocket类派生类CMIClientSocket指针
CreateThread(NULL,0,ListenThread,
m_pClientSocket,0,&dwThreadId);……
} // 监听线程函数
DWORD WINAPI ListenThread (LPVOID lpParam)
{CMIClientSocket* pSocket =NULL;
pSocket = (CMIClientSocket*)lpParam;while(!pSocket->Accept(...))
{
  // 创建接收线程   
   CreateThread( 
NULL,                        // no security attributes 
0,                           // use default stack size  
MThreadProcessRead,                  // thread function 
pSocket,
0,
&dwThreadID);                // returns the thread identifier}// 继续创建监听线程
DWORD dwThreadId=0;
CreateThread(NULL,0, ListenThread,
lpParam,0,&dwThreadId);}
       大侠,我这个思路对吗?

Answer 13

     大侠,再请教你一下.我在接收线程函数MThreadProcessRead调用之前那个网络拆包函数GlocalReceiveMsg可以吗(之前我向你请教过的)?网络拆包函数的代码如下:
BOOL GlocalReceiveMsg(CMIClientSocket* pClientSocket,BYTE** pResultBuf,int& iResultLen)
{
  // 待接收的数据包的长度
  int  nLeftDataLen = 0; 
// 数据包体长度
int  nPackBodyLen = 0;
 // 外部接收缓冲区
BYTE* pRstbuffer = NULL;
// 接收函数一次实际收到的数据长度
int nRevOnceLen = 0;
// 包头缓冲区
BYTE PackLenBuf[STDATABAND_SIZE];
// STDATABAND_SIZE为网络数据包头，具体数值为12
int nRecPackLen = STDATABAND_SIZE;
// 初始化实际接收的长度为0
iResultLen = 0;// 接收包头数据
do 
{
// Receive函数第一个参数为缓冲区指针，第二个参数为缓冲区长度，返回值为// 实际接收的字节数。注意这里有缓冲区指针的移动和缓冲区长度的变化，变化规律就是// 首先设定缓冲区长度为STDATABAND_SIZE（即12），若实际接收字节数为4，那么第二// 次设定缓冲区指针移动4个字节，长度为12-4=8，照此方法循环接收
  nRevOnceLen = pClientSocket->Receive(PackLenBuf+STDATABAND_SIZE-nRecPackLen,nRecPackLen);
     if(result<STDATABAND_SIZE)
 {
    if(nRevOnceLen == SOCKET_ERROR)
{
AfxMessageBox("接收数据失败");
return FALSE;
}

else if(0 == nRevOnceLen)
{
pClientSocket->Close();
return FALSE;
}
else
{
             nRecPackLen = nRecPackLen - nRevOnceLen;
}
 }
     else
  {
 break;
  }
}while(nRecPackLen!=0);
// 解析数据包头，获取数据包长度。数据包体长度（数据包除开包头的长度）放在包头的// 第DATA_LENGTH_INDEX字节。 memcpy(&nPackBodyLen,PackLenBuf+DATA_LENGTH_INDEX,sizeof(DWORD));
pRstbuffer = new BYTE[nPackBodyLen +STDATABAND_SIZE];
nLeftDataLen = nPackBodyLen +STDATABAND_SIZE;
  // 拷贝包头数据到外部缓冲区
memcpy(pRstbuffer,PackLenBuf,STDATABAND_SIZE);
// 设置剩余接收的数据长度为包体长度
nLeftDataLen -=STDATABAND_SIZE;
// 若包体长度为0，就退出 
if(nLeftDataLen ==0)
return TRUE; // 实际接受数据的长度加上包头长度，因为已经成功接收包头
iResultLen = iResultLen + STDATABAND_SIZE; do 
{
// 循环接收包体数据，其原理和接收包头数据类似，
//注意这里的缓冲区指针pRstbuffer是向前偏移的
nRevOnceLen = pClientSocket->Receive(pRstbuffer + iResultLen, nLeftDataLen);
        iResultLen = iResultLen + nRevOnceLen; if(nRevOnceLen == SOCKET_ERROR)
{
AfxMessageBox("接收数据失败");
return FALSE;
}

else if(0 == nRevOnceLen)
{
pClientSocket->Close();
return FALSE;
}
else
{
// 现在剩余接收的长度为上次剩余接收的长度减去本次实际接受的长度
            nLeftDataLen -= nRevOnceLen;
// 假如剩余接收的长度为0，表示完全接收整个包，就退出循环
            if(nLeftDataLen ==0)
                   break;
}
} while(true);
// 赋值给外部缓冲区指针  
*pResultBuf = pRstbuffer; return TRUE;
}

Answer 14

可以。
TCP接收数据都要判断返回值，必要时多次接收。

Answer 15

不会影响，你接收失败的时候continue就可以了，在循环里加上退出标志判断，以便程序退出线程也正常退出。

Answer 16

用WSAAsyncSelect模型，或WSAEventSelect模型都可以!

Answer 17

    你说多线程要注意的是访问共享数据可能会有冲突。我们假设这样一种情况:监听线程创建了A接收线程,然后A接收线程开始接收数据,但还没等A接收线程接收完数据,监听线程已经创建B接收线程,B接收线程也开始接收数据,那么A接收线程和B接收线程会不会接收同一个数据,这算不算访问共享数据呢?