非阻塞套接字会丢失 Windows 上的数据

Non-blocking socket loses data on Windows

本文关键字：Windows 数据 套接字      更新时间：2023-10-16

我有一个支持所有连接客户端的非阻塞套接字服务器。它使用多线程，并且可以使用GCC进行交叉编译。

它在 Linux 中完美运行（如我所愿），但是当我尝试在 Windows 中使用它时，当我通过它发送 70MB 的文件时，它会从文件中丢失大约 20MB。

所有套接字

都是非阻塞的，因此对于接收/发送套接字调用，我没有检查/停止。它处于循环中，它发送它收到的内容，它有点充当 Echo 服务器，但它在 Windows 中丢失了数据。我在WSAStartup中使用Winsock 2.2。

怎么了？如何让等待/刷新发送呼叫，但从不阻止 recv 呼叫？（如果这是问题所在）

代码片段：我如何使其不阻塞：

iMode = 1;
ioctlsocket(sock1,FIONBIO, &iMode);
ioctlsocket(sock2,FIONBIO, &iMode);

如何在两个套接字之间发送/接收：

for (;;)
{
    memset(buffer, 0, 8192);
    int count = recv(sock1, buffer, sizeof(buffer), 0);
    receiveResult = WSAGetLastError();
    if (receiveResult == WSAEWOULDBLOCK && count <= 0)
        continue;
    if (count <= 0)
    {
        closesocket(sock1);
        closesocket(sock2);
        return;
    }
    if (count > 0)
    {
        int retval = send(sock2, buffer, count, 0);
    }
}

int count = recv(sock1, buffer, sizeof(buffer), 0);
receiveResult = WSAGetLastError();
if (receiveResult == WSAEWOULDBLOCK && count <= 0)

当调用 recv() 或 send() 时，WSAGetLastError() 只有在返回 -1 （SOCKET_ERROR） 时才返回一个有意义的值，但你也会在返回 0 时检查它。 它们在返回>= 0 时不会为 WSAGetLastError() 设置错误代码。 您需要将这些条件分开。

此外，仅仅因为您已经读取了 X 个字节并不能保证您一次能够发送 X 个字节，因此您需要检查send()是否有WSAEWOULDBLOCK，直到您没有更多数据要发送。

尝试更多类似的东西：

bool keepLooping = true;
do
{
    int count = recv(sock1, buffer, sizeof(buffer), 0);
    if (count > 0)
    {
        // data received...
        char *p = buffer;
        do
        {
            int retval = send(sock2, p, count, 0);
            if (retval > 0)
            {
                p += retval;
                count -= retval;
            }
            else if (retval == 0)
            {
                // peer disconnected...
                keepLooping = false;
            }
            else if (WSAGetLastError() != WSAEWOULDBLOCK)
            {
                // a real error occurred...
                keepLooping = false;
            }
            else
            {
                // peer is not ready to receive...
                // optionally use select() to wait here until it is...
            }
        }
        while ((count > 0) && (keepLooping));
    }
    else if (count == 0)
    {
        // peer disconnected...
        keepLooping = false;
    }
    else if (WSAGetLastError() != WSAEWOULDBLOCK)
    {
        // a real error occurred...
        keepLooping = false;
    }
    else
    {
        // no data is available for reading...
        // optionally use select() to wait here until it is...
    }
}
while (keepLooping);
closesocket(sock1);
closesocket(sock2);
return;
相关文章：