19.7 Boost Asio 传输序列化数据

简介: 序列化和反序列化是指将数据结构或对象转换为一组字节,以便在需要时可以将其存储在磁盘上或通过网络传输,并且可以在需要时重新创建原始对象或数据结构。序列化是将内存中的对象转换为字节的过程。在序列化期间,对象的状态被编码为一组字节,并可以保存或传输到另一个位置。序列化后的字节可以在之后进行反序列化,以将对象重建为在序列化之前的状态。反序列化则是将字节序列重新转换为对象或数据结构的过程。在反序列化期间,字节被反转回原始对象的状态,以便它可以被使用或操作。

序列化和反序列化是指将数据结构或对象转换为一组字节,以便在需要时可以将其存储在磁盘上或通过网络传输,并且可以在需要时重新创建原始对象或数据结构。

序列化是将内存中的对象转换为字节的过程。在序列化期间,对象的状态被编码为一组字节,并可以保存或传输到另一个位置。序列化后的字节可以在之后进行反序列化,以将对象重建为在序列化之前的状态。

反序列化则是将字节序列重新转换为对象或数据结构的过程。在反序列化期间,字节被反转回原始对象的状态,以便它可以被使用或操作。

在Boost库中,提供了text_oarchivetext_iarchive于将C对象序列化为文本格式并将其反序列化回去,使用text_oarchive可以将C对象以可读文本形式输出,以便在文件或网络上进行存储或传输,与之对应的text_iarchive则可以将先前序列化的文本格式数据还原为C对象。

首先来看服务端代码,在代码中我们定义一个自定义MyDate结构体,该结构体内包含了一个serialize该函数适用于序列化与反序列化时使用的,当我们调用struct_load函数时,就会触发这个序列化方法,从而将接收到的序列化数据包反序列化为对应的结构体变量,这样我们就可以自由的解析内部参数。

#include <iostream>
#include <sstream>
#include <boost/asio.hpp>

#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>

using namespace std;
using namespace boost::asio;

typedef struct MyDate
{
   
   
  unsigned int m_day;
  unsigned int m_month;
  unsigned int m_year;

  MyDate(int d, int m, int y)
  {
   
   
    m_day = d;
    m_month = m;
    m_year = y;
  }
  MyDate()
  {
   
   
    m_day = 0;
    m_month = 0;
    m_year = 0;
  }

  template<typename Archive>
  void serialize(Archive& archive, const unsigned int version)
  {
   
   
    archive & BOOST_SERIALIZATION_NVP(m_day);
    archive & BOOST_SERIALIZATION_NVP(m_month);
    archive & BOOST_SERIALIZATION_NVP(m_year);
  }
}MyDate;

MyDate struct_load(std::string load_string)
{
   
   
  MyDate item;
  std::istringstream is(load_string);
  boost::archive::text_iarchive archive(is);

  archive >> item;
  return item;
}

int main(int argc, char* argv[])
{
   
   
  io_service io_service;
  ip::tcp::acceptor acceptor(io_service, ip::tcp::endpoint(ip::tcp::v4(), 6666));
  ip::tcp::socket socket(io_service);

  acceptor.accept(socket);
  boost::system::error_code error_code;

  // 接收序列化后的数据
  char recv_buffer[8196] = {
   
    0 };
  socket.read_some(boost::asio::buffer(recv_buffer, 8196), error_code);

  // 反序列化接收到的数据
  MyDate ptr;
  ptr = struct_load(recv_buffer);
  std::cout << "反序列化: " << ptr.m_year << std::endl;

  std::system("pause");
  return 0;
}

接着我们来分析一下客户端代码实现,对于客户端而言我们同样需要定义一个完全一致的MyDate结构体,当调用struct_save函数时则会将传入的结构体参数序列化为一个字符串,此时通过调用write_some即可将压缩后的结构体传输给服务端。

#include <iostream>
#include <sstream>
#include <string>
#include <boost/asio.hpp>

#include <boost/archive/text_oarchive.hpp>
#include <boost/archive/text_iarchive.hpp>

using namespace std;
using namespace boost::asio;

typedef struct MyDate
{
   
   
  unsigned int m_day;
  unsigned int m_month;
  unsigned int m_year;

  MyDate(int d, int m, int y)
  {
   
   
    m_day = d;
    m_month = m;
    m_year = y;
  }
  MyDate()
  {
   
   
    m_day = 0;
    m_month = 0;
    m_year = 0;
  }

  template<typename Archive>
  void serialize(Archive& archive, const unsigned int version)
  {
   
   
    archive & BOOST_SERIALIZATION_NVP(m_day);
    archive & BOOST_SERIALIZATION_NVP(m_month);
    archive & BOOST_SERIALIZATION_NVP(m_year);
  }
}MyDate;

