首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >boost::asio::write() VS socket->write_some()

boost::asio::write() VS socket->write_some()
EN

Stack Overflow用户
提问于 2017-09-21 07:40:46
回答 1查看 1.9K关注 0票数 2

我正在努力学习boost::asio,我和boost::asio::write()socket->write_some()有一些问题。从我所读到的到现在,我了解到boost::asio::write确保所有数据都是传输的,而socket->write没有这样做,因为它使用的是来自操作系统的send,这并不能保证完整的传输。

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

服务器

代码语言:javascript
复制
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;
}
}

客户端

代码语言:javascript
复制
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));

问题在客户端。如果我用:

代码语言:javascript
复制
size_t length = s.read_some(boost::asio::buffer(buf,100));

Works和data是recevide,但如果我使用:

代码语言:javascript
复制
boost::asio::read(s, boost::asio::buffer(buf, 100));

数据丢失了。

问题:

  1. 如果服务器发送数据,例如使用boost::asio::write 客户端需要使用boost::asio::read或也可以使用socket.read_some()
  2. 更确切地说,boost::Asio::readsocket->read_some之间的连接是什么?为什么只有当我使用s.read_some(boost::asio::buffer(buf,100));时才能做到这一点?
EN

回答 1

Stack Overflow用户

回答已采纳

发布于 2017-09-21 07:50:55

boost::asio::read()会一直读到

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

( b)有错误,或

( c)有一种断流状态.

这是一种复合操作。其影响之一是,它既可以返回一个错误,也可以读取一些数据。

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

对于复合操作,在检查错误之前检查bytes_transferred非常重要。

票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/46338147

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档