1.非阻塞套接字的模式
(1)服務器端
通常socket運行后默認為阻塞模式。要調用ioctlsocket函數設置非阻塞模式。
如：
WSAData Data;
WSAStartup(MAKEWORD(2, 2), &Data);
SerSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if(INVALID_SOCKET == SerSocket)
cout<<"Invalid Socket!\n";
u_long iMode = 1;
ioctlsocket(SerSocket, FIONBIO, &iMode);
在接受客戶端請求的線程中，若接受成功就返回客戶端的套接字，否則返回INVALID_SOCKET錯誤，
若錯誤代碼為WSAEWOULDBLOCK，說明當前沒有客戶端請求。
如：
//接受客戶端請求線程
DWORD WINAPI AcceptClientPro(LPVOID LpP)
{
SOCKADDR_IN ClientAdrr;
int AddrLen = sizeof(SOCKADDR);
//非阻塞模式
while (!IsConnet)
{
ClientSock = accept(SerSocket, (SOCKADDR *)&ClientAdrr, &AddrLen );
if(INVALID_SOCKET == ClientSock)
{
int n = WSAGetLastError();
//沒有客戶端請求
if(WSAEWOULDBLOCK == n)
{
cout<<"沒有客戶端發出請求!"<<endl;
Sleep(1000);
continue;
}else
{
cout<<"出現錯誤!"<<endl;
Sleep(1000);
}
}else
{
cout<<"已連接客戶端!"<<endl;
IsConnet = true;
break;
}
}
return 0;
}
就recv函數來說，在阻塞模式中，如果沒有客戶端發送數據過來，線程到這里會阻塞，直到有數
據發送過來為止。在非阻塞模式中，沒有客戶端發送數據過來，返回SOCKER_ERROR，錯誤代碼為WSAEWOULDBLOCK。
如：
//接收數據線程
DWORD WINAPI ReceiveDataPro(LPVOID LpP)
{
while(!IsConnet); //保證連接后再接受數據
while(1)
{
if(IsReadyRecei) //保證緩沖區在未處理時不受新來的數據的影響
{
int ReceiLen = recv(ClientSock, (char *)&DataPack, sizeof(DataPack), 0);
if(SOCKET_ERROR == ReceiLen)
{
int Err = WSAGetLastError();
if(WSAEWOULDBLOCK == Err)
{
cout<<"沒有收到數據"<<endl;
continue;
}
else if (WSAENETDOWN == Err ||//客戶端關閉了連接
WSAETIMEDOUT == Err ||
WSAECONNRESET == Err )
{
cout<<"服務器關閉了連接"<<endl;
break;
}
}
if(0 == ReceiLen) //客戶端關閉了連接
{
cout<<"ReceiLen = 0"<<endl;
break;
}
if(ReceiLen >= sizeof(DataPack)) //成功接收
{
cout<<"已收到數據："<<DataPack.buf<<endl;
IsReadyRecei = false;
break;
}
}
}
return 0;
}
(2)客戶端
在客戶端的連接請求線程中，connect函數會返回SOCKET_ERROR，這并不是說明連接失敗，具體情況
要看它的WSAGetLastError()返回值，若它三次返回SOCKET_ERROR的Error代碼依次為WSAEWOULDBLOCK，
WSAEINVAL，WSAEISCONN，就說明連接服務器成功，否則失敗。但有的時候WSAEINVAL沒有出現就有WSAEISCONN
了，所以我還是以WSAEISCONN為連接完成的標志，但要注意其實在三次返回代碼中，第一次的WSAEWOULDBLOCK
之前的connect操作就成功了，如果沒出意外服務器就要響應了。
如：
//連接服務器線程
DWORD WINAPI ConnetServerPro(LPVOID LpP)
{
SOCKADDR_IN ServerAddr;
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons(1200);
ServerAddr.sin_addr.s_addr = inet_addr("192.168.1.100");
int BlockFlag = 0;
int InvalFlag = 0;
while (!IsConnet)
{
int nResu = connect(ClientSock, (SOCKADDR *)&ServerAddr, sizeof(SOCKADDR));
if(SOCKET_ERROR == nResu)
{
int n = WSAGetLastError();
if(WSAEWOULDBLOCK == n ) //不能立即完成
{
cout<<"過程1!"<<endl;
BlockFlag++;
continue;
}
else if(WSAEINVAL == n) //監聽狀態
{
cout<<"過程2!"<<endl;
InvalFlag++;
continue;
}
else if(WSAEISCONN == n) //連接完成
{
cout<<"已連接服務器!"<<endl;
IsConnet = true;
break;
}
else
{
cout<<"出現其他錯誤!\n"<<endl;
Sleep(1000);
}
}
}
return 0;
}
在發送數據線程中，send()返回的是發送數據的長度說明發送成功；返回SOCKET_ERROR時，若
錯誤代碼為WSAEWOULDBLOCK就再重試，不是WSAEWOULDBLOCK就說明有錯誤。】
如：
//發送數據線程
DWORD WINAPI SendDataPro(LPVOID LpP)
{
while(!IsConnet); //保證已連接服務器
while(1)
{
int len = send(ClientSock, (char *)&DataPack, DataPack.Head.len, 0);
if(SOCKET_ERROR == len)
{
int Error = WSAGetLastError();
if(WSAEWOULDBLOCK == Error)
continue;
}
else //發送成功
{
cout<<"發送成功!"<<endl;
break;
}
}
return 0;
}
posted on 2009-07-26 11:13
yunboy 閱讀(2112)
評論(1) 編輯 收藏 引用 所屬分類:
網絡通信