Linux服务器持续发数据时Winsock客户端recv阻塞问题求助

场景概述 #

• Linux虚拟机上运行C++服务器，接收文件下载请求后，先发送带Content-Length的类HTTP响应头，再以2KB块为单位通过write发送总大小284678字节的文件数据
• Windows平台开发Winsock客户端，实现发送下载请求、接收文件数据

核心问题 #

• 阻塞Socket模式：接近下载完成时，客户端recv调用持续阻塞（服务器已发完所有数据）
• 非阻塞Socket模式：接近下载完成时，客户端陷入WSAEWOULDBLOCK无限循环

根本原因 #

不管阻塞还是非阻塞模式，核心问题都是客户端没有正确判断文件接收完成的条件：

1. 阻塞模式下，服务器发完数据后若保持连接未主动关闭，客户端recv会一直等待新数据，导致阻塞
2. 非阻塞模式下，客户端未区分“暂时无数据”和“数据已全部接收”，反复调用recv得到WSAEWOULDBLOCK却不终止循环

服务器端若存在write返回值处理不当的情况（比如未检查实际发送字节数，导致部分数据未发完就终止）也可能引发问题，但结合你描述的“服务器已发完数据”，主要问题集中在客户端接收逻辑。

解决方案 #

1. 客户端接收逻辑修正（核心） #

从响应头中解析出Content-Length得到总字节数，累计已接收字节数，当累计值达到总大小后立即停止接收：

• 阻塞模式：每次recv后更新已接收字节数，判断是否达标，达标则退出循环
• 非阻塞模式：除了判断字节数，还要用select/WSAEventSelect等待可读事件，避免因WSAEWOULDBLOCK陷入空循环

2. 服务器端补充优化（推荐） #

• 每次调用write后检查实际发送字节数，若小于待发送字节数，需继续发送剩余数据（write可能因系统缓冲区满仅发送部分数据）
• 文件发送完成后主动调用close关闭Socket，让客户端recv返回0，明确标识连接关闭，辅助判断接收完成

代码修正示例 #

客户端（阻塞模式修正） #

// 先解析响应头，获取Content-Length的值存入totalBytes
unsigned long long totalBytes = 284678;
unsigned long long receivedBytes = 0;
char buffer[2048];
int recvLen;
FILE* localFile = fopen("downloaded.file", "wb");
if (!localFile) { /* 处理文件打开错误 */ }

while (receivedBytes < totalBytes) {
    recvLen = recv(clientSocket, buffer, sizeof(buffer), 0);
    if (recvLen == SOCKET_ERROR) {
        /* 处理recv错误，比如打印WSAGetLastError() */
        break;
    } else if (recvLen == 0) {
        // 服务器主动关闭连接，若未接收完全则判定传输中断
        break;
    }
    // 写入本地文件
    fwrite(buffer, 1, recvLen, localFile);
    receivedBytes += recvLen;
    // 已接收足够字节，直接退出
    if (receivedBytes >= totalBytes) break;
}

fclose(localFile);
closesocket(clientSocket);

客户端（非阻塞模式修正，用select等待） #

unsigned long long totalBytes = 284678;
unsigned long long receivedBytes = 0;
char buffer[2048];
int recvLen;
FILE* localFile = fopen("downloaded.file", "wb");
if (!localFile) { /* 处理文件打开错误 */ }

// 先设置Socket为非阻塞模式
u_long mode = 1;
ioctlsocket(clientSocket, FIONBIO, &mode);

fd_set readFd;
struct timeval tv;
while (receivedBytes < totalBytes) {
    FD_ZERO(&readFd);
    FD_SET(clientSocket, &readFd);
    // 设置1秒超时，避免无限等待
    tv.tv_sec = 1;
    tv.tv_usec = 0;

    int selectRet = select(0, &readFd, NULL, NULL, &tv);
    if (selectRet == SOCKET_ERROR) {
        /* 处理select错误 */
        break;
    } else if (selectRet == 0) {
        // 超时，判定传输中断（可根据业务调整逻辑）
        break;
    }

    if (FD_ISSET(clientSocket, &readFd)) {
        recvLen = recv(clientSocket, buffer, sizeof(buffer), 0);
        if (recvLen == SOCKET_ERROR) {
            int err = WSAGetLastError();
            if (err == WSAEWOULDBLOCK) continue;
            /* 处理其他错误 */
            break;
        } else if (recvLen == 0) {
            // 服务器关闭连接
            break;
        }
        fwrite(buffer, 1, recvLen, localFile);
        receivedBytes += recvLen;
    }
}

fclose(localFile);
closesocket(clientSocket);

服务器端发送逻辑修正 #

// 发送类HTTP响应头
const char* header = "HTTP/1.1 200 OK\r\nContent-Length: 284678\r\n\r\n";
ssize_t headerSent = write(clientSocket, header, strlen(header));
if (headerSent == -1) { /* 处理发送错误 */ }

// 发送文件数据
FILE* fp = fopen("target.file", "rb");
if (!fp) {
    close(clientSocket);
    return;
}

char buffer[2048];
size_t readLen;
unsigned long long sentBytes = 0;
while (sentBytes < 284678 && (readLen = fread(buffer, 1, sizeof(buffer), fp)) > 0) {
    ssize_t writeLen = write(clientSocket, buffer, readLen);
    if (writeLen == -1) {
        /* 处理发送错误 */
        break;
    }
    sentBytes += writeLen;
    // 处理部分发送的情况
    while (writeLen < readLen) {
        ssize_t remaining = readLen - writeLen;
        writeLen = write(clientSocket, buffer + writeLen, remaining);
        if (writeLen == -1) break;
        sentBytes += writeLen;
    }
}

fclose(fp);
// 发送完成后关闭Socket，通知客户端
close(clientSocket);

关键机制说明 #

阻塞Socket模式 #

• recv会一直阻塞，直到有数据可读、连接关闭（返回0）或发生错误（返回SOCKET_ERROR）
• 若服务器发完数据后不关闭连接，客户端必须通过Content-Length判断接收完成，否则recv会无限等待

非阻塞Socket模式 #

• recv会立即返回，无数据时返回WSAEWOULDBLOCK错误
• 不能直接循环调用recv，需用select等机制等待Socket可读事件，同时结合Content-Length判断接收完成，避免空循环

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