1.非阻塞套接字的模式
(1)服務(wù)器端
通常socket運(yùn)行后默認(rèn)為阻塞模式。要調(diào)用ioctlsocket函數(shù)設(shè)置非阻塞模式。
如：
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);
在接受客戶端請(qǐng)求的線程中，若接受成功就返回客戶端的套接字，否則返回INVALID_SOCKET錯(cuò)誤，
若錯(cuò)誤代碼為WSAEWOULDBLOCK，說(shuō)明當(dāng)前沒(méi)有客戶端請(qǐng)求。
如：
//接受客戶端請(qǐng)求線程
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();
//沒(méi)有客戶端請(qǐng)求
if(WSAEWOULDBLOCK == n)
{
cout<<"沒(méi)有客戶端發(fā)出請(qǐng)求!"<<endl;
Sleep(1000);
continue;
}else
{
cout<<"出現(xiàn)錯(cuò)誤!"<<endl;
Sleep(1000);
}
}else
{
cout<<"已連接客戶端!"<<endl;
IsConnet = true;
break;
}
}
return 0;
}
就recv函數(shù)來(lái)說(shuō)，在阻塞模式中，如果沒(méi)有客戶端發(fā)送數(shù)據(jù)過(guò)來(lái)，線程到這里會(huì)阻塞，直到有數(shù)
據(jù)發(fā)送過(guò)來(lái)為止。在非阻塞模式中，沒(méi)有客戶端發(fā)送數(shù)據(jù)過(guò)來(lái)，返回SOCKER_ERROR，錯(cuò)誤代碼為WSAEWOULDBLOCK。
如：
//接收數(shù)據(jù)線程
DWORD WINAPI ReceiveDataPro(LPVOID LpP)
{
while(!IsConnet); //保證連接后再接受數(shù)據(jù)
while(1)
{
if(IsReadyRecei) //保證緩沖區(qū)在未處理時(shí)不受新來(lái)的數(shù)據(jù)的影響
{
int ReceiLen = recv(ClientSock, (char *)&DataPack, sizeof(DataPack), 0);
if(SOCKET_ERROR == ReceiLen)
{
int Err = WSAGetLastError();
if(WSAEWOULDBLOCK == Err)
{
cout<<"沒(méi)有收到數(shù)據(jù)"<<endl;
continue;
}
else if (WSAENETDOWN == Err ||//客戶端關(guān)閉了連接
WSAETIMEDOUT == Err ||
WSAECONNRESET == Err )
{
cout<<"服務(wù)器關(guān)閉了連接"<<endl;
break;
}
}
if(0 == ReceiLen) //客戶端關(guān)閉了連接
{
cout<<"ReceiLen = 0"<<endl;
break;
}
if(ReceiLen >= sizeof(DataPack)) //成功接收
{
cout<<"已收到數(shù)據(jù)："<<DataPack.buf<<endl;
IsReadyRecei = false;
break;
}
}
}
return 0;
}
(2)客戶端
在客戶端的連接請(qǐng)求線程中，connect函數(shù)會(huì)返回SOCKET_ERROR，這并不是說(shuō)明連接失敗，具體情況
要看它的WSAGetLastError()返回值，若它三次返回SOCKET_ERROR的Error代碼依次為WSAEWOULDBLOCK，
WSAEINVAL，WSAEISCONN，就說(shuō)明連接服務(wù)器成功，否則失敗。但有的時(shí)候WSAEINVAL沒(méi)有出現(xiàn)就有WSAEISCONN
了，所以我還是以WSAEISCONN為連接完成的標(biāo)志，但要注意其實(shí)在三次返回代碼中，第一次的WSAEWOULDBLOCK
之前的connect操作就成功了，如果沒(méi)出意外服務(wù)器就要響應(yīng)了。
如：
//連接服務(wù)器線程
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<<"過(guò)程1!"<<endl;
BlockFlag++;
continue;
}
else if(WSAEINVAL == n) //監(jiān)聽(tīng)狀態(tài)
{
cout<<"過(guò)程2!"<<endl;
InvalFlag++;
continue;
}
else if(WSAEISCONN == n) //連接完成
{
cout<<"已連接服務(wù)器!"<<endl;
IsConnet = true;
break;
}
else
{
cout<<"出現(xiàn)其他錯(cuò)誤!\n"<<endl;
Sleep(1000);
}
}
}
return 0;
}
在發(fā)送數(shù)據(jù)線程中，send()返回的是發(fā)送數(shù)據(jù)的長(zhǎng)度說(shuō)明發(fā)送成功；返回SOCKET_ERROR時(shí)，若
錯(cuò)誤代碼為WSAEWOULDBLOCK就再重試，不是WSAEWOULDBLOCK就說(shuō)明有錯(cuò)誤。】
如：
//發(fā)送數(shù)據(jù)線程
DWORD WINAPI SendDataPro(LPVOID LpP)
{
while(!IsConnet); //保證已連接服務(wù)器
while(1)
{
int len = send(ClientSock, (char *)&DataPack, DataPack.Head.len, 0);
if(SOCKET_ERROR == len)
{
int Error = WSAGetLastError();
if(WSAEWOULDBLOCK == Error)
continue;
}
else //發(fā)送成功
{
cout<<"發(fā)送成功!"<<endl;
break;
}
}
return 0;
}
posted on 2009-07-26 11:13
yunboy 閱讀(2112)
評(píng)論(1) 編輯 收藏 引用 所屬分類:
網(wǎng)絡(luò)通信