在reqwest与actix_web中不消费原Response获取响应体

因为Reqwest的Response类型不实现Clone，且读取响应体的方法（如text()、bytes()）会消费原对象，所以不能同时保留Response实例并多次读取其内容。针对你的代理场景，正确的做法是先提取无需消费Response的元数据（状态码、响应头），再一次性读取响应体到内存，之后用这些数据构造代理响应。

修改后的核心代码 #

// 处理请求执行阶段的错误（如网络连接失败）
let resp = CLIENT.execute(request).await?;

// 提取状态码和响应头，这两步不会消费Response
let status = resp.status();
let upstream_headers = resp.headers().clone();

// 读取响应体，此时Response会被消费
let resp_body = resp.text().await.unwrap_or_else(|_| String::from("Failed to read response body"));

// 针对错误状态码记录日志
if status.is_client_error() || status.is_server_error() {
    eprintln!("上游服务器返回错误状态码 {}: {}", status.as_u16(), resp_body);
}

// 构造代理响应，复用上游的状态、头和响应体
let mut response = HttpResponse::build(status);
// 复制上游响应头（可根据需求过滤或修改）
for (name, value) in upstream_headers {
    response.append_header((name, value));
}
add_headers(&mut response); // 保留你原有的自定义头逻辑
Ok(response.body(resp_body))

关键逻辑说明 #

1. 提前提取元数据：resp.status()和resp.headers()都是引用方法，不会消耗Response，可以在读取响应体前安全获取。
2. 一次性读取响应体：text()/bytes()方法会消费Response，但此时我们已经拿到了所有需要的元数据，后续无需再使用原Response实例。
3. 完整转发响应：无论上游返回成功还是错误状态（如403），都直接用上游的状态码、响应头和响应体构造代理响应，满足你同时返回状态和内容的需求。
4. 避免重复处理Result：用await?直接解包请求执行的结果，简化错误处理流程。

如果需要处理二进制响应内容，只需将text()替换为bytes()，得到Bytes类型后同样可以作为HttpResponse的body使用。

内容的提问来源于stack exchange，提问作者kryptonian