Rust语言从入门到精通系列 - 零基础掌握prost库和Protobuf
liebian365 2024-10-24 14:38 27 浏览 0 评论
Prost是一个用于序列化和反序列化协议缓冲区数据的Rust语言库。它使用Google Protocol Buffers语言来定义协议,并生成Rust代码以便使用该协议。 Prost具有高性能的特点,并且支持许多protobuf功能,例如嵌套消息、默认值、枚举类型以及变长编码。
Prost支持从protobuf2和protobuf3生成代码,而且可以与其他Rust语言库和框架无缝集成。
模块场景和基础用法
Prost可以用于许多场景,包括网络通信、持久化、日志记录等。在这里,我们将通过一个简单的例子来介绍Prost的基础用法。
首先在Cargo.toml中引入prost模块,示例配置如下:
[dependencies]
prost = "0.11"
# Only necessary if using Protobuf well-known types:
prost-types = "0.11"
假设我们有一个动物园,里面有许多不同种类的动物。我们可以使用Prost来定义一个动物的协议,然后使用该协议来序列化和反序列化动物对象。
首先,我们需要定义动物的protobuf文件。在这里,我们定义了一个动物具有名称、年龄和类型。动物类型是一个枚举类型,它可以是狗、猫或鸟。
syntax = "proto3";
enum AnimalType {
DOG = 0;
CAT = 1;
BIRD = 2;
}
message Animal {
string name = 1;
uint32 age = 2;
AnimalType animal_type = 3;
}
接下来,我们需要使用Prost生成Rust代码。我们可以使用以下命令来执行此操作:
$ protoc --rust_out . animals.proto
这将生成一个名为animals.rs的文件,其中包含与protobuf定义相对应的Rust代码。
接下来,我们可以使用Prost来序列化和反序列化动物对象。以下是一个示例代码:
use prost::{Enumeration, Message};
#[derive(Clone, PartialEq, Message)]
pub struct Animal {
#[prost(string, tag="1")]
pub name: String,
#[prost(uint32, tag="2")]
pub age: u32,
#[prost(enumeration="AnimalType", tag="3")]
pub animal_type: i32,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, Enumeration)]
pub enum AnimalType {
Dog = 0,
Cat = 1,
Bird = 2,
}
fn main() {
let mut animal = Animal::default();
animal.name = "Tom".to_string();
animal.age = 3;
animal.animal_type = AnimalType::Cat as i32;
let mut buf = Vec::new();
animal.encode(&mut buf).unwrap();
let decoded_animal = Animal::decode(&buf[..]).unwrap();
assert_eq!(animal, decoded_animal);
println!("{:?}", animal);
}
// 输出结果:
// Animal { name: "Tom", age: 3, animal_type: Cat }
在这个示例代码中,我们定义了一个名为Animal的结构体,并使用prost宏将其与protobuf定义相关联。我们还定义了一个名为AnimalType的枚举类型,它与protobuf定义中的枚举类型相对应。
在main函数中,我们创建了一个Animal对象,并将其序列化为字节数组。然后,我们将字节数组反序列化为另一个Animal对象,并使用assert_eq宏比较这两个对象是否相等。
高级特性
Prost提供了许多高级特性,例如自定义类型、扩展字段、oneof等。在这里,我们将介绍其中一些特性。
自定义类型
有时,我们可能需要在protobuf定义中使用自定义类型。例如,我们可能需要使用自定义类型来表示日期或时间。在这种情况下,我们可以使用prost宏的bytes属性来定义自定义类型。
以下是一个示例代码:
syntax = "proto3";
message Date {
bytes value = 1 [(prost(bytes_type) = "chrono::NaiveDate")];
}
message Time {
bytes value = 1 [(prost(bytes_type) = "chrono::NaiveTime")];
}
在这个示例代码中,我们定义了两个消息类型:Date和Time。它们都包含一个名为value的字节数组字段,并使用prost宏的bytes_type属性将其与chrono库中的NaiveDate和NaiveTime类型相关联。
自定义编解码
Prost支持自定义编解码,可以使用prost::Message trait来实现自定义编解码。
impl Animal {
pub fn from_bytes(bytes: &[u8]) -> Result<Self, prost::DecodeError> {
Animal::decode(bytes)
}
pub fn to_bytes(&self) -> Result<Vec<u8>, prost::EncodeError> {
let mut buf = Vec::new();
self.encode(&mut buf)?;
Ok(buf)
}
}
fn main() {
let mut animal = Animal::default();
animal.name = "Tom".to_string();
animal.age = 3;
animal.animal_type = AnimalType::Cat as i32;
let bytes = animal.to_bytes();
println!("{:?}", Animal::from_bytes(&bytes.unwrap()));
}
// 输出结果:
// Ok(Animal { name: "Tom", age: 3, animal_type: Cat })
扩展字段
有时,我们可能需要向protobuf消息添加额外的字段,但是又不想破坏现有的消息格式。在这种情况下,我们可以使用扩展字段。
扩展字段是在protobuf定义中定义的,但是在生成的Rust代码中不会出现。它们可以用来存储任何类型的数据,并且可以与protobuf消息一起序列化和反序列化。
以下是一个示例代码:
syntax = "proto3";
message Animal {
string name = 1;
uint32 age = 2;
AnimalType animal_type = 3;
map<string, bytes> extensions = 1000;
}
在这个示例代码中,我们添加了一个名为extensions的字段,它是一个map类型,可以存储任何类型的数据。此字段的标签为1000,这意味着它是一个扩展字段。
在Rust代码中,我们可以使用prost::Message trait的extensions方法来访问扩展字段。以下是一个示例代码:
use prost::{Enumeration, Message};
use std::collections::HashMap;
#[derive(Clone, PartialEq, Message)]
pub struct Animal {
#[prost(string, tag="1")]
pub name: String,
#[prost(uint32, tag="2")]
pub age: u32,
#[prost(enumeration="AnimalType", tag="3")]
pub animal_type: i32,
#[prost(map="string, bytes", tag="1000")]
pub extensions: HashMap<String, Vec<u8>>,
}
#[derive(Clone, Copy, Debug, PartialEq, Eq, Hash, Enumeration)]
pub enum AnimalType {
Dog = 0,
Cat = 1,
Bird = 2,
}
fn main() {
let mut animal = Animal::default();
animal.extensions.insert("color".to_string(), b"brown".to_vec());
let mut buf = Vec::new();
animal.encode(&mut buf).unwrap();
let decoded_animal = Animal::decode(&buf[..]).unwrap();
assert_eq!(animal.extensions, decoded_animal.extensions);
}
在这个示例代码中,我们创建了一个Animal对象,并向其添加了一个名为color的扩展字段。然后,我们将该对象序列化为字节数组,并将其反序列化为另一个Animal对象。最后,我们使用assert_eq宏比较这两个对象的扩展字段是否相等。
Proto Oneof
有时,我们可能需要在protobuf消息中使用oneof语法,以表示字段中的多个可能类型。在这种情况下,我们可以使用prost宏的oneof属性来定义oneof字段。
以下是一个示例代码:
syntax = "proto3";
message Animal {
string name = 1;
uint32 age = 2;
oneof animal_type {
Dog dog = 3;
Cat cat = 4;
Bird bird = 5;
}
}
message Dog {
string breed = 1;
}
message Cat {
bool has_tail = 1;
}
message Bird {
uint32 wingspan = 1;
}
在这个示例代码中,我们定义了一个名为Animal的消息类型,它包含一个名为animal_type的oneof字段。oneof字段中包含三个可能的类型:Dog、Cat和Bird。每个类型都包含与其相关联的字段。
在Rust代码中,我们可以使用prost::Oneof trait来访问oneof字段。以下是一个示例代码:
use prost::{Enumeration, Message, Oneof};
use std::collections::HashMap;
use core::option::Option;
#[derive(Clone, PartialEq, Message)]
pub struct Animal {
#[prost(string, tag="1")]
pub name: String,
#[prost(uint32, tag="2")]
pub age: u32,
#[prost(oneof="AnimalType", tag="3,4,5")]
pub animal_type: Option<AnimalType>,
}
#[derive(Clone, Debug, PartialEq, Enumeration)]
pub enum AnimalType {
#[prost(message, tag = "3", name = "Dog")]
Dog(Dog),
#[prost(message, tag = "4", name = "Cat")]
Cat(Cat),
#[prost(message, tag = "5", name = "Bird")]
Bird(Bird),
}
#[derive(Clone, PartialEq, Message)]
pub struct Dog {
#[prost(string, tag="1")]
pub breed: String
}
#[derive(Clone, PartialEq, Message)]
pub struct Cat {
#[prost(bool, tag="1")]
pub has_tail: bool
}
#[derive(Clone, PartialEq, Message)]
pub struct Bird {
#[prost(uint32, tag="1")]
pub wingspan: u32
}
fn main() {
let mut animal = Animal::default();
animal.name = "Tom".to_string();
animal.age = 3;
animal.animal_type = Some(AnimalType::Cat(Cat { has_tail: true }));
let mut buf = Vec::new();
animal.encode(&mut buf).unwrap();
let decoded_animal = Animal::decode(&buf[..]).unwrap();
assert_eq!(animal, decoded_animal);
}
在这个示例代码中,我们创建了一个Animal对象,并将其cat字段设置为一个包含has_tail字段的Cat对象。然后,我们将该对象序列化为字节数组,并将其反序列化为另一个Animal对象。最后,我们使用assert_eq宏比较这两个对象是否相等。
prost最佳实践
以下是一些使用Prost的最佳实践经验:
- ? 在protobuf定义中使用简单的数据类型。Prost支持许多protobuf功能,例如嵌套消息、默认值、枚举类型以及变长编码。但是,使用这些功能可能会导致生成的Rust代码变得复杂。因此,为了使代码保持简单和易于维护,请尽可能使用简单的数据类型。
- ? 在Rust代码中使用结构体。Prost生成的Rust代码可以是一个模块或一个trait。但是,使用结构体可以使代码更易于使用和维护。因此,建议在Rust代码中使用结构体。
- ? 使用自定义类型时,请使用标准库或第三方库。Prost支持许多自定义类型,包括日期、时间、UUID等。但是,使用标准库或第三方库可能会使代码更加通用和可移植。因此,建议在使用自定义类型时使用标准库或第三方库。
- ? 在使用扩展字段时,请注意字段标签。扩展字段的标签必须大于1000。因此,请确保您为扩展字段选择一个大于1000的标签。
- ? 在使用oneof语法时,请选择一个好的字段名称。oneof字段包含多个可能的类型,因此请为其选择一个好的字段名称。这将使代码更易于理解和维护。
总结
Prost是一个高性能的Rust语言库,可用于序列化和反序列化协议缓冲区数据。它支持许多protobuf功能,并且可以与其他Rust语言库和框架无缝集成。在本教程中,我们介绍了Prost的基础用法和一些高级特性,并提供了一些最佳实践经验。我们希望这个教程能够帮助您更好地使用Prost。
相关推荐
- 4万多吨豪华游轮遇险 竟是因为这个原因……
-
(观察者网讯)4.7万吨豪华游轮搁浅,竟是因为油量太低?据观察者网此前报道,挪威游轮“维京天空”号上周六(23日)在挪威近海发生引擎故障搁浅。船上载有1300多人,其中28人受伤住院。经过数天的调...
- “菜鸟黑客”必用兵器之“渗透测试篇二”
-
"菜鸟黑客"必用兵器之"渗透测试篇二"上篇文章主要针对伙伴们对"渗透测试"应该如何学习?"渗透测试"的基本流程?本篇文章继续上次的分享,接着介绍一下黑客们常用的渗透测试工具有哪些?以及用实验环境让大家...
- 科幻春晚丨《震动羽翼说“Hello”》两万年星间飞行,探测器对地球的最终告白
-
作者|藤井太洋译者|祝力新【编者按】2021年科幻春晚的最后一篇小说,来自大家喜爱的日本科幻作家藤井太洋。小说将视角放在一颗太空探测器上,延续了他一贯的浪漫风格。...
- 麦子陪你做作业(二):KEGG通路数据库的正确打开姿势
-
作者:麦子KEGG是通路数据库中最庞大的,涵盖基因组网络信息,主要注释基因的功能和调控关系。当我们选到了合适的候选分子,单变量研究也已做完,接着研究机制的时便可使用到它。你需要了解你的分子目前已有哪些...
- 知存科技王绍迪:突破存储墙瓶颈,详解存算一体架构优势
-
智东西(公众号:zhidxcom)编辑|韦世玮智东西6月5日消息,近日,在落幕不久的GTIC2021嵌入式AI创新峰会上,知存科技CEO王绍迪博士以《存算一体AI芯片:AIoT设备的算力新选择》...
- 每日新闻播报(September 14)_每日新闻播报英文
-
AnOscarstatuestandscoveredwithplasticduringpreparationsleadinguptothe87thAcademyAward...
- 香港新巴城巴开放实时到站数据 供科技界研发使用
-
中新网3月22日电据香港《明报》报道,香港特区政府致力推动智慧城市,鼓励公私营机构开放数据,以便科技界研发使用。香港运输署21日与新巴及城巴(两巴)公司签署谅解备忘录,两巴将于2019年第3季度,开...
- 5款不容错过的APP: Red Bull Alert,Flipagram,WifiMapper
-
本周有不少非常出色的app推出,鸵鸟电台做了一个小合集。亮相本周榜单的有WifiMapper's安卓版的app,其中包含了RedBull的一款新型闹钟,还有一款可爱的怪物主题益智游戏。一起来看看我...
- Qt动画效果展示_qt显示图片
-
今天在这篇博文中,主要实践Qt动画,做一个实例来讲解Qt动画使用,其界面如下图所示(由于没有录制为gif动画图片,所以请各位下载查看效果):该程序使用应用程序单窗口,主窗口继承于QMainWindow...
- 如何从0到1设计实现一门自己的脚本语言
-
作者:dong...
- 三年级语文上册 仿写句子 需要的直接下载打印吧
-
描写秋天的好句好段1.秋天来了,山野变成了美丽的图画。苹果露出红红的脸庞,梨树挂起金黄的灯笼,高粱举起了燃烧的火把。大雁在天空一会儿写“人”字,一会儿写“一”字。2.花园里,菊花争奇斗艳,红的似火,粉...
- C++|那些一看就很简洁、优雅、经典的小代码段
-
目录0等概率随机洗牌:1大小写转换2字符串复制...
- 二年级上册语文必考句子仿写,家长打印,孩子照着练
-
二年级上册语文必考句子仿写,家长打印,孩子照着练。具体如下:...
你 发表评论:
欢迎- 一周热门
- 最近发表
- 标签列表
-
- wireshark怎么抓包 (75)
- qt sleep (64)
- cs1.6指令代码大全 (55)
- factory-method (60)
- sqlite3_bind_blob (52)
- hibernate update (63)
- c++ base64 (70)
- nc 命令 (52)
- wm_close (51)
- epollin (51)
- sqlca.sqlcode (57)
- lua ipairs (60)
- tv_usec (64)
- 命令行进入文件夹 (53)
- postgresql array (57)
- statfs函数 (57)
- .project文件 (54)
- lua require (56)
- for_each (67)
- c#工厂模式 (57)
- wxsqlite3 (66)
- dmesg -c (58)
- fopen参数 (53)
- tar -zxvf -c (55)
- 速递查询 (52)