C Socket初探 - 参加多线程支撑,限制最大接入客户端个数

    添加时间:2013-7-29 点击量:

    先上一些多线程须要应用的函数定义:



    DWORD WINAPI ProcessClientRequests(LPVOID lpParam)  //新线程将会履行的函数定义
    
    {
    return 0;
    }

    HANDLE handler
    =CreateThread(NULL, 0, ProcessClientRequests, &clientsocket, 0, NULL); //这里斗劲简单,&clientsocket是个指针,是从主线程传入新线程的参数


    WaitForMultipleObjects(MAXCLIENTS, threads, TRUE, INFINITE);
    //用来梗阻主线程,直到所有创建的子线程都完成任务为止,才持续履行后面的代码

    forint i=0;i<MAXCLIENTS; i++
    {
    CloseHandle(threads[i]);
    //创建的每个子线程的HANDLE都邑被保存在HANDLE数组中,这个函数用于封闭各个handle所对应的线程空间
    }



    先附上C Socket初探这篇文章的url


    开端,客户端法度没有任何批改,是以此处略(请看C Socket初探中代码所示)



    办事器端法度


    主线程代码如下:



    #define MAXCLIENTS 3           //宏定义,最多3个客户端连接
    

    int main()
    {
    WSADATA wsaData;
    WSAStartup(MAKEWORD(
    22), &wsaData);
    HANDLE threads[MAXCLIENTS];

    SOCKET s
    =socket(PF_INET, SOCK_STREAM, IPPROTO_TCP);

    sockaddr_in sockaddr;
    sockaddr.sin_family
    =PF_INET;
    sockaddr.sin_addr.S_un.S_addr
    =inet_addr(127.0.0.1);
    sockaddr.sin_port
    =htons(9000);
    bind(s, (SOCKADDR
    )&sockaddr, sizeof(SOCKADDR));

    listen(s,
    1);

    printf(
    listening on port [%d].\n9000);

    int existingClientCount=0;
    while(TRUE)
    {
    SOCKADDR clientAddr;
    int size=sizeof(SOCKADDR);

    SOCKET clientsocket;
    clientsocket
    =accept(s, &clientAddr, &size);
    printf(
    SYS New client touched.\n);

    if(existingClientCount<MAXCLIENTS) //断定是否已经超出最大连接数了
    {
    threads[existingClientCount
    ++]=CreateThread(NULL, 0, ProcessClientRequests, &clientsocket, 0, NULL); //启动新线程,并且将socket传入
    }
    else
    {
    char msg=Exceeded Max incoming requests, will refused this connect!\r\n;
    send(clientsocket, msg, strlen(msg)
    +sizeofchar), NULL); //发送拒绝连接消息给客户端
    printf(
    SYS REFUSED.\n);
    closesocket(clientsocket); //开释资料
    break;

    }
    }

    printf(
    Maximize clients occurred for d%.\r\n, MAXCLIENTS);

    WaitForMultipleObjects(MAXCLIENTS, threads, TRUE, INFINITE); //守候所有子线程,直到完成为止

    closesocket(s);
    forint i=0;i<MAXCLIENTS; i++
    {
    CloseHandle(threads[i]); //清理线程资料
    }

    WSACleanup();

    printf(
    Cleared all.\r\n);

    getchar();

    exit(
    0);
    }


    子线程函数定义



    DWORD WINAPI ProcessClientRequests(LPVOID lpParam)
    
    {
    SOCKET
    clientsocket=(SOCKET)lpParam; //这里须要强迫转换,重视:指针类型的

    char msg=Hello, my client.\r\n;
    send(
    clientsocket, msg, strlen(msg)+sizeofchar), NULL);
    printf(
    SYS HELLO.\n);

    while(TRUE)
    {
    char buffer[MAXBYTE]={0};
    recv(
    clientsocket, buffer, MAXBYTE, NULL);
    if(strcmp(buffer, exit)==0
    {
    char msg_bye=Bye.\r\n;
    send(
    clientsocket, msg_bye, strlen(msg_bye)+sizeofchar), NULL);
    break;
    }
    printf(
    Client %s\n, buffer);
    }

    closesocket(
    clientsocket);

    return 0;
    }





    运行结果图:





    读书,不要想着实用,更不要有功利心。读书只为了自身的修养。邂逅一本好书如同邂逅一位知己,邂逅一个完美之人。有时心生敬意,有时怦然心动。仿佛你心底埋藏多年的话,作者替你说了出来,你们在时光深处倾心相遇的一瞬间,情投意合,心旷神怡。
    分享到: