如何使用 boost asio 读取固定大小的数据包？

Question

我正在使用 boost-asio 进行同步读/写。数据以二进制格式出现，没有边界，长度信息以数据包格式编码。因此，以指定的大小读入很重要。 ip::tcp::iostream 可以吗？有人可以举个例子吗？谢谢。

Answer 1

简单的：

boost::asio::read(socket, buffers, boost::asio::transfer_exactly(your_fixed_size));

Answer 2

我正在开发一个发送不同大小的不同数据的程序。我使用 8 字节的固定标头来编码大小，然后添加数据：

 enum { header_length = 8 }; //const header length

我得到大小（m_outbound_data 是 std::string == 序列化对象）

//give header length    
std::ostringstream header_stream
header_stream << std::setw(header_length) //set a field padding for header  
              << std::hex                 //set next val to hexadecimal
              << m_data_out.m_outbound_data.size(); //write size in hexa

m_data_out.m_outbound_header = header_stream.str(); //m_outbound_head == size in hexa in a std::string

      //m_outbound_header = [ 8 byte size ] 
      //m_outbound_data = [ serialized data ]

      //write all data in the std::vector and send it
      std::vector<boost::asio::const_buffer> buffer;
      buffer.push_back(boost::asio::buffer(m_data_out.m_outbound_header));
      buffer.push_back(boost::asio::buffer(m_data_out.m_outbound_data));

并且为了读取，您需要读取 2 次：第一次读取 8 个字节来获取大小，然后读取向量中的数据并反序列化为对象：

 struct network_data_in {   
  char m_inbound_header[header_length]; //size of data to read  
  std::vector<char> m_inbound_data; // read data    
};

我使用此结构来获取数据，调用 m_inbound_header 上的 read 首先用大小填充缓冲区，然后，在句柄中：

//get size of data
std::istringstream is(std::string(m_data_in.m_inbound_header, header_length));
std::size_t m_inbound_datasize = 0;
is >> std::hex >> m_inbound_datasize;
m_data_in.m_inbound_data.resize(m_inbound_datasize); //resize the vector

然后再次使用缓冲区上的 m_inbound_data 调用 read，读取的结果正是发送的数据
在第二个handle_read中，您只需反序列化数据：

//extract data
std::string archive_data (&(m_data_in.m_inbound_data[0]),m_data_in.m_inbound_data.size());
std::istringstream archive_stream(archive_data);
boost::archive::text_iarchive archive(archive_stream);
archive >> t; //deserialize

希望对您有帮助！

Answer 3

TCP 是一种基于流的协议。这意味着您读取的任何内容都只是字节流。
让我们考虑一个例子：您有一条固定大小的消息，并通过 TCP 发送它。另一端的程序如何读取整条消息？有两种方法，一种是用控制字符包围消息（例如开头为 STX，结尾为 ETX）。开始时，程序将丢弃 STX 之前的所有字符，然后将所有其他字符读入消息缓冲区，直到遇到 ETX。

另一种方法是将消息长度编码在固定大小的标头中（这显然是您的情况）。因此，您能做的最好的事情就是找到一种方法来读取消息长度，解析它并相应地读取剩余字节。