C++ Socket中listen/accept阻塞下多客户端连接问题咨询

嘿，我一眼就揪出问题啦！你的代码现在有个致命的阻塞问题：当第一个客户端连接后，主线程会直接进入GameStart()函数，而这个函数是持续收发数据包直到客户端断开的循环逻辑，这就导致主线程完全被占用，根本没法回到accept()语句去接受第二个客户端的连接请求。

核心问题拆解 #

你的当前流程是：

1. 主线程调用listen()监听端口
2. 第一个客户端连接，主线程accept()拿到client_socket
3. 主线程调用GameStart()，陷入循环处理该客户端的收发，再也不执行后续的accept()
4. 第二个客户端发起连接请求，服务器主线程根本没在accept()上等待，自然无法建立连接

解决方案：用多线程实现并发处理 #

解决思路很简单：主线程只负责接受连接，把每个客户端的处理逻辑丢给独立的子线程，这样主线程就能立刻回到accept()等待下一个客户端。

下面是修改后的代码示例（两种方案，选你顺手的）：

方案1：用POSIX线程（pthread库）

#include <pthread.h>
#include <unistd.h>  // 用于close()

// 线程处理函数：负责单个客户端的GameStart逻辑
void* handleClientConnection(void* arg) {
    int clientSocket = *(static_cast<int*>(arg));
    delete static_cast<int*>(arg);  // 释放传递参数的内存

    // 处理该客户端的收发逻辑
    GameStart(clientSocket);  // 这里假设你可以把client_socket作为参数传入GameStart，原代码的clients参数可能是笔误？

    // 客户端断开后，关闭socket并回收资源
    close(clientSocket);
    return nullptr;
}

int main() {
    // ... 前面创建server_socket、bind的代码省略 ...

    if (listen(server_socket, 50) < 0) { 
        perror("listen"); 
        exit(1); 
    } 

    while (1) { 
        socklen_t clientAddrSize = sizeof(client_addr);
        int client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &clientAddrSize); 

        if (client_socket < 0) {
            perror("accept failed");
            continue;
        }

        // 保存客户端socket（注意：如果多线程操作connection容器，需要加互斥锁！）
        connection.push_back(client_socket); 

        // 创建子线程处理该客户端
        pthread_t threadId;
        int* socketPtr = new int(client_socket);
        if (pthread_create(&threadId, nullptr, handleClientConnection, socketPtr) != 0) {
            perror("failed to create thread");
            close(client_socket);
            connection.pop_back();
            continue;
        }

        // 分离线程：让系统自动回收线程资源，不需要主线程等待
        pthread_detach(threadId);

        clients++; 
    } 
}

方案2：用C++11及以上的std::thread（更现代的方式）

#include <thread>
#include <unistd.h>

// 处理单个客户端的函数
void handleClientConnection(int clientSocket) {
    GameStart(clientSocket);
    close(clientSocket);
}

int main() {
    // ... 前面创建server_socket、bind的代码省略 ...

    if (listen(server_socket, 50) < 0) { 
        perror("listen"); 
        exit(1); 
    } 

    while (1) { 
        socklen_t clientAddrSize = sizeof(client_addr);
        int client_socket = accept(server_socket, (struct sockaddr*)&client_addr, &clientAddrSize); 

        if (client_socket < 0) {
            perror("accept failed");
            continue;
        }

        connection.push_back(client_socket); 

        // 创建并分离线程，直接传入client_socket
        std::thread(handleClientConnection, client_socket).detach();

        clients++; 
    } 
}

额外注意事项 #

• 线程安全：如果connection容器会被多个线程修改（比如子线程断开后从容器移除），一定要用std::mutex或者pthread互斥锁来保护，避免数据竞争。
• 资源回收：每个客户端断开后，记得关闭对应的client_socket，避免文件句柄泄漏。
• GameStart适配：确保GameStart()函数可以接收单个客户端的socket作为参数，原代码的clients参数看起来像是客户端计数，可能需要调整函数逻辑。

内容的提问来源于stack exchange，提问作者dakvamir