a亚洲精品_精品国产91乱码一区二区三区_亚洲精品在线免费观看视频_欧美日韩亚洲国产综合_久久久久久久久久久成人_在线区

首頁 > 編程 > C > 正文

c語言socket多線程編程限制客戶端連接數

2020-01-26 15:40:41
字體:
來源:轉載
供稿:網友

先上一些多線程需要使用的函數定義:

復制代碼 代碼如下:

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



發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表

圖片精選

主站蜘蛛池模板: 日韩一区二区三区在线观看 | 亚洲a级| 色5月婷婷丁香六月 | 国产永久免费观看 | 日韩欧美大片在线观看 | 亚洲一区 中文字幕 | 一级在线免费视频 | 成人精品一区二区 | 国产91免费在线 | 91亚洲精品国产 | 黄色影片网址 | 国产乱码精品一区二区三区av | 国产一区视频在线 | 天天爱天天操 | 极情综合网| 成人激情视频 | 日韩视频区 | 欧美日韩精品一区二区 | 久久精品天堂 | 久久综合九色综合欧美狠狠 | 国产涩涩 | 国产一区二区精品丝袜 | 色播99| 九九亚洲精品 | 亚洲精品一区二区三区麻豆 | 免费观看日韩 | 欧美日韩网 | 日韩中文字幕免费在线播放 | 伊人免费在线观看高清版 | 亚洲成人av在线 | 91色在线观看 | 黄色的网站在线免费观看 | 亚洲精品一区久久久久久 | av一区二区三区 | 精品日韩欧美一区二区三区 | 亚洲精品一区二三区不卡 | 亚洲三级在线观看 | 精品久| 欧美日韩国产一区二区 | 国产最新网站 | 欧美一级在线视频 |