多線程實(shí)現(xiàn)服務(wù)器和客戶端聊天

1、#include #include #pragma comment(lib,ws2_32.lib)/*定義客戶端連接上后的聊天線程函數(shù)*/DWORD WINAPI ClientThread(LPVOID lpParam)SOCKET sock = (SOCKET)lpParam;/定義連接客戶端的套接字char szBuff2048;/定義接收緩沖區(qū)char szMessage2048;/定義發(fā)送的消息int ret,nLeft,idx;/nLeft,idx用以控制寫緩沖的數(shù)據(jù)，以保證數(shù)據(jù)寫入正確/提示輸入exit退出聊天puts(輸入exit可退出聊天n);/進(jìn)入數(shù)據(jù)傳輸循環(huán)，即聊天/缺陷是

2、只能一人一句來回對(duì)話while(1)/ 接收 /ret = recv(sock,szBuff,2048,0);if(ret = 0) break;else if(ret = SOCKET_ERROR)printf(recv() failed:%dn,WSAGetLastError();break;szBuffret = 0;/判斷對(duì)方發(fā)過來的是否為exit退出命令，若是則退出聊天繼續(xù)監(jiān)聽if(!strcmp(szBuff,exit) printf(對(duì)方已經(jīng)停止聊天!n);printf(服務(wù)器正在監(jiān)聽);break;printf(客戶：%sn,szBuff);/在控制臺(tái)打印客戶的聊天語句/ 回復(fù)

3、 /printf(發(fā)送消息:); /服務(wù)器輸入數(shù)據(jù)回答客戶gets(szMessage);/若發(fā)送為空，則傳送不說話三字，并提示if(strlen(szMessage)=0)printf(發(fā)送不能為空哦n);strcpy(szMessage,不說話!);/傳送數(shù)據(jù)nLeft = strlen(szMessage);idx = 0;/確保寫進(jìn)所有數(shù)據(jù)while(nLeft0)ret = send(sock,&szMessageidx,nLeft,0);if(ret = 0)break;else if(ret = SOCKET_ERROR)printf(send error!%dn,WSAGetL

4、astError();break;nLeft-=ret;idx +=ret;/判斷szMessage是否為exit命令，若是則退出聊天繼續(xù)監(jiān)聽if(!strcmp(szMessage,exit) printf(連接正在斷開!n);printf(服務(wù)器繼續(xù)監(jiān)聽n);break;return 0;/主函數(shù)int main(int argc, char* argv)WSADATA wsd;/定義WINSOCK32消息結(jié)構(gòu)體SOCKET sServSock;/服務(wù)器端的套接字SOCKET sConns;/服務(wù)器的各連接HANDLE hThread;/定義處理客戶連接的縣城DWORD dwThreadI

5、d;/定義線程IDchar szAddress128;/監(jiān)聽的地址struct hostent *host = NULL;/定義本地地址指針sockaddr_in local,client;/分別定義本地，客戶端的地址結(jié)構(gòu)int nSockErr;/定義出錯(cuò)信息printf(請(qǐng)你輸入監(jiān)聽地址(格式如202.204.118.138):);gets(szAddress);int nAddrLen = sizeof(client);/得到地址結(jié)構(gòu)長度/初始化Winsock32庫if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)printf(failed to load w

6、insock!n);return 1;/建立socket對(duì)象sServSock = socket(AF_INET,SOCK_STREAM,IPPROTO_IP);/流套接字，面向連接/為socket分配端口地址監(jiān)聽local.sin_family = AF_INET;local.sin_port = htons(5150);/監(jiān)聽端口/若地址出錯(cuò)則監(jiān)聽本機(jī)地址if(local.sin_addr.s_addr = inet_addr(szAddress)=INADDR_NONE)puts(所輸入的地址不正確，本服務(wù)將使用本機(jī)地址!);/得到主機(jī)名if(gethostname(szAddress,

7、sizeof(szAddress)=SOCKET_ERROR)/得到本機(jī)的域名，名稱 puts(Cant getting local host name.);/通過主機(jī)名得到主機(jī)IP地址host = gethostbyname(szAddress);/得到本地ipif(host)CopyMemory(&local.sin_addr,host-h_addr_list0,host-h_length);elseprintf(gethostbyname() failed:%dn,WSAGetLastError();Sleep(5000);return 1;/將套接字綁定到本機(jī)地址local上if(bi

8、nd(sServSock,(LPSOCKADDR)&local,sizeof(local)=SOCKET_ERROR)nSockErr = WSAGetLastError();printf(bind error:%d!n, nSockErr);return 1;/監(jiān)聽客戶連接請(qǐng)求if(listen(sServSock,5)=SOCKET_ERROR)nSockErr =WSAGetLastError();printf(listen error:%dn, nSockErr);return 1;/提示狀態(tài)printf(服務(wù)器啟動(dòng)成功!n);printf(服務(wù)器正在監(jiān)聽n);/進(jìn)入處理連接循環(huán)whi

9、le(1)/若有客戶連接，則接受連接sConns = accept(sServSock,(struct sockaddr *)&client,&nAddrLen);if(sConns = INVALID_SOCKET)nSockErr = WSAGetLastError();printf(accept error %dn,nSockErr);break;/連接正確則提示可以開始聊天printf(%s:%d連接到了本服務(wù)，現(xiàn)在可以聊天了.n,inet_ntoa(client.sin_addr),ntohs(client.sin_port);/創(chuàng)建一個(gè)線程用于聊天hThread = CreateT

10、hread(NULL,0,ClientThread, (LPVOID)sConns,0,&dwThreadId);if(hThread = NULL)printf(CreateThread() failed %dn,GetLastError();break;/聊天結(jié)束關(guān)閉聊天線程，繼續(xù)監(jiān)聽CloseHandle(hThread);closesocket(sServSock);WSACleanup();return 0;/*客戶端*/#includestdafx.h#include#include#pragmacomment(lib,ws2_32.lib)intmain(intargc,char

11、*argv)WSADATAwsd;/定義winsock32信息結(jié)構(gòu)SOCKETsClient;/定義本地套接字charszBuffer2048;/定義接受的緩沖charszMessage2048;/發(fā)送的消息charszServer128;/連接的服務(wù)器地址，IP地址intret;structsockaddr_inserver;/定義連接的服務(wù)器地址structhostent*host=NULL;/定義地址/提示輸入連接的服務(wù)器地址printf(請(qǐng)輸入連接的服務(wù)器IP地址(如：202.204.118.138):);gets(szServer);/初始winsock庫if(WSAStartup(

12、MAKEWORD(2,2),&wsd)!=0)printf(FailedtoloadWinsocklibrary!n);Sleep(5000);return1;/strcpy(szMessage,我是*);/建立socket對(duì)象sClient=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);if(sClient=INVALID_SOCKET)printf(socket()failed:%dn,WSAGetLastError();Sleep(5000);return1;/定義服務(wù)器地址以發(fā)送信息server.sin_family=AF_INET;server.si

13、n_port=htons(5150);/端口server.sin_addr.s_addr=inet_addr(szServer);/若沒有地址，則將地址設(shè)置為本機(jī)地址if(server.sin_addr.s_addr=INADDR_NONE)puts(所輸入服務(wù)器地址不正確，本將使用本機(jī)地址!);/得到主機(jī)名if(gethostname(szServer,sizeof(szServer)=SOCKET_ERROR)/得到本機(jī)的域名，名稱puts(Cantgettinglocalhostname.);/通過主機(jī)名得到IPhost=gethostbyname(szServer);if(host=N

14、ULL)printf(Unabletoresolveserver:%sn,szServer);Sleep(5000);return1;CopyMemory(&server.sin_addr,host-h_addr_list0,host-h_length);/建立連接if(connect(sClient,(structsockaddr*)&server,sizeof(server)=SOCKET_ERROR)printf(connect()failed:%dn,WSAGetLastError();Sleep(5000);return1;/提示當(dāng)前狀態(tài)puts(連接成功，現(xiàn)在可以聊天了!n);pu

15、ts(輸入exit可退出聊天n);/進(jìn)入聊天狀態(tài)while(1)/發(fā)送printf(發(fā)送消息：);/寫入發(fā)送信息gets(szMessage);if(strlen(szMessage)=0)printf(發(fā)送不能為空哦n);strcpy(szMessage,不說話!);/發(fā)送信息ret=send(sClient,szMessage,strlen(szMessage),0);if(ret=0)elseif(ret=SOCKET_ERROR)printf(send()failed:%dn,WSAGetLastError();Sleep(5000);/判斷輸入信息是否為exit命令，若是則退出if(!strcmp(szMessage,exit)printf(你已經(jīng)退出了聊天!);break;/printf(send%dbyten,ret);/接收回復(fù)的信息ret=recv(sClient,szBuffer,2048,0