经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置：技术经验 » 程序设计 » Rust » 查看文章
25. 干货系列从零用Rust编写正反向代理，序列化之serde是如何工作的
来源：cnblogs　　作者：问蒙服务框架　　时间：2023/11/10 10:07:12　　对本文有异议

wmproxy

wmproxy已用Rust实现http/https代理, socks5代理, 反向代理, 静态文件服务器，四层TCP/UDP转发，内网穿透，后续将实现websocket代理等，会将实现过程分享出来，感兴趣的可以一起造个轮子

项目地址

国内: https://gitee.com/tickbh/wmproxy

github: https://github.com/tickbh/wmproxy

序列化

序列化（Serialization）是指将数据结构或对象状态转化为可以存储或传输的形式的过程。

在序列化过程中，对象的成员属性和类型信息一起被转换为一个字节流或可打印字符流，以便于存储或网络传输。

这个字节流或字符流可以再次被反序列化（Deserialization）还原为原始对象状态。

字符流比如JSON，字节流比如ProtoBuf。

Rust中的序列化

在Rust中序列化最常用且支持最广的为第三方库serde，当前在github上已有8000颗star。

常用的比如JSON库的serde_json，比如YAML，TOML，BSON等，依靠serde库之上，对常用的格式已经有了广泛的的支持。

在代码中，Serde数据模型的序列化部分由特定义 Serializer，反序列化部分由特征定义Deserializer。这些是将每个 Rust 数据结构映射到 29 种可能类型之一的方法。特征的每个方法Serializer对应于数据模型的一种类型。

支持基础类型如常用的布尔值，整型，浮点型，字符串，字节流

支持的高级类型，如tuple，struct，seq，enum可以映射成各种内置的数据结构。

如何使用serde

假如用现有的数据格式，如json之类的，可以轻松的实现。

  1. 配置Cargo.toml
  1. [package]
  2. name = "wmproxy"
  3. version = "0.1.0"
  4. authors = ["wenmeng <user@wm-proxy.com>"]
  6. [dependencies]
  7. serde = { version = "1.0", features = ["derive"] }
  9. # 这仅仅是测试用例，需要用哪个可以选择添加
  10. serde_json = "1.0"
  1. 现在src/main.rs使用Serde的自定义导出：
  1. use serde::{Serialize, Deserialize};
  3. #[derive(Serialize, Deserialize, Debug)]
  4. struct Point {
  5.     x: i32,
  6.     y: i32,
  7. }
  9. fn main() {
  10.     let point = Point { x: 1, y: 2 };
  12.     let serialized = serde_json::to_string(&point).unwrap();
  13.     println!("serialized = {}", serialized);
  15.     let deserialized: Point = serde_json::from_str(&serialized).unwrap();
  16.     println!("deserialized = {:?}", deserialized);
  17. }

以下输出：

  1. $ cargo run
  2. serialized = {"x":1,"y":2}
  3. deserialized = Point { x: 1, y: 2 }

serde中的属性参数

在使用serde中经常可以看到在字段前加一些属性参数，这些是约定该字段序列化或反序列化时将如何处理的，下面我们看以下的例子：

  • #[serde(default)]
    这是设置默认参数，或者可以带上#[serde(default="???")]，这里???将是一个函数名，不能带参数，可以直接访问，如Vec::new可以直接访问的函数。
  1. fn default_y() -> i32  {
  2.     1024
  3. }
  4. #[derive(Serialize, Deserialize, Debug)]
  5. struct Point {
  6.     #[serde(default)]
  7.     x: i32,
  8.     #[serde(default="default_y")]
  9.     y: i32,
  10. }

此时我们反序化一个值时，如果没有x的参数会将x默认设置成0，如果没有y参数，将会调用default_y函数，也就是y会默认为1024。

  • #[serde(rename = "name")]
    重命名字段名字，在内存中显示长的名字好理解，在配置中可以用短的名字好配置。此外还有#[serde(rename_all = "...")]可以将所有的名字结构变成全小写，或者全大写之类或者驼峰结构等。
  • #[serde(skip)]
    该字段跳过序列化及反序列化，也就是一些内存对象或者临时数据不适合做序列化，用此来做约束。还有#[serde(skip_serializing)]跳过序列化和#[serde(skip_deserializing)]跳过反序列化等。
  • #[serde(flatten)]
    将不能解析的数据统一挪入到另一个数据结构，在此项目中用到的通用的配置化结构，就将其均挪到了CommonConfig，可以极好的精简配置结构
  1. #[derive(Debug, Clone, Serialize, Deserialize)]
  2. pub struct HttpConfig {
  3.     #[serde(default = "Vec::new")]
  4.     pub server: Vec<ServerConfig>,
  5.     #[serde(default = "Vec::new")]
  6.     pub upstream: Vec<UpstreamConfig>,
  7.     #[serde(flatten)]
  8.     #[serde(default = "CommonConfig::new")]
  9.     pub comm: CommonConfig,
  10. }
  • #[serde(with = "module")]
    这个是自定义序列化的关键，也是他强大的基础，可以很好的实现自定义的一些操作，就比如配置一个整型，现在要把他转成Duration或者原来是一个字符串"4k"表示大小，现在需要把他按数据大小转成数字4096，就需要自定义的序列化过程。
    该声名同时包含了serialize_with和deserialize_with，该模块需实现$module::serialize及$module::deserialize做对应的序列化和反序列化。

