如何将字节流从 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

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

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

这将发送请求并自动将其转换为 JSON。由于该json方法在内部使用serde_json::from_reader，因此它还将字节流反序列化为结构体。

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