基于TCP和多线程的聊天框架代码是什么
本篇文章给大家分享的是有关基于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;
}
新闻名称:基于TCP和多线程的聊天框架代码是什么
当前网址:http://ybzwz.com/article/pgciii.html