Winsock using send() and FD_WRITE

我是Winsock的新手。我正在编写一个HTTP服务器，我的目标是通过读取和发送块来发送一个大文件。为了优化这个过程，我尝试使用一个非阻塞套接字，在发送当前块的同时从磁盘读取下一个块。

我现在的问题是，我得到一个FD_WRITE消息，即使它似乎缓冲区应该是满的，我的函数从内存中过早地删除相关的数据。我认为这导致我的响应包含的数据少于它们应该包含的数据。send()过早地停止发送，客户端(这是一个众所周知的)接收大约70%的数据。当我使用阻塞套接字时，它工作得很好，只是更长。

我尝试使用Wget，一个简单的HTTP客户端，以便更好地了解正在发生的事情。从我所看到的，当我在使用send()后检查错误时检测到WSAEWOULDBLOCK错误时，数据流会变细。看起来在这些发送过程中，并不是所有的数据都被发送了。

当我在检查FD_WRITE消息后将睡眠时间设置为超过2000ms时，一切都工作了，因为它基本上归结为使用阻塞套接字。我也尝试将时间设置在100-200毫秒左右，但也失败了。事实上，FD_WRITE的条件检查总是在进入循环之前返回valid。

WSAEVENT event = WSACreateEvent();
const int sendBufferSize = 1024 * 64;
int connectionSpeed = 5; //estimated, in MBytes/s
const int sleepTime = sendBufferSize / (connectionSpeed * 1024 * 1024);
size = 0;
const int bufSize = 1024 * 1024 * 35;
int lowerByteIndex = 0;
int upperByteIndex = bufSize;
size = bufSize;
int totalSIZE = 0;
unsigned char* p;
unsigned char* pt;
clock_t t = std::clock();
p = getFileBytesC(resolveLocalPath(path), size, lowerByteIndex, upperByteIndex);
lowerByteIndex += bufSize;
upperByteIndex += bufSize;
totalSIZE += size;
while (upperByteIndex <= fileSize + bufSize)
{
    int ret = send(socket, (char*)p, size, 0);
    pt = getFileBytesC(resolveLocalPath(path), size, lowerByteIndex, upperByteIndex);
    totalSIZE += size;
    lowerByteIndex += bufSize;
    upperByteIndex += bufSize;
    if (ret == SOCKET_ERROR && WSAGetLastError() == WSAEWOULDBLOCK)
    {
        while (SOCKET_ERROR == WSAEventSelect(socket, event, FD_WRITE))
        {
            Sleep(50);
        }
    }
    Sleep(sleepTime); //should be around 30-50ms. Wait for the buffer to be empty
    delete[] p;
    p = pt;
    std::cout << std::endl << (std::clock() - t) / (double)CLOCKS_PER_SEC;
}
send(socket, (char*)p, size, 0);
delete[] p;
std::cout << std::endl << (std::clock() - t) / (double)CLOCKS_PER_SEC ;
if (totalSIZE == fileSize) std::cout << std::endl << "finished transfer. UBI=" << upperByteIndex;
else
{
    std::cout << std::endl << "ERROR: finished transferrnBytes read=" << totalSIZE;
}
Sleep(2000);
closeSocket(socket);