如何解决使用 serde 将 json 反序列化为数值作为类型标识符
我对 Rust 很陌生,并且来自 OOP 背景。所以,也许我误解了一些 Rust 基础知识。
我想用 serde 解析一个固定的 json 结构。此结构代表一种不同的消息类型。每条消息都有一个数字 type
属性来区分它。各个消息类型的确切结构大不相同,但它们也可以相同。
{"type": 1,"sender_id": 4,"name": "sender",...}
{"type": 2,"sender_id": 5,"measurement": 3.1415,...}
{"type": 3,"sender_id": 6,"measurement": 13.37,...}
...
首先,我定义了一个 enum
来区分消息类型,还为每种类型的消息定义了一个 struct
,没有存储类型的字段。
#[derive(Debug,Serialize,Deserialize)]
#[serde(tag = "type")]
enum Message {
T1(Type1),T2(Type2),T3(Type3),// ...
}
#[derive(Debug,Deserialize)]
struct Type1 {
sender_id: u32,name: String,// ...
}
#[derive(Debug,Deserialize)]
struct Type2 {
sender_id: u32,measurement: f64,Deserialize)]
struct Type3 {
sender_id: u32,// ...
}
// ...
当我尝试将字符串转换为 Message
对象时,出现错误。
let message = r#"{"type":1,"sender_id":123456789,"name":"sender"}"#;
let message: Message = serde_json::from_str(message)?; // error here
// Error: Custom { kind: InvalidData,error: Error("invalid type: integer `1`,expected variant identifier",line: 1,column: 9) }
所以,据我所知,serde 试图找出当前消息的类型,但它需要一个字符串
为了那个原因。我还尝试编写自己的 deserialize()
函数。我试图获得数值
对应的 type
-key 并希望通过类型值创建特定对象。
我必须如何实现 deserialize()
来提取消息的类型并创建特定的消息对象?是否可以在不为每个 deserialize()
结构编写 Type1/2/3/...
函数的情况下编写此代码?
impl<'de> Deserialize<'de> for Message {
fn deserialize<D>(deserializer: D) -> Result<Self,D::Error>
where D: Deserializer<'de>,{
// which functions I have to call?
}
或者是否有更好的解决方案来实现我的反序列化?
我为此问题准备了一个游乐场:Playground
解决方法
Serde 尚不支持整数标签(请参阅 issue #745)。
如果您能够更改产生数据的内容,那么如果您能够将 type
更改为字符串,即 "1"
而不是 1
。然后您只需使用 #[serde(rename)]
即可使其工作。
#[derive(Debug,Serialize,Deserialize)]
#[serde(tag = "type")]
enum Message {
#[serde(rename = "1")]
T1(Type1),#[serde(rename = "2")]
T2(Type2),#[serde(rename = "3")]
T3(Type3),// ...
}
如果这不是一个选项,那么您确实需要创建一个自定义解串器。就代码而言最短的,很可能反序列化成serde_json::Value
,然后在type
上匹配,然后将serde_json::Value
反序列化成正确的{{ 1}}。
Type{1,2,3}
您可能想要执行一些适当的 error handling,而不是展开和惊慌。
如果您还需要序列化,那么您同样需要一个自定义序列化器。为此,您可以创建一个新类型进行序列化,因为您不能使用 use serde_json::Value;
impl<'de> serde::Deserialize<'de> for Message {
fn deserialize<D: serde::Deserializer<'de>>(d: D) -> Result<Self,D::Error> {
let value = Value::deserialize(d)?;
Ok(match value.get("type").and_then(Value::as_u64).unwrap() {
1 => Message::T1(Type1::deserialize(value).unwrap()),2 => Message::T2(Type2::deserialize(value).unwrap()),3 => Message::T3(Type3::deserialize(value).unwrap()),type_ => panic!("unsupported type {:?}",type_),})
}
}
。
Message
当使用 #[serde(flatten)]
时,它使用 serde::private::ser::FlatMapSerializer
,这在文档中是隐藏的。您可以使用 SerializeMap
和 use serde::Serializer;
impl Serialize for Message {
fn serialize<S>(&self,serializer: S) -> Result<S::Ok,S::Error>
where
S: Serializer,{
#[derive(Serialize)]
#[serde(untagged)]
enum Message_<'a> {
T1(&'a Type1),T2(&'a Type2),T3(&'a Type3),}
#[derive(Serialize)]
struct TypedMessage<'a> {
#[serde(rename = "type")]
t: u64,#[serde(flatten)]
msg: Message_<'a>,}
let msg = match self {
Message::T1(t) => TypedMessage { t: 1,msg: Message_::T1(t) },Message::T2(t) => TypedMessage { t: 2,msg: Message_::T2(t) },Message::T3(t) => TypedMessage { t: 3,msg: Message_::T3(t) },};
msg.serialize(serializer)
}
}
代替创建新类型。
但是,请注意,鉴于它没有记录,如果您直接使用 FlatMapSerializer
,那么任何未来版本的 serde 可能会破坏您的代码。
FlatMapSerializer
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。