Windows網(wǎng)絡(luò)編程阻塞式迭代模式和并發(fā)模式

1、Windows網(wǎng)絡(luò)編程阻塞式迭代模式和并發(fā)模式區(qū)別：阻塞式迭代模式：每次只服務(wù)一個(gè)連接，只有在服務(wù)完當(dāng)前服務(wù)器連接之后，才會(huì)繼續(xù)服務(wù)下一個(gè)客戶(hù)端連接阻塞式并發(fā)連接模式：通過(guò)多線程，可以同時(shí)服務(wù)多個(gè)連接，每一個(gè)線程處理一個(gè)客戶(hù)端連接步驟：阻塞式迭代模式步驟：1，先連接處理，綁定本地地址和監(jiān)聽(tīng)接受一個(gè)客戶(hù)端連接并返回對(duì)應(yīng)的連接的套接字處理一個(gè)客戶(hù)端的連接，實(shí)現(xiàn)接受和發(fā)送數(shù)據(jù)4，關(guān)閉一個(gè)服務(wù)5,服務(wù)器主體阻塞式并發(fā)模式：和迭代模式基本相同，只是在于處理客戶(hù)端連接上，我們需要用到多線程來(lái)處理客戶(hù)端連接，以給予服務(wù)端同時(shí)處理業(yè)務(wù)的能力多線程函數(shù)：HANDLECreateThread(LPSECURITY

2、_ATTRIBUTESIpThreadAttributes,/pointertosecurityattributesDWORDdwStackSize,/initialthreadstacksizeLPTHREAD_START_ROUTINEIpStartAddress,/pointertothreadfunctionLPVOIDIpParameter,/argumentfornewthreadDWORDdwCreationFlags,/creationflagsLPDWORDIpThreadId/pointertoreceivethreadID);第一個(gè)參數(shù)是指向SECURITY_ATTRIB

3、UTES型態(tài)的結(jié)構(gòu)的指針。一般取值0第二個(gè)參數(shù)是用于新線程的初始堆棧大小，默認(rèn)值為0。在任何情況下，Windows根據(jù)需要?jiǎng)討B(tài)延長(zhǎng)堆棧的大小。第三個(gè)參數(shù)是指向線程函數(shù)的指標(biāo)。函數(shù)名稱(chēng)沒(méi)有限制,但是必須以下列形式聲明：DWORDWINAPIThreadProc(PVOIDpParam);第四個(gè)參數(shù)為傳遞給ThreadProc的參數(shù)。這樣主線程和從屬線程就可以共享數(shù)據(jù)。第五個(gè)參數(shù)通常為0,但當(dāng)建立的線程不馬上執(zhí)行時(shí)為旗標(biāo)CREATE_SUSPENDED。線程將暫停直到呼叫ResumeThread來(lái)恢復(fù)線程的執(zhí)行為止。第六個(gè)參數(shù)是一個(gè)指標(biāo)，指向接受執(zhí)行緒ID值的變量。代碼：迭代模型代碼：/阻塞式迭代

4、模型.cpp:定義控制臺(tái)應(yīng)用程序的入口點(diǎn)。#includestdafx.h#include#include#pragmacomment(lib,ws2_32.lib)usingnamespacestd;#definenSERPort8000#definenBufMaxSize1024/封裝的打印voiddebugLog(char*logStr)coutlogStrWSAGetLastError()WSAStartuperror);returnFALSE;/先創(chuàng)建套接字綁定本地地址然后開(kāi)始監(jiān)聽(tīng)SOCKETBind_Listen(intnBacklog)SOCKEThSocket=socket(A

