如何将来自 reqwest 响应的字节流反序列化为 JSON？

Question

通过 reqwest 的请求需要一个长轮询响应，因此我创建了一个字节流并尝试将每个块反序列化为 JSON。我立即意识到这是错误的，因为每个块都可能不完整，因此反序列化可能会失败；即使一些块被反序列化为 JSON，但大多数都失败了。我该怎么做？

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let client = reqwest::Client::new();
    let mut stream = client
        .get("https://...")
        .send()
        .await?
        .bytes_stream();

    while let Some(chunk) = stream.next().await {
        match serde_json::from_slice::<Value>(&chunk?){
            Ok(value) => println!("OK: {:?}", value),
            Err(e) => println!("ERROR: {:?}", e),
        }
    };

    Ok(())
}

Answer 1

如果您从 Cargo.toml 的 reqwest 库中启用功能 json。然后你可以将代码简化为：

let json = client
    .get("https://...")
    .send()
    .await?
    .json::<T>() //T needs to implement serde::de::DeserializeOwned
    .await?;

这将发送请求并自动将其转换为 JSON。由于 json method internally uses serde_json::from_reader，它还将字节流反序列化为结构。

如果响应正文不是 JSON 格式或者无法正确反序列化为 T.

，这将失败

如何将来自 reqwest 响应的字节流反序列化为 JSON？

How do I deserialize the byte stream from a reqwest response into JSON?

json

rust

deserialization

serde

reqwest