C++怎么使用FlatBuffers进行高效序列化_C++数据序列化与FlatBuffers应用_技术教程

FlatBuffers 因零拷贝访问、高内存效率、跨语言支持和编译时代码生成，成为高性能 C++ 项目的理想选择。

FlatBuffers 是 Google 开发的一个高效跨平台序列化库，特别适合对性能要求高的 C++ 项目。与 Protocol Buffers 不同，FlatBuffers 不需要解析和反序列化即可直接访问数据，这使得它在读取速度上极具优势，非常适合游戏、实时通信和嵌入式系统等场景。

为什么选择 FlatBuffers？

零拷贝访问：序列化后的数据以二进制形式存储，可以直接映射到内存中，无需解包就能读取字段。

内存效率高：不产生额外的临时对象，避免了频繁的内存分配。

跨语言支持：支持 C++、Java、Python 等多种语言，便于多端数据交互。

编译时生成代码：通过 schema 文件（.fbs）自动生成 C++ 类，类型安全且易于维护。

安装与环境配置

可以从 GitHub 获取 FlatBuffers 源码并编译：

git clone https://github.com/google/flatbuffers.git
cd flatbuffers
cmake .
make
sudo make install

安装后会得到 flatc 编译器，用于将 .fbs 文件转为 C++ 头文件。

定义 Schema 并生成代码

创建一个名为 person.fbs 的 schema 文件：

table Person {
  name:string;
  age:int;
  email:string = "";
}
root_type Person;

使用 flatc 工具生成 C++ 代码：

flatc --cpp person.fbs

会生成 person_generated.h，其中包含 PersonBuilder 和 Person 类。

序列化与反序列化操作

使用生成的类进行数据构建和访问：

序列化示例：

#include "person_generated.h"
#include 
flatbuffers::FlatBufferBuilder builder;
auto name = builder.CreateString("Alice");
auto email = builder.CreateString("alice@example.com");
PersonBuilder pb(builder);
pb.add_name(name);
pb.add_age(25);
pb.add_email(email);
auto person_offset = pb.Finish();
builder.Finish(person_offset);
// 获取二进制数据指针和长度
uint8_t *data = builder.GetBufferPointer();
size_t size = builder.GetSize();
// 可保存到文件或网络发送

反序列化示例：

// 假设 data 和 size 来自文件或网络
const Person* person = flatbuffers::GetRoot(data);
std::cout << "Name: " << person->name()->c_str() << std::endl;
std::cout << "Age: " << person->age() << std::endl;
std::cout << "Email: " << person->email()->c_str() << std::endl;

注意：只要 data 内存有效，就可以直接访问字段，无需额外解析。

处理复杂结构与向量

FlatBuffers 支持嵌套结构和数组。例如：

table Address {
  city:string;
  zip_code:string;
}
table Person {
name:string;
addresses:[Address];  // 向量字段
}

构建向量时使用 CreateVector 或 StartVector/EndVector：

std::vector addresses;
AddressBuilder ab(builder);
ab.add_city(builder.CreateString("Beijing"));
ab.add_zip_code(builder.CreateString("100000"));
addresses.push_back(ab.Finish());
auto addresses_vector = builder.CreateVector(addresses);
PersonBuilder pb(builder);
pb.add_addresses(addresses_vector);