深入了解異步套接字
發表于:2007-07-14來源:作者:點擊數:
標簽:
CAsyncSocket異步套接字是MFC封裝的SOCKET的類。 只有在三種條件下,才會發出FD_WRITE通知: 1、使用connect或WSAConnect,一個套接字首次建立了連接; 2、使用accept或WSAAccept,套接字被接受以后; 3、若send、WSASend、sendto或WSASendTo操作失敗,返回了W
CAsyncSocket異步套接字是MFC封裝的SOCKET的類。
只有在三種條件下,才會發出FD_WRITE通知:
1、使用connect或WSAConnect,一個套接字首次建立了連接;
2、使用a
clearcase/" target="_blank" >ccept或WSAAccept,套接字被接受以后;
3、若send、WSASend、sendto或WSASendTo操作失敗,返回了WSAEWOULDBLOCK錯誤
,而且緩沖區的空間變得可用。
因此,一個應用程序自收到FD_WRITE消息開始,便認為自己必然能在一個套接字
上發出數據。
所以系統是通過掩碼(例:FD_WRITE)來通知異步套接字消息響應函數的。
在實例程序中,經過設置斷點調試得知系統會在如下的函數中處理異步消息:
void PASCAL CAsyncSocket::DoCallBack(WPARAM wParam, LPARAM lParam)
{
if (wParam == 0 && lParam == 0)
return;
// Has the socket be closed?
CAsyncSocket* pSocket =
CAsyncSocket::LookupHandle((SOCKET)wParam, TRUE);
// If yes ignore message
if (pSocket != NULL)
return;
pSocket = CAsyncSocket::LookupHandle((SOCKET)wParam, FALSE);
if (pSocket == NULL)
{
// Must be in the middle of an Accept call
pSocket = CAsyncSocket::LookupHandle(INVALID_SOCKET,
FALSE);
ASSERT(pSocket != NULL);
pSocket->m_hSocket = (SOCKET)wParam;
CAsyncSocket::DetachHandle(INVALID_SOCKET, FALSE);
CAsyncSocket::AttachHandle(pSocket->m_hSocket, pSocket,
FALSE);
}
int nErrorCode = WSAGETSELECTERROR(lParam);
switch (WSAGETSELECTEVENT(lParam))
{
case FD_READ://如果來的異步消息FD_READ,就準備觸發OnReceive() 函數
{
DWORD nBytes;
if (!pSocket->IOCtl(FIONREAD, &nBytes))
nErrorCode = WSAGetLastError();
if (nBytes != 0 || nErrorCode != 0)
pSocket->OnReceive(nErrorCode);
}
break;
case FD_WRITE:
pSocket->OnSend(nErrorCode);
break;
case FD_OOB:
pSocket->OnOutOfBandData(nErrorCode);
break;
case FD_A
CCEPT:
pSocket->OnAccept(nErrorCode);
break;
case FD_CONNECT:
pSocket->OnConnect(nErrorCode);
break;
case FD_CLOSE:
pSocket->OnClose(nErrorCode);
break;
}
}
從以上的代碼可以看出,MFC是通過DoCallBack()這個函數來處理異步
網絡事件。
當我們用
AsyncSelect(FD_READ);的話,一旦成功,系統將會觸發函數
OnReceive(nErrorCode);
同樣FD_WRITE對應函數OnSend(nErrorCode);
同樣FD_ACCEPT對應函數OnAccept(nErrorCode);
同樣FD_CONNECT對應函數OnConnect(nErrorCode);
同樣FD_CLOSE對應函數OnClose(nErrorCode);
同樣FD_OOB對應函數OnOutOfBandData(nErrorCode);
原文轉自:http://www.anti-gravitydesign.com