在发送大数据时，在数据包之间丢失Boost asio-tcp数据

Question

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

我将数据分割成16000大小的块，并使用async_write_some发送它们。我在客户端中使用async_read或sync_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();
});
}