2013-03-21 37 views
0

我目前正在使用Boost ASIO在客户端服务器TCP/IP应用程序上工作。 客户端使用下面的语句从客户端接收数据时出现异常 - “文件结尾”错误

boost::system::error_code ignored_error; 
boost::asio::write(socket, boost::asio::buffer("Hello World\0"), ignored_error); 

服务器读取此数据作为这样的将数据发送到服务器(从非同步。读取)

boost::asio::async_read(*sock, boost::asio::buffer(buf_server),boost::bind(&ServerRead,boost::asio::placeholders::error)); 

这里就是读数完成

boost::array<char, 158> buf_server; 

void ServerRead(const boost::system::error_code& error) 
{ 
    if(!error) 
    { 
     std::cout << "Message: " << buf_server.data() << std::endl; 
    } 
    else 
    { 
     std::cout << "Error occurred." << error.message() << std::endl; 
    } 
} 

但是,我收到错误“文件结束”。 所以现在我有两个问题

  1. 我该如何解决这个问题。我在这里做错了什么?

  2. 假设我的buf_server只有5个字符而不是158.我怎样才能让我的接收器使用这个缓冲区只读取整个数据而std::cout呢?

回答

0

当您指示应用程序读取158个字节但仅发送12个字节时,应该会发生此行为。要解决此可以发送固定大小的标头,指示该消息的大小,包括在短耳文档中的chat client and server例子展示了如何实现这一点,从客户端实例的摘录:

void handle_connect(const boost::system::error_code& error) 
    { 
    if (!error) 
    { 
     boost::asio::async_read(socket_, 
      boost::asio::buffer(read_msg_.data(), chat_message::header_length), 
      boost::bind(&chat_client::handle_read_header, this, 
      boost::asio::placeholders::error)); 
    } 
    } 

    void handle_read_header(const boost::system::error_code& error) 
    { 
    if (!error && read_msg_.decode_header()) 
    { 
     boost::asio::async_read(socket_, 
      boost::asio::buffer(read_msg_.body(), read_msg_.body_length()), 
      boost::bind(&chat_client::handle_read_body, this, 
      boost::asio::placeholders::error)); 
    } 
    else 
    { 
     do_close(); 
    } 
    } 

    void handle_read_body(const boost::system::error_code& error) 
    { 
    if (!error) 
    { 
     std::cout.write(read_msg_.body(), read_msg_.body_length()); 
     std::cout << "\n"; 
     boost::asio::async_read(socket_, 
      boost::asio::buffer(read_msg_.data(), chat_message::header_length), 
      boost::bind(&chat_client::handle_read_header, this, 
      boost::asio::placeholders::error)); 
    } 
    else 
    { 
     do_close(); 
    } 
    } 

可替换地,或使用更多的外来协议such as HTTP你在哪里阅读,直到遇到\r\n定界符。

相关问题