5、F_INET,SOCK_STREAM,IPPROTO_TCP);if(hSocket=INVALID_SOCKET)debugLog(Bind_Listen-socketerror!);returnINVALID_SOCKET;sockaddr_insaSerAddr;saSerAddr.sin_family=AF_INET;saSerAddr.sin_addr.s_addr=htonl(ADDR_ANY);saSerAddr.sin_port=htons(nSERPort);if(bind(hSocket,(LPSOCKADDR)&saSerAddr,sizeof(saSerAddr)deb

6、ugLog(Bind_Listen-binderror);closesocket(hSocket);returnINVALID_SOCKET;if(listen(hSocket,nBacklog)=SOCKET_ERROR)closesocket(hSocket);debugLog(Bind_Listen-listenerror);returnINVALID_SOCKET;returnhSocket;/接受一個(gè)客戶(hù)端連接并返回對(duì)應(yīng)的連接的套接字SOCKETAcceptConnetion(SOCKEThScoket)sockaddr_insaConAddr;intnSize=sizeof(saC

7、onAddr);SOCKETsd=accept(hScoket,(LPSOCKADDR)&saConAddr,&nSize);if(sd=INVALID_SOCKET)debugLog(AcceptConnetion-connecterror);returnINVALID_SOCKET;returnsd;Windows網(wǎng)絡(luò)編程阻塞式迭代模式和并發(fā)模式處理一個(gè)客戶(hù)端的連接，實(shí)現(xiàn)接受和發(fā)送數(shù)據(jù)BOOLClientConFun(SOCKETsd)charBufnBufMaxSize;intnRetByte;/循環(huán)處理數(shù)據(jù)do接受到來(lái)自客戶(hù)端的數(shù)據(jù)nRetByte=recv(sd,Buf,nBufMa

8、xSize,0);if(nRetByte=SOCKET_ERROR)debugLog(ClientConFun-recverror!);returnFALSE;elseif(nRetByte!=0)BufnRetByte=0;cout接收到一條數(shù)據(jù)：Bufendl;intnSend=0;while(nSend0)nSend+=nTemp;elseif(nTemp=SOCKET_ERROR)debugLog(ClientConFun-senderror);returnFALSE;else/send返回0由于此時(shí)sendsend-closeerror);returnFALSE;while(nRet

9、Byte!=0);returnTRUE;Windows網(wǎng)絡(luò)編程阻塞式迭代模式和并發(fā)模式/關(guān)閉一個(gè)連接BOOLCloseConnect(SOCKETsd)/首先發(fā)送一個(gè)TCPFIN分段，向?qū)Ψ奖砻饕呀?jīng)完成數(shù)據(jù)發(fā)送if(shutdown(sd,SD_SEND)=SOCKET_ERROR)debugLog(CloseConnect-shutdownerror);returnFALSE;charBufnBufMaxSize;intnRetByte;donRetByte=recv(sd,Buf,nBufMaxSize,0);if(nRetByte=SOCKET_ERROR)debugLog(CloseC

10、onnect-recverror);break;elseif(nRetByte0)debugLog(CloseConnect錯(cuò)誤的接收數(shù)據(jù));break;while(nRetByte!=0);if(closesocket(sd)=SOCKET_ERROR)debugLog(CloseConnect-closeSocketerror);returnFALSE;returnTRUE;/服務(wù)器主體voidMyTcpSerFun()SOCKEThSocket=Bind_Listen(1);if(hSocket=INVALID_SOCKET)debugLog(MyTcpSocket-Bind_Liste

11、nerror);return;while(TRUE)/返回客戶(hù)端的套接字SOCKETsd=AcceptConnetion(hSocket);if(sd=INVALID_SOCKET)debugLog(MyTcpSerFun-AcceptConnectionerror);break;Windows網(wǎng)絡(luò)編程阻塞式迭代模式和并發(fā)模式/客戶(hù)端處理if(ClientConFun(sd)=FALSE)/break;關(guān)閉一個(gè)客戶(hù)端的連接if(CloseConnect(sd)=FALSE)break;if(closesocket(hSocket)=SOCKET_ERROR)debugLog(MyTcpSerF

12、un-closesocketerror);return;int_tmain(intargc,_TCHAR*argv)/初始化InitSocket();/業(yè)務(wù)數(shù)據(jù)處理MyTcpSerFun();/釋放WinSocketWSACleanup();system(pause);return0;并發(fā)模型代碼：/阻塞式并發(fā)模型.cpp:定義控制臺(tái)應(yīng)用程序的入口點(diǎn)。#includestdafx.h#include#include#pragmacomment(lib,ws2_32.lib)usingnamespacestd;#definenSERPort8000#definenBufMaxSize1024/封

