能否从String构建hyper::Request？Rust拦截代理开发相关咨询

不需要自行编写完整HTTP解析逻辑，有两种成熟方案可选 #

方案1：直接使用hyper底层解析能力（推荐） #

你不需要完全放弃hyper的服务端逻辑，也不需要手动把TcpStream的字节转成String再处理，只需要自定义hyper连接的错误处理逻辑，就可以避免hyper自动返回格式错误响应的问题：

• 直接用hyper::server::conn::Http结构体处理拿到的TcpStream，重写Service的错误回调，遇到解析错误时不返回默认响应，而是按你的需求直接转发原始字节流即可。
• 这种方案不需要自己处理HTTP解析的各种边缘情况（比如分块编码、大请求、特殊编码头），稳定性更高。

方案2：用hyper底层依赖的httparse库手动解析 #

如果你坚持要自己控制字节流的读取，可以用hyper底层使用的轻量HTTP解析库httparse来完成字节到请求结构的转换，再拼装成hyper::Request即可，不需要完全手写解析逻辑：

• 不要提前把所有字节转成String，HTTP请求的Body可能包含二进制内容，转String会出现编码错误，直接操作原始字节数组即可。
• 示例代码如下：

use httparse::Request;
use http::Method;
use hyper::{Request as HyperRequest, Body};

// buf为从TcpStream读取的原始字节数组
fn parse_raw_http(buf: &[u8]) -> Result<HyperRequest<Body>, Box<dyn std::error::Error>> {
    // 初始化请求头容器，最大请求头数量可根据需求调整
    let mut headers = [httparse::EMPTY_HEADER; 64];
    let mut req = Request::new(&mut headers);
    
    // 解析请求，返回已解析的字节偏移量
    let parsed_offset = req.parse(buf)?;

    // 构造hyper请求基础信息
    let method = Method::from_bytes(req.method.unwrap().as_bytes())?;
    let uri = req.path.unwrap().parse()?;
    let mut req_builder = HyperRequest::builder()
        .method(method)
        .uri(uri);

    // 填充请求头
    for header in req.headers {
        req_builder = req_builder.header(header.name, header.value);
    }

    // 未解析的剩余字节作为请求Body
    let body = Body::from(buf[parsed_offset..].to_vec());
    Ok(req_builder.body(body)?)
}

注意事项 #

• 如果需要处理大请求或流式请求，需要自己实现字节流的拼接逻辑，拿到完整请求头后再启动解析，不要只读一次TcpStream就开始解析。
• 不推荐自行实现完整的HTTP解析逻辑，HTTP协议边缘场景非常多，自研解析逻辑很容易出现兼容性问题。

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