本篇文章给大家分享的是有关基于TCP和多线程的聊天框架代码是什么，小编觉得挺实用的，因此分享给大家学习，希望大家阅读完这篇文章后可以有所收获，话不多说，跟着小编一起来看看吧。
站在用户的角度思考问题，与客户深入沟通，找到漠河网站设计与漠河网站推广的解决方案，凭借多年的经验，让设计与互联网技术结合，创造个性化、用户体验好的作品，建站类型包括：网站制作、成都网站建设、企业官网、英文网站、手机端网站、网站推广、主机域名、雅安服务器托管、企业邮箱。业务覆盖漠河地区。
/**//****************************************************
【服务端】基于TCP，多线程的聊天框架代码评注：非常完整
******************************************************/
#include "stdafx.h"#include #include #pragma comment(lib,"ws2_32.lib")/**//*****************定义客户端连接上后的聊天线程函数************/DWORD WINAPI ClientThread(LPVOID lpParam)
{ SOCKET sock = (SOCKET)lpParam;//定义连接客户端的套接字 char szBuff[2048];//定义接收缓冲区 char szMessage[2048];//定义发送的消息 int ret, nLeft, idx;//nLeft,idx用以控制写缓冲的数据，以保证数据写入正确 //提示输入exit退出聊天 puts("输入\"exit\"可退出聊天\n"); //进入数据传输循环，即聊天 //缺陷是只能一人一句来回对话 while(1)
{ /**////////////////////////// 接收 ///////////////// ret = recv(sock,szBuff,2048,0); if(ret == 0) break; else if(ret == SOCKET_ERROR) { printf("recv() failed:%d\n",WSAGetLastError()); break;
} szBuff[ret] = '\0'; //判断对方发过来的是否为exit退出命令，若是则退出聊天继续监听 if(!strcmp(szBuff,"exit")) { printf("对方已经停止聊天!\n"); printf("服务器正在监听"); break; } printf("客户：%s\n",szBuff);//在控制台打印客户的聊天语句 /**/////////////////////////// 回复 ////////////////// printf("发送消息:"); //服务器输入数据回答客户 gets(szMessage); //若发送为空，则传送‘不说话’三字，并提示 if(strlen(szMessage)==0) { printf("发送不能为空哦\n"); strcpy(szMessage,"不说话!"); } //传送数据 nLeft = strlen(szMessage); idx = 0; //确保写进所有数据 while(nLeft>0) { ret = send(sock,&szMessage[idx],nLeft,0); if(ret == 0) break; else if(ret == SOCKET_ERROR) { printf("send error!%d\n",WSAGetLastError()); 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 dwThreadId;//定义线程ID char szAddress[128];//监听的地址 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 winsock!\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,sizeof(szAddress))==SOCKET_ERROR)//得到本机的域名，名称 { puts("Can't getting local host name."); } //通过主机名得到主机IP地址 host = gethostbyname(szAddress);//得到本地ip if(host) CopyMemory(&local.sin_addr,host->h_addr_list[0], host->h_length); else { printf("gethostbyname() failed:%d\n",WSAGetLastError()); Sleep(5000); return 1; } } //将套接字绑定到本机地址local上 if(bind(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:%d\n", nSockErr); return 1; } //提示状态 printf("服务器启动成功!\n"); printf("服务器正在监听\n"); //进入处理连接循环 while(1) { //若有客户连接，则接受连接 sConns = accept(sServSock,(struct sockaddr *)&client,&nAddrLen); if(sConns == INVALID_SOCKET) { nSockErr = WSAGetLastError(); printf("accept error %d\n",nSockErr); break; } //连接正确则提示可以开始聊天 printf("%s:%d连接到了本服务，现在可以聊天了.\n",inet_ntoa(client.sin_addr),ntohs(client.sin_port)); //创建一个线程用于聊天 hThread = CreateThread(NULL,0,ClientThread, (LPVOID)sConns,0,&dwThreadId); if(hThread == NULL) { printf("CreateThread() failed %d\n",GetLastError()); break; } //聊天结束关闭聊天线程，继续监听 CloseHandle(hThread); } closesocket(sServSock); WSACleanup(); return 0;}
