您现在的位置：程式碼之家 >> 編程語言 > >> C語言 >> VC >> VC++

基於 TCP/IP 的局域網多用戶通信系統設計（四）：多線程通信機制與客戶端設計

編輯：VC++

3.2 通信服務器（續）：多線程模型深度解析

雙線程架構

每個用戶連接成功後，服務器創建兩個緊密協作的線程：

接收線程：創建後處於可執行狀態，循環調用 recv 監聽數據。
發送線程：創建後即掛起（SuspendThread），等待接收線程喚醒發送數據。

兩線程同生共死：任一方異常或連接關閉，雙雙退出。雖簡化了邏輯，但每連接佔用兩線程，限制了最大併發數，需根據硬體資源評估。

線程同步與互斥

因多線程共同操作 info_data，引入互斥量 CMutex m_mutex 保護臨界區：

// 接收線程片段
UINT RecvData(void* cs) {
    SOCKET clientSocket = (SOCKET)cs;
    while(1) {
        numrcv = recv(clientSocket, buffer, MAXBUFLEN, 0);
        buffer[numrcv] = '\0';
        if(strcmp(buffer, "Close!") != 0) { // 普通訊息
            // 遍歷 s_info 查找目標用戶
            for(i=0; i<COUNT; i++) {
                if(po != NULL) {
                    s1 = s_info.GetNext(po);
                    if(s1.pet.Compare(petname) == 0) {
                        m_mutex.Lock();
                        info_data.data = pos;
                        info_data.thread = s1.thread;
                        m_mutex.Unlock();
                        s1.thread->ResumeThread(); // 喚醒發送線程
                        break;
                    }
                }
            }
        } else { // 用戶下線
            // ... 類似加鎖操作，並從 s_info 移除用戶
        }
    }
    closesocketlink((LPVOID)clientSocket);
    AfxEndThread(0, true);
    return 1;
}

// 發送線程片段
UINT SendData(void* cs) {
    SOCKET clientSocket = (SOCKET)cs;
    while(1) {
        if(info_data.data != "Close!") {
            m_mutex.Lock();
            numsnd = send(clientSocket, info_data.data, info_data.data.GetLength(), 0);
            now = info_data.thread;
            m_mutex.Unlock();
            now->SuspendThread(); // 發送完自我掛起
        } else { goto bb; }
    }
    bb: closesocketlink((LPVOID)clientSocket);
    AfxEndThread(0, true);
    return 1;
}