多线程实现服务器和客户端聊天

1、#include #include #pragma comment(lib,ws2_32.lib)/*定义客户端连接上后的聊天线程函数*/DWORD WINAPI ClientThread(LPVOID lpParam)SOCKET sock = (SOCKET)lpParam;/定义连接客户端的套接字char szBuff2048;/定义接收缓冲区char szMessage2048;/定义发送的消息int ret,nLeft,idx;/nLeft,idx用以控制写缓冲的数据，以保证数据写入正确/提示输入exit退出聊天puts(输入exit可退出聊天n);/进入数据传输循环，即聊天/缺陷是

2、只能一人一句来回对话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;/判断对方发过来的是否为exit退出命令，若是则退出聊天继续监听if(!strcmp(szBuff,exit) printf(对方已经停止聊天!n);printf(服务器正在监听);break;printf(客户：%sn,szBuff);/在控制台打印客户的聊天语句/ 回复

3、 /printf(发送消息:); /服务器输入数据回答客户gets(szMessage);/若发送为空，则传送不说话三字，并提示if(strlen(szMessage)=0)printf(发送不能为空哦n);strcpy(szMessage,不说话!);/传送数据nLeft = strlen(szMessage);idx = 0;/确保写进所有数据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命令，若是则退出聊天继续监听if(!strcmp(szMessage,exit) printf(连接正在断开!n);printf(服务器继续监听n);break;return 0;/主函数int main(int argc, char* argv)WSADATA wsd;/定义WINSOCK32消息结构体SOCKET sServSock;/服务器端的套接字SOCKET sConns;/服务器的各连接HANDLE hThread;/定义处理客户连接的县城DWORD dwThreadI

5、d;/定义线程IDchar szAddress128;/监听的地址struct hostent *host = NULL;/定义本地地址指针sockaddr_in local,client;/分别定义本地，客户端的地址结构int nSockErr;/定义出错信息printf(请你输入监听地址(格式如202.204.118.138):);gets(szAddress);int nAddrLen = sizeof(client);/得到地址结构长度/初始化Winsock32库if(WSAStartup(MAKEWORD(2,2),&wsd) != 0)printf(failed to load w

6、insock!n);return 1;/建立socket对象sServSock = socket(AF_INET,SOCK_STREAM,IPPROTO_IP);/流套接字，面向连接/为socket分配端口地址监听local.sin_family = AF_INET;local.sin_port = htons(5150);/监听端口/若地址出错则监听本机地址if(local.sin_addr.s_addr = inet_addr(szAddress)=INADDR_NONE)puts(所输入的地址不正确，本服务将使用本机地址!);/得到主机名if(gethostname(szAddress,

7、sizeof(szAddress)=SOCKET_ERROR)/得到本机的域名，名称 puts(Cant getting local host name.);/通过主机名得到主机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;/将套接字绑定到本机地址local上if(bi

8、nd(sServSock,(LPSOCKADDR)&local,sizeof(local)=SOCKET_ERROR)nSockErr = WSAGetLastError();printf(bind error:%d!n, nSockErr);return 1;/监听客户连接请求if(listen(sServSock,5)=SOCKET_ERROR)nSockErr =WSAGetLastError();printf(listen error:%dn, nSockErr);return 1;/提示状态printf(服务器启动成功!n);printf(服务器正在监听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连接到了本服务，现在可以聊天了.n,inet_ntoa(client.sin_addr),ntohs(client.sin_port);/创建一个线程用于聊天hThread = CreateT

10、hread(NULL,0,ClientThread, (LPVOID)sConns,0,&dwThreadId);if(hThread = NULL)printf(CreateThread() failed %dn,GetLastError();break;/聊天结束关闭聊天线程，继续监听CloseHandle(hThread);closesocket(sServSock);WSACleanup();return 0;/*客户端*/#includestdafx.h#include#include#pragmacomment(lib,ws2_32.lib)intmain(intargc,char

11、*argv)WSADATAwsd;/定义winsock32信息结构SOCKETsClient;/定义本地套接字charszBuffer2048;/定义接受的缓冲charszMessage2048;/发送的消息charszServer128;/连接的服务器地址，IP地址intret;structsockaddr_inserver;/定义连接的服务器地址structhostent*host=NULL;/定义地址/提示输入连接的服务器地址printf(请输入连接的服务器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对象sClient=socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);if(sClient=INVALID_SOCKET)printf(socket()failed:%dn,WSAGetLastError();Sleep(5000);return1;/定义服务器地址以发送信息server.sin_family=AF_INET;server.si

13、n_port=htons(5150);/端口server.sin_addr.s_addr=inet_addr(szServer);/若没有地址，则将地址设置为本机地址if(server.sin_addr.s_addr=INADDR_NONE)puts(所输入服务器地址不正确，本将使用本机地址!);/得到主机名if(gethostname(szServer,sizeof(szServer)=SOCKET_ERROR)/得到本机的域名，名称puts(Cantgettinglocalhostname.);/通过主机名得到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;/提示当前状态puts(连接成功，现在可以聊天了!n);pu

15、ts(输入exit可退出聊天n);/进入聊天状态while(1)/发送printf(发送消息：);/写入发送信息gets(szMessage);if(strlen(szMessage)=0)printf(发送不能为空哦n);strcpy(szMessage,不说话!);/发送信息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(你已经退出了聊天!);break;/printf(send%dbyten,ret);/接收回复的信息ret=recv(sClient,szBuffer,2048,0