serde的工作原理

序列化

以下过程是Rust中的数据结构是如何转化成目标格式的

  1. Rust （结构体枚举） 
  2.   ↓
  3.   -- Serialize（序列化） --> 当前结构体中，有对字段进行协议说明的，加属性标记
  4.   ↓
  5.   -- 数据的格式（如JSON/BSON/YAML等） --> 根据对应的输出库（serde_json/serde_yaml）输出相应的字节流

反序列化

以下以JSON格式是如何转化成Rust的结构，在JSON中属于键值对且值有特定的数据格式，其中key将解析成数据结构中的字段名，值value将根据反序列化可以尝试解析的类型尝试是否能转成目标类型。

比如value值为字符串，且反序列反时选择deserialize_str，将在反序列化的时候会尝试调用

  1. /// 我们将根据该字符串的值能否解析成目标类型，如果失败返回错误
  2. fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
  3. where
  4.     E: de::Error,
  5. {
  6. }

比如value值为数值，且反序列反时选择deserialize_i64，将在反序列化的时候会尝试调用

  1. /// 我们将根据该数值的值能否解析成目标类型，如果失败返回错误
  2. fn visit_i64<E>(self, v: i64) -> Result<Self::Value, E>
  3.     where
  4.         E: Error, {
  5. }

或者以上两种格式我们都是支持的，比如时间可以支持数字8或者"8s"，此时我们需要同时将数字或者字符串同时支持转成Duration::new(8,0)，那么此时我们自定义的反序列化函数可以我选择deserialize_any，并分别实现visit_i64及visit_str

举个例子

以下是通过标准的Display做输出及FromStr做反序列化，但是此时我们又需要同时支持数字的处理，首先我们先定义模块

  1. pub struct DisplayFromStrOrNumber;

此时该模块需要实现序列化及反序列化。
实现序列化，将用标准的Display做输出：

  1. impl<T> SerializeAs<T> for DisplayFromStrOrNumber
  2. where
  3.     T: Display,
  4. {
  5.     fn serialize_as<S>(source: &T, serializer: S) -> Result<S::Ok, S::Error>
  6.     where
  7.         S: Serializer,
  8.     {
  9.         serializer.collect_str(source)
  10.     }
  11. }

实现反序列化，我们将数字统一转成字符串，然后用FromStr做反序列化：

  2. impl<'de, T> DeserializeAs<'de, T> for DisplayFromStrOrNumber
  3. where
  4.     T: FromStr,
  5.     T::Err: Display,
  6. {
  7.     fn deserialize_as<D>(deserializer: D) -> Result<T, D::Error>
  8.     where
  9.         D: Deserializer<'de>,
  10.     {
  11.         struct Helper<S>(PhantomData<S>);
  12.         impl<'de, S> Visitor<'de> for Helper<S>
  13.         where
  14.             S: FromStr,
  15.             <S as FromStr>::Err: Display,
  16.         {
  17.             type Value = S;
  19.             fn expecting(&self, formatter: &mut fmt::Formatter<'_>) -> fmt::Result {
  20.                 write!(formatter, "a string")
  21.             }
  23.             fn visit_str<E>(self, value: &str) -> Result<Self::Value, E>
  24.             where
  25.                 E: de::Error,
  26.             {
  27.                 value.parse::<Self::Value>().map_err(de::Error::custom)
  28.             }
  30.             /// 将数字转成字符串从而能调用FromStr函数
  31.             fn visit_i64<E>(self, v: i64) -> Result<Self::Value, E>
  32.                 where
  33.                     E: Error, {
  34.                 format!("{}", v).parse::<Self::Value>().map_err(de::Error::custom)
  35.             }
  36.         }
  38.         deserializer.deserialize_any(Helper(PhantomData))
  39.     }
  40. }

此时我们已有了标准模块了，我们只能重新实现类的Display及FromStr，由于现有的类型如Duration我们不能重新实现impl Display for Duration因为接口Display和类型Duration均不是我们定义的，如果我们可以重新实现，那么此有可能其它第三方库也实现了，那么我们在引用的时候可能就有多种实现方法，从而无法确定调用函数。

那么此时我们做一层包裹方法

  1. pub struct ConfigDuration(pub Duration);