std::string struct_save(MyDate *ptr)
{
   
   
  std::ostringstream os;
  boost::archive::text_oarchive archive(os);
  archive & BOOST_SERIALIZATION_NVP(*ptr);

  std::string content = os.str();
  return content;
}

int main(int argc, char* argv[])
{
   
   

  io_service io_service;
  ip::tcp::socket socket(io_service);
  ip::tcp::endpoint ep(ip::address_v4::from_string("127.0.0.1"), 6666);

  boost::system::error_code error_code;
  socket.connect(ep, error_code);

  // 序列化为字符串
  MyDate save_data(12, 7, 1997);
  std::string save_string = struct_save(&save_data);
  std::cout << "序列化后: " << save_string << std::endl;

  // 发送给服务端
  socket.write_some(boost::asio::buffer(save_string), error_code);

  std::system("pause");
  return 0;
}

读者可自行编译运行这段代码片段,当两个程序运行时则会实现结构体的远程传输功能,如下图所示;

目录
相关文章
|
3月前
boost序列化报错
boost序列化报错
|
5月前
|
JSON 前端开发 Java
表单数据序列化,后台如何接收(java)
表单数据序列化,后台如何接收(java)
|
1月前
|
消息中间件 分布式计算 Kafka
硬核!Apache Hudi中自定义序列化和数据写入逻辑
硬核!Apache Hudi中自定义序列化和数据写入逻辑
33 1
|
3月前
|
JSON 机器人 数据格式
阿里云RPA支持将序列化的JSON数据作为输入参数传递给机器人应用程序
【1月更文挑战第7天】【1月更文挑战第33篇】阿里云RPA支持将序列化的JSON数据作为输入参数传递给机器人应用程序
206 1
|
8月前
|
存储 编译器 文件存储
4.4 C++ Boost 数据集序列化库
Boost库提供了一组通用的数据序列化和反序列化库,包括archive、text_oarchive、text_iarchive、xml_oarchive、xml_iarchive等。可用于许多数据类型的持久化和传输。使用这些库,我们可以轻松地将各种数据类型序列化到文件或流中,并从文件或流中反序列化数据。
91 0
|
8月前
|
XML 存储 JSON
数据序列化工具 Protobuf 编码&避坑指南
我们现在所有的协议、配置、数据库的表达都是以 protobuf 来进行承载的,所以我想深入总结一下 protobuf 这个协议,以免踩坑。 先简单介绍一下 Protocol Buffers(protobuf),它是 Google 开发的一种数据序列化协议(与 XML、JSON 类似)。它具有很多优点,但也有一些需要注意的缺点: 优点: 效率高:Protobuf 以二进制格式存储数据,比如 XML 和 JSON 等文本格式更紧凑,也更快。序列化和反序列化的速度也很快。 跨语言支持:Protobuf 支持多种编程语言,包括 C++、Java、Python 等。 清晰的结构定义:使用 prot
|
10月前
|
JSON Java 数据格式
Jackson对象 ObjectMapper实现序列化数据为json
Jackson对象 ObjectMapper实现序列化数据为json
|
JSON JavaScript PHP
PHP传递给js的JSON数据无法反序列化
PHP传递给js的JSON数据无法反序列化
103 0
|
Java
java中的IO流之序列化与反序列化(对象数据和文件的读写交互)
在之前的IO流中,都是内存与磁盘进行交互的读写,要传输只能在本地上进行传输。想要在网络上进行传输,那就要通过进行对象的传输,java万物皆对象嘛。
109 0
java中的IO流之序列化与反序列化(对象数据和文件的读写交互)
|
JSON JavaScript 数据格式
VUE element-ui之jspreadsheet-ce在线表格数据json序列化(excel数据同步为相应key:value,并过滤掉为空的数据,未输入的行)
VUE element-ui之jspreadsheet-ce在线表格数据json序列化(excel数据同步为相应key:value,并过滤掉为空的数据,未输入的行)
467 0
VUE element-ui之jspreadsheet-ce在线表格数据json序列化(excel数据同步为相应key:value,并过滤掉为空的数据,未输入的行)

热门文章

最新文章