单线程Winsock2群聊服务器无法接收客户端消息问题求助

核心问题：条件判断的赋值错误 #

服务器代码中存在一个致命的语法错误，导致所有Socket事件都被误判为新连接请求，永远不会进入接收客户端消息的分支：

// 错误：使用赋值运算符=而非比较运算符==
if (incomingSocket = server)

这行代码会把server Socket赋值给incomingSocket，条件永远为真，所以无论客户端发送什么消息，服务器都会尝试去接受新连接，完全忽略消息处理逻辑。

修复方法：将赋值运算符改为比较运算符：

if (incomingSocket == server)

其他次要问题及修复 #

1. 循环变量重名冲突 #

服务器处理消息广播时，内层循环使用了和外层循环相同的变量名i，会导致逻辑混乱：

// 外层循环变量
for (int i = 0; i < incoming; i++)
{
    // ...
    // 内层循环重名变量
    for (int i = 0; i < masterConnection.fd_count; i++)
}

修复方法：将内层循环变量改为其他名称，比如j：

for (int j = 0; j < masterConnection.fd_count; j++)
{
    SOCKET sendSock = masterConnection.fd_array[j];
    if (sendSock != server && sendSock != incomingSocket)
    {
        // ... 广播逻辑
    }
}

2. 客户端线程使用不合理 #

客户端每次发送消息都创建新线程接收数据，recv是阻塞调用，如果没有消息到来，线程会一直阻塞，导致用户必须等收到消息才能继续输入。

修复方法：改为启动一个后台线程持续监听消息：

// 客户端main函数修改
int main()
{
    // ... 初始化与连接代码 ...

    cout << "Connected to the server\n";

    // 启动后台接收线程，独立运行
    thread receiveThread(receiveData);
    receiveThread.detach();

    string sendBuffer;
    while (true)
    {
        cout << "Enter a message: ";
        getline(cin, sendBuffer);

        if (send(clientSocket, sendBuffer.c_str(), sendBuffer.length(), 0) == SOCKET_ERROR)
        {
            cerr << "Failed to send Data" << endl;
            break;
        }
        cout << "Data sent to server.\n";
    }

    closesocket(clientSocket);
    WSACleanup();
    return 0;
}

// 修改receiveData为循环监听
void receiveData()
{
    char buffer[1024];
    int bytesRead;
    while (true)
    {
        ZeroMemory(buffer, sizeof(buffer));
        bytesRead = recv(clientSocket, buffer, sizeof(buffer), 0);
        if (bytesRead == SOCKET_ERROR)
        {
            cerr << "Failed to receive data\n";
            break;
        }
        else if (bytesRead == 0)
        {
            cerr << "Server Disconnected\n";
            break;
        }
        else
            cout << "Received: " << buffer << endl;
    }
}

3. 字符串终止符缺失 #

recv接收的数据不会自动添加\0，直接用std::string sendBuffer = receiveBuffer可能导致字符串包含垃圾数据。

修复方法：用实际接收的字节数构造字符串：

std::string sendBuffer(receiveBuffer, bytesReceived);
send(sendSock, sendBuffer.c_str(), sendBuffer.length(), 0);

4. 完善错误处理 #

服务器和客户端的send、recv调用应检查返回值，避免忽略异常情况。比如服务器发送欢迎消息时：

int bytesSent = send(client, welcomeMessage.c_str(), welcomeMessage.length(), 0);
if (bytesSent == SOCKET_ERROR)
{
    std::cerr << "Failed to send welcome message\n";
    closesocket(client);
    FD_CLR(client, &masterConnection);
}

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