boost::asio::write() VS 套接字->write_some()答案

【问题标题】：boost::asio::write() VS socket->write_some()boost::asio::write() VS 套接字->write_some()
【发布时间】：2021-09-27 00:24:19
【问题描述】：

我正在努力学习boost::asio，但我对boost::asio::write()、socket->write_some() 有一些问题。从我读到现在的内容，我了解到boost::asio::write 确保所有数据都已传输，而socket->write 没有这样做，因为使用的是操作系统中的send，这并不能保证完全传输。

这是我的client/server 应用程序的一部分。

服务器

void server::session(socket_ptr sock)
{
char data[MAX_SIZE] = {};
bool flag = false;
sprintf(data,"On the server are %d users.",user_vector.size());

//boost::asio::write(*sock, boost::asio::buffer(data, strlen(data)));
sock->write_some(boost::asio::buffer(data, strlen(data)));

cleanMemory(data,strlen(data));
try
{
    for (;;)
    {
        boost::system::error_code error;
        size_t length = sock->read_some(boost::asio::buffer(data), error);
        //boost::asio::write(*sock, boost::asio::buffer(data,strlen(data)));
        cout << std::endl << data;
        cleanMemory(data, strlen(data));
        if (error == boost::asio::error::eof)
        {
            std::vector<user_detail>::iterator it = user_vector.begin();
            for (; it!= user_vector.end();)
            {
                std::pair<socket_ptr, int> user = *it;
                if (user.first == sock)
                {
                    cout << "User " << user.second << " leave server." << std::endl;
                    cout << std::endl << "Connection has been closed." << std::endl;
                    it = user_vector.erase(it);
                    flag = true;
                    break;
                }
                else
                    ++it;
            }
            if (flag)
                break;
        }
    }
}
catch (const std::exception&e) {
    std::cerr << "Error in threead : " << e.what() << endl;
}
}

客户

size_t length = s.read_some(boost::asio::buffer(buf,100)); //OK DATA RECEVIED
    //boost::asio::read(s, boost::asio::buffer(buf, 100));//FAIL TO RECEIVE DATA
    cout.write(buf,strlen(buf));

问题出在客户端。如果我使用：

size_t length = s.read_some(boost::asio::buffer(buf,100));

工作正常，数据已接收，但如果我使用：

boost::asio::read(s, boost::asio::buffer(buf, 100));

数据丢失。

问题：

如果服务器发送数据，例如使用boost::asio::write 客户端需要使用boost::asio::read还是也可以使用socket.read_some()？
boost::Asio::read 和 socket->read_some 之间更确切的联系是什么，为什么只有在我使用 s.read_some(boost::asio::buffer(buf,100)); 时才有效？

【问题讨论】：

标签： c++ boost

【解决方案1】：

boost::asio::read() 将一直读取到

a) 已读取所有 100 个字节，或

b) 有错误，或

c) 存在流结束条件。

这是一个复合操作。这样做的影响之一是它既可以返回错误又可以读取一些数据。

例如，如果读取了 50 个字节，然后流进入 eof 条件，则 bytes_transferred 将为 50，返回的 error_code 将指示文件结束。

对于复合操作，在检查错误之前检查 bytes_transferred 很重要。

【讨论】：