如何使用recv()在C++套接字中重用超过65000个字节

Question

我正在使用C++在Linux中开发客户端服务器应用程序(TCP).我想同时发送多个65,000字节.在TCP中,最大数据包大小65,535仅为字节.

如何在不丢失的情况下发送整个字节？

以下是我在服务器端的代码.

//Receive the message from client socket
if((iByteCount = recv(GetSocketId(), buffer, MAXRECV, MSG_WAITALL)) > 0) 
{
     printf("\n Received bytes %d\n", iByteCount);

     SetReceivedMessage(buffer);
     return LS_RESULT_OK;
}

如果我使用MSG_WAITALL它需要很长时间来接收字节,那么如何设置标志以便在时间上接收超过100万字节.

编辑:MTU大小为1500字节,但如果为65,535,则为TCP数据包大小的绝对限制.

Answer 1

从上面的评论来看,似乎你不明白recv它是如何工作的,或者它应该如何被使用.

你真的想recv在一个循环中调用,直到你知道已经收到预期的数据量或者你得到一个"零字节读取"结果,这意味着另一端已经关闭了连接.总是,没有例外.

如果您需要同时执行其他操作(可能是使用服务器进程!),那么您可能希望先使用poll或epoll先检查描述符就绪状态.这使您可以在套接字准备就绪时多路复用套接字.

您希望以这种方式执行此操作并且永远不会有任何不同的原因是您不知道数据将如何打包以及数据包将如何(或何时)到达.另外,recv不保证一次读取的数据量.它会在你调用它时提供它在缓冲区中的内容,不多也不少(它可能会阻塞,如果什么也没有,但是你仍然无法保证任何特定数量的数据将在它返回时恢复,它可能仍然返回例如50个字节!).

即使您只发送总共5,000个字节,TCP也可以将其分解为5(或10或20)个数据包,以及recv返回500(或100或20或1)个字节的完全有效行为.每次你打电话的时候.这就是它的工作原理.
TCP保证您发送的任何内容最终都会到达另一端或产生错误.并且,它保证您发送的任何内容都按顺序到达.它不能保证很多.最重要的是,它不保证在任何给定时间都准备好任何特定数量的数据.
你必须为此做好准备,唯一的方法就是recv反复打电话.否则,在某些情况下,您将始终丢失数据.

MSG_WAITALL原则上应该按照你期望的方式工作,但这是不好的行为,并且不能保证工作.如果套接字(或网络堆栈中的某些其他结构)针对软限制或硬限制运行,则它可能不会,并且可能无法满足您的请求.一些限制也是模糊不清的.例如,由于实现细节,数量SO_RCVBUF必须是您在Linux下期望接收的数量的两倍.

服务器应用程序的正确行为绝不应该依赖于诸如"它适合接收缓冲区"之类的假设.原则上,您的应用程序需要准备好使用1千字节的接收缓冲区接收数TB的数据,如果需要,可以一次接收1字节的数据块.较大的接收缓冲区将使其更高效,但就是这样......它仍然必须以任何方式工作.

事实上,你只看到一些"巨大"限制的失败只是运气(或者更确切地说,运气不好).事实上它显然"工作正常"达到这个限制表明你所做的是正确的,但事实并非如此.这是一个不吉利的巧合,它的工作原理.

编辑:
根据以下评论的要求,这可能是这样的(代码显然未经测试,警告经理.)

std::vector<char> result;
int size;

char recv_buf[250];

for(;;)
{
    if((size = recv(fd, recv_buf, sizeof(recv_buf), 0)) > 0)
    {
        for(unsigned int i = 0; i < size; ++i)
            result.push_back(recv_buf[i]);
    }
    else if(size == 0)
    {
        if(result.size() < expected_size)
        {
            printf("premature close, expected %u, only got %u\n", expected_size, result.size());
        }
        else
        {
            do_something_with(result);
        }
        break;
    }
    else
    {
        perror("recv");
        exit(1);
    }
}

这将获得你想要的任何数量的数据(或者在分配数百个MiB的向量之后operator new抛出bad_alloc,但这是一个不同的故事...).

如果你想处理多个连接,你需要添加poll或者epoll或者kqueue类似的功能(或...... fork),我将把它作为读者的练习.