资源描述：
《多线程实现服务器和客户端聊天》由会员上传分享，免费在线阅读，更多相关内容在行业资料-天天文库。
1、#include#include#pragmacomment(lib,"ws2_32.lib")/*****************定义客户端连接上后的聊天线程函数************/DWORDWINAPIClientThread(LPVOIDlpParam){SOCKETsock=(SOCKET)lpParam;//定义连接客户端的套接字charszBuff[2048];//定义接收缓冲区charszMessage[2048];//定义发送的消息intret,nLeft,idx;//nL
2、eft,idx用以控制写缓冲的数据，以保证数据写入正确//提示输入exit退出聊天puts("输入"exit"可退出聊天");//进入数据传输循环，即聊天//缺陷是只能一人一句来回对话while(1){/////////////////////////接收/////////////////ret=recv(sock,szBuff,2048,0);if(ret==0)break;elseif(ret==SOCKET_ERROR){printf("recv()failed:%d",WSAGetLastError());break
3、;}szBuff[ret]=' ';//判断对方发过来的是否为exit退出命令，若是则退出聊天继续监听if(!strcmp(szBuff,"exit")){printf("对方已经停止聊天!");printf("服务器正在监听");break;}printf("客户：%s",szBuff);//在控制台打印客户的聊天语句//////////////////////////回复//////////////////printf("发送消息:");//服务器输入数据回答客户gets(szMessage);//若发送为空，则传送‘不说
4、话’三字，并提示if(strlen(szMessage)==0){printf("发送不能为空哦");strcpy(szMessage,"不说话!");}//传送数据nLeft=strlen(szMessage);idx=0;//确保写进所有数据while(nLeft>0){ret=send(sock,&szMessage[idx],nLeft,0);if(ret==0)break;elseif(ret==SOCKET_ERROR){printf("senderror!%d",WSAGetLastError());break;}
5、nLeft-=ret;idx+=ret;}//判断szMessage是否为exit命令，若是则退出聊天继续监听if(!strcmp(szMessage,"exit")){printf("连接正在断开!");printf("服务器继续监听");break;}}return0;}//主函数intmain(intargc,char*argv[]){WSADATAwsd;//定义WINSOCK32消息结构体SOCKETsServSock;//服务器端的套接字SOCKETsConns;//服务器的各连接HANDLEhThread;//定义
6、处理客户连接的县城DWORDdwThreadId;//定义线程IDcharszAddress[128];//监听的地址structhostent*host=NULL;//定义本地地址指针sockaddr_inlocal,client;//分别定义本地，客户端的地址结构intnSockErr;//定义出错信息printf("请你输入监听地址(格式如202.204.118.138):");gets(szAddress);intnAddrLen=sizeof(client);//得到地址结构长度//初始化Winsock32库if(WSASta
7、rtup(MAKEWORD(2,2),&wsd)!=0){printf("failedtoloadwinsock!");return1;}//建立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(szA
8、ddress))==INADDR_NONE){puts("所输入的地址不正确，本服务将使用本机地址!");//得到主机名if(gethostname(szAddress,sizeof(szAddress))
