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