发送大数据时增强数据包之间丢失的asio tcp数据

问题描述

我尝试使用boost的asio库从服务器向客户端发送大数据（1mb +）。

我将数据分成大小为16000的块，并使用 async_write_some 发送它们。我在客户端中使用 async_read 或 async_read_some 读取数据。

当服务器和客户端都是我的本地计算机时，一切正常，我可以发送10mb +的数据而没有任何问题。

当我使用其他机器发送数据时，小于1mb的数据就可以了。但是，当数据大小为1mb +时，客户端读取数据时，块之间会丢失数据。我正在使用以太网电缆连接服务器和客户端（网络确实可靠）。

当我在发送以下块之间设置超时时：

std::this_thread::sleep_for(30ms)

客户可以毫无损失地获取全部数据。

有人可以给我一些提示吗，我该如何纠正错误？ TCP要求在任何情况下都不得丢失任何数据。

编辑：这是发送逻辑

void SendData(const char* data,int size) {
    const int tr_size = std::min(CHUNK_SIZE,size);
    socket_->async_write_some(asio::buffer(data,tr_size),[this,data = data + tr_size,size = size - tr_size]
    (const std::error_code &error,size_t bytes_transferred){
        if(!error && size > 0) {
            SendData(data,size);
        } else if(socket_ && socket_->is_open()) {
            socket_->close();
        }
    });
}

这是接收逻辑

    void ReceiveData(char* data,size_t size)
{
    socket_.async_read_some(asio::buffer(data,size),data,size]
    (const std::error_code &error,size_t bytes_transferred) mutable{
        if(!error) {
            assert(size >= bytes_transferred);
            size -= bytes_transferred;
            data += bytes_transferred;
        }
        if(error) {
            return;
        }
        if(size > 0) {
            ReceiveData(data,size);
        }
    });

解决方法

评论者已经发现了问题：您应该重复使用write_some，直到发送完整的缓冲区为止。

当然，这项任务是如此普遍，为什么不使用asio::async_write呢？

void SendData(const char* data,int size) {
    const int tr_size = std::min(CHUNK_SIZE,size);
    async_write(*socket_,asio::buffer(data,tr_size),[this,data = data + tr_size,size = size - tr_size]
        (std::error_code error,size_t /*bytes_transferred*/){
            if (error) {
                std::cerr << "async_write: " << error.message() << std::endl;
            }
            socket_->close();
        });
}

asio boost-asio c++sockets