欢迎来到入门教程网!

C语言

当前位置:主页 > 软件编程 > C语言 >

c语言socket多线程编程限制客户端连接数

来源:本站原创|时间:2020-01-10|栏目:C语言|点击:

先上一些多线程需要使用的函数定义:

复制代码 代码如下:

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

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


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

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

服务器端程序

主线程代码如下:

复制代码 代码如下:

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

int main()
{
    WSADATA wsaData;
    WSAStartup(MAKEWORD(2, 2), &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].\n", 9000);

    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)+sizeof(char), NULL);       //发送拒绝连接消息给客户端
            printf("***SYS***    REFUSED.\n");
            closesocket(clientsocket);                                     //释放资源
            break;
        }
    }

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

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

    closesocket(s);
    for(int 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)+sizeof(char), 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)+sizeof(char), NULL);
            break;
        }
        printf("***Client***    %s\n", buffer);
    }

    closesocket(*clientsocket);

    return 0;
}



上一篇:C++获取文件哈希值(hash)和获取torrent(bt种子)磁力链接哈希值

栏    目:C语言

下一篇:c语言判断是否素数程序代码

本文标题:c语言socket多线程编程限制客户端连接数

本文地址:https://www.xiuzhanwang.com/a1/Cyuyan/3879.html

网页制作CMS教程网络编程软件编程脚本语言数据库服务器

如果侵犯了您的权利,请与我们联系,我们将在24小时内进行处理、任何非本站因素导致的法律后果,本站均不负任何责任。

联系QQ:835971066 | 邮箱:835971066#qq.com(#换成@)

Copyright © 2002-2020 脚本教程网 版权所有