13、裝的打印voiddebugLog(char*logStr)coutlogStrWSAGetLastError()WSAStartuperror);returnFALSE;/先創(chuàng)建套接字綁定本地地址然后開(kāi)始監(jiān)聽(tīng)SOCKETBind_Listen(intnBacklog)SOCKEThSocket=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);if(hSocket=INVALID_SOCKET)debugLog(Bind_Listen-socketerror!);returnINVALID_SOCKET;sockaddr_insaSerAddr;saSerAddr

14、.sin_family=AF_INET;saSerAddr.sin_addr.s_addr=htonl(ADDR_ANY);saSerAddr.sin_port=htons(nSERPort);if(bind(hSocket,(LPSOCKADDR)&saSerAddr,sizeof(saSerAddr)debugLog(Bind_Listen-binderror);closesocket(hSocket);returnINVALID_SOCKET;if(listen(hSocket,nBacklog)=SOCKET_ERROR)closesocket(hSocket);debugLog(Bi

15、nd_Listen-listenerror);returnINVALID_SOCKET;returnhSocket;接受一個(gè)客戶(hù)端連接并返回對(duì)應(yīng)的連接的套接字SOCKETAcceptConnetion(SOCKEThScoket)sockaddr_insaConAddr;intnSize=sizeof(saConAddr);SOCKETsd=accept(hScoket,(LPSOCKADDR)&saConAddr,&nSize);if(sd=INVALID_SOCKET)debugLog(AcceptConnetion-connecterror);returnINVALID_SOCKET;r

16、eturnsd;處理一個(gè)客戶(hù)端的連接，實(shí)現(xiàn)接受和發(fā)送數(shù)據(jù)BOOLClientConFun(SOCKETsd)charBufnBufMaxSize;intnRetByte;/循環(huán)處理數(shù)據(jù)do接受到來(lái)自客戶(hù)端的數(shù)據(jù)nRetByte=recv(sd,Buf,nBufMaxSize,0);if(nRetByte=SOCKET_ERROR)debugLog(ClientConFun-recverror!);returnFALSE;elseif(nRetByte!=0)BufnRetByte=0;cout接收到一條數(shù)據(jù)：Bufendl;intnSend=0;while(nSend0)nSend+=nTem

17、p;elseif(nTemp=SOCKET_ERROR)debugLog(ClientConFun-senderror);returnFALSE;else/send返回0由于此時(shí)sendsend-closeerror);returnFALSE;while(nRetByte!=0);returnTRUE;關(guān)閉一個(gè)連接BOOLCloseConnect(SOCKETsd)首先發(fā)送一個(gè)TCPFIN分段，向?qū)Ψ奖砻饕呀?jīng)完成數(shù)據(jù)發(fā)送if(shutdown(sd,SD_SEND)=SOCKET_ERROR)debugLog(CloseConnect-shutdownerror);returnFALSE;ch

18、arBufnBufMaxSize;intnRetByte;donRetByte=recv(sd,Buf,nBufMaxSize,0);if(nRetByte=SOCKET_ERROR)debugLog(CloseConnect-recverror);break;elseif(nRetByte0)debugLog(CloseConnect錯(cuò)誤的接收數(shù)據(jù));break;while(nRetByte!=0);if(closesocket(sd)=SOCKET_ERROR)debugLog(CloseConnect-closeSocketerror);returnFALSE;returnTRUE;/線程處理業(yè)務(wù)DWORDWINAPIClientThreadFun(LPVOIDlpParam)SOCKETsd=(SOCKET)lpParam;/客戶(hù)端處理if(ClientConFun(sd)=FALSE)/break;/關(guān)閉一個(gè)客戶(hù)端的連接if(CloseConnect(sd)=FALSE)/break;return0;/服務(wù)器主體voidMyTcpSerFun()SOCKEThSocket=Bind_Listen(1);if(hSoc