Rust hyper 1.x 发送 https 请求

jetsung

Rust hyper 1.x 发送 https 请求

网上的案例全是基于 0.14+ 版本的，全部都无法正常使用。

1.x 版本已经移除了 Client，相关文档：https://hyper.rs/guides/1/upgrading/

下面是一个正常的示例

use http_body_util::Empty;
use hyper::{http::uri::Uri, Request};
use hyper::body::Bytes;
use hyper_tls::HttpsConnector;
use hyper_util::client::legacy::Client;
use hyper_util::rt::TokioExecutor;

#[tokio::main]
async fn main() {

    let url = Uri::from_static("https://baidu.com");
    println!("The URL is: {}", url);

    // let client = Client::builder(hyper_util::rt::TokioExecutor::new()).build(HttpConnector::new());
    let https = HttpsConnector::new();
    let client = Client::builder(TokioExecutor::new()).build::<_, Empty<Bytes>>(https);

    // let res = client.get("https://hyper.rs".parse()?).await?;    

    let req = Request::builder()
        .uri(url)
        .body(Empty::<Bytes>::new())
        .unwrap();
    println!("{:?}", req);

    let resp = client.request(req).await.unwrap();
    println!("{:?}", resp)
}

jetsung

连续重定向

    let https = HttpsConnector::new();
    let client = Client::builder(TokioExecutor::new()).build::<>(https);

    let mut builder = hyper::Request::builder()
        .method(method)
        .uri(url);

    for (key, value) in headers.iter() {
        builder = builder.header(key, value);
    }

    let req = builder.body(Empty::<hyper::body::Bytes>::new())
        .unwrap();

        println!("req: {:?}", req);
        let resp = client.request(req).await.unwrap();
        println!("resp: {:?}", resp);

        if let Some(localtion) = resp.headers().get(header::LOCATION) {
            println!("location: {:?}", localtion);
            if let Ok(location_str) = localtion.to_str() {
                println!("Redirecting1 to: {}", location_str);
            }
        }

    let https = HttpsConnector::new();
    let client = Client::builder(TokioExecutor::new()).build::<_, Empty<hyper::body::Bytes>>(https);

    let req = hyper::Request::builder()
        .method(method)
        .uri(url)
        .body(Empty::<hyper::body::Bytes>::new())
        .unwrap();

        println!("req: {:?}", req);
        let resp = client.request(req).await.unwrap();
        println!("resp: {:?}", resp);

        if let Some(localtion) = resp.headers().get(header::LOCATION) {
            println!("location: {:?}", localtion);
            if let Ok(location_str) = localtion.to_str() {
                println!("Redirecting1 to: {}", location_str);

                
            }
        }

下面这一行有问题

    for (key, value) in headers.iter() {
        builder = builder.header(key, value);
    }