WinSocket聊天程序实例（多线程）

#pragma comment(lib,"Ws2_32.lib") 
#include <stdio.h>
#include <Winsock2.h>
SOCKET sockSrv;//连接所用套节字 
SOCKET sockConn; //监听套接字
SOCKADDR_IN addrSrv;
DWORD WINAPI funA(LPVOID lp);
//定义发送和接收的缓存数组
char sendBuf[50];
char recvBuf[50];

void main(){
    //要求使用的版本
    WORD wVersionRequested;
    //
    WSADATA wsaData;
    int err;
    
    wVersionRequested = MAKEWORD(1,1);
    //初始化WinSock dll库 WSAStartup 函数返回0表示初始化成功
    err = WSAStartup(wVersionRequested,&wsaData);
    //测试版本获取结果
    //printf("%d
",err);
    if(err!=0){
        printf("WinSock初始化失败
");
        return;
        
    }
    
    if(LOBYTE(wsaData.wVersion)!=1||HIBYTE(wsaData.wVersion)!=1){
        WSACleanup();
        return;
    }
    printf("服务器已启动......
");
    
    //创建Socket套接字
    sockSrv = socket(AF_INET,SOCK_STREAM,0);
    //通讯的IP地址 htonl把主机字节转换成网络字节
    addrSrv.sin_addr.S_un.S_addr=htonl(INADDR_ANY);
    //使用IP地址族
    addrSrv.sin_family=AF_INET;
    //通讯的端口号
    addrSrv.sin_port=htons(8888);
    //函数绑定 将套接字与通讯地址建立联系
    bind(sockSrv,(SOCKADDR*)&addrSrv,sizeof(SOCKADDR));
    //建立监听队列（把套接字转换成监听模式）
    listen(sockSrv,5);
    int len=sizeof(SOCKADDR);

    //accept接受客户请求
    sockConn = accept(sockSrv,(SOCKADDR*)&addrSrv,&len);
    
    sprintf(sendBuf,"服务器IP: %s ;连接成功！",inet_ntoa(addrSrv.sin_addr));
    //发送消息
    send(sockConn,sendBuf,strlen(sendBuf)+1,0);    
    
    HANDLE a; 
    DWORD dwT; 
    
    //参数1：使用默认的安全性；参数2：与调用线程一样的栈大小；
    //参数3：线程入口函数地址；参数4：传递给线程的参数；参数5：线程创建标记；参数6：新线程的ID
    a=CreateThread(NULL,0,funA,0,0,&dwT); 
    CloseHandle(a);
    
    //消息循环接收和发送
    while(1){
        //从控制台接收用户输入
        //printf("服务器说：");
        scanf("%s",sendBuf);
        //发送消息到客户端
        send(sockConn,sendBuf,strlen(sendBuf)+1,0);
    }
    closesocket(sockConn);
    //关闭连接和套接字
    WSACleanup();
}

DWORD WINAPI funA(LPVOID lp) 
{    
    while(1){
        //从服务器接收数据显示到控制台
        if(recv(sockConn,recvBuf,50,0) != -1){
            printf("客户端说：%s
",recvBuf);
        }else{
            printf("连接已经中断.....请检查客户端是否连接并重试。");
            system("pause");
            exit(0);
        }
    }
    return 0;
}