基于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;
}