发送大数据时提升数据包之间丢失的asio tcp数据

Question

我尝试使用 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), [this, 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);
        }
    });

Answer 1

评论者已经发现了问题：您应该重复使用 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 tcp数据

Boost asio tcp data lost between packet when sending large data

c++

sockets

tcp

boost-asio

asio