此时我们只需要重新实现Display及FromStr就可以了

  2. impl FromStr for ConfigDuration {
  3.     type Err=io::Error;
  5.     fn from_str(s: &str) -> Result<Self, Self::Err> {
  6.         if s.len() == 0 {
  7.             return Err(io::Error::new(io::ErrorKind::InvalidInput, ""));
  8.         }
  10.         let d = if s.ends_with("ms") {
  11.             let new = s.trim_end_matches("ms");
  12.             let s = new.parse::<u64>().map_err(|_| io::Error::new(io::ErrorKind::InvalidInput, ""))?;
  13.             Duration::new(0, (s * 1000_000) as u32)
  14.         } else if s.ends_with("h") {
  15.             let new = s.trim_end_matches("h");
  16.             let s = new.parse::<u64>().map_err(|_| io::Error::new(io::ErrorKind::InvalidInput, ""))?;
  17.             Duration::new(s * 3600, 0)
  18.         } else if s.ends_with("min") {
  19.             let new = s.trim_end_matches("min");
  20.             let s = new.parse::<u64>().map_err(|_| io::Error::new(io::ErrorKind::InvalidInput, ""))?;
  21.             Duration::new(s * 60, 0)
  22.         } else if s.ends_with("s") {
  23.             let new = s.trim_end_matches("s");
  24.             let s = new.parse::<u64>().map_err(|_| io::Error::new(io::ErrorKind::InvalidInput, ""))?;
  25.             Duration::new(s, 0)
  26.         } else {
  27.             let s = s.parse::<u64>().map_err(|_| io::Error::new(io::ErrorKind::InvalidInput, ""))?;
  28.             Duration::new(s, 0)
  29.         };
  31.         Ok(ConfigDuration(d))
  32.     }
  33. }
  36. impl Display for ConfigDuration {
  37.     fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
  38.         let ms = self.0.subsec_millis();
  39.         let s = self.0.as_secs();
  40.         if ms > 0 {
  41.             f.write_str(&format!("{}ms", ms as u64 + s * 1000))
  42.         } else {
  43.             if s >= 3600 && s % 3600 == 0 {
  44.                 f.write_str(&format!("{}h", s / 3600))
  45.             } else if s >= 60 && s % 60 == 0 {
  46.                 f.write_str(&format!("{}min", s / 60))
  47.             } else {
  48.                 f.write_str(&format!("{}s", s))
  49.             }
  50.         }
  51.     }
  52. }

这样子我们在加上声名即可以实现自定义的序列化过程了：

  1. pub struct CommonConfig {
  2.     #[serde_as(as = "Option<DisplayFromStrOrNumber>")]
  3.     pub rate_limit_per: Option<ConfigDuration>,
  4. }

结语

序列化不管在配置还是在传输等过程中，都是必不可少的存在，了解序列化及反序列化的过程我们将可以更快的找到切入点去实现自己的功能。

点击 [关注]，[在看]，[点赞] 是对作者最大的支持

原文链接：https://www.cnblogs.com/wmproxy/p/17823384.html

 友情链接：直通硅谷 　点职佳 　北美留学生论坛

Rust热门文章

  • Rust GUI库 egui 的简单应用
  • 36. 干货系列从零用Rust编写负载均衡及代理，内网穿透中内网代理的实现
  • 用Rust手把手编写一个Proxy(代理), TLS加密通讯
  • 简明快速配置 Rust 工具链
  • 9. 用Rust手把手编写一个wmproxy(代理，内网穿透等), HTTP2改造篇之HPACK示例, 了解http2头信息如何处理
  • rust 过程宏
  • 45从零开始用Rust编写nginx，静态文件服务器竟然还有这些细节
  • 37. 干货系列从零用Rust编写负载均衡及代理，负载均衡中try_files实现
  • 26. 干货系列从零用Rust编写正反向代理，如何发布Rust项目到Docker
  • 折腾 Quickwit，Rust 编写的分布式搜索引擎-官方教程

    • Rust推荐文章

  • 折腾 Quickwit，Rust 编写的分布式搜索引擎-官方教程
  • 折腾 Quickwit，Rust 编写的分布式搜索引擎(专为从对象存储中实现亚秒级搜索而设计)
  • Rust使用Sauron实现Web界面交互
  • Rust GUI库 egui 的简单应用
  • 50从零开始用Rust编写nginx，原来TLS证书还可以这么申请
  • 48从零开始用Rust编写nginx，搭建一个简单又好看官方网站
  • 45从零开始用Rust编写nginx，静态文件服务器竟然还有这些细节
  • 44从零开始用Rust编写nginx，命令行参数的设计与解析及说明
  • 43 干货系列从零用Rust编写负载均衡及代理，内网穿透方案完整部署
  • rust angular 自签名证书 wss

    • 本站QQ群：前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

    W3xue 的所有内容仅供测试，对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
    关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接（目前9元/月）请联系QQ：27243702 沸活量
    皖ICP备17017327号-2　皖公网安备34020702000426号