hyper-proxy

基于hyper的应用的代理连接器。

文档

示例

use hyper::{Client, Request, Uri};
use hyper::client::HttpConnector;
use futures::{TryFutureExt, TryStreamExt};
use hyper_proxy::{Proxy, ProxyConnector, Intercept};
use headers::Authorization;
use std::error::Error;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
    let proxy = {
        let proxy_uri = "http://my-proxy:8080".parse().unwrap();
        let mut proxy = Proxy::new(Intercept::All, proxy_uri);
        proxy.set_authorization(Authorization::basic("John Doe", "Agent1234"));
        let connector = HttpConnector::new();
        let proxy_connector = ProxyConnector::from_proxy(connector, proxy).unwrap();
        proxy_connector
    };

    // Connecting to http will trigger regular GETs and POSTs.
    // We need to manually append the relevant headers to the request
    let uri: Uri = "http://my-remote-website.com".parse().unwrap();
    let mut req = Request::get(uri.clone()).body(hyper::Body::empty()).unwrap();

    if let Some(headers) = proxy.http_headers(&uri) {
        req.headers_mut().extend(headers.clone().into_iter());
    }

    let client = Client::builder().build(proxy);
    let fut_http = client.request(req)
        .and_then(|res| res.into_body().map_ok(|x|x.to_vec()).try_concat())
        .map_ok(move |body| ::std::str::from_utf8(&body).unwrap().to_string());

    // Connecting to an https uri is straightforward (uses 'CONNECT' method underneath)
    let uri = "https://my-remote-websitei-secured.com".parse().unwrap();
    let fut_https = client.get(uri)
        .and_then(|res| res.into_body().map_ok(|x|x.to_vec()).try_concat())
        .map_ok(move |body| ::std::str::from_utf8(&body).unwrap().to_string());

    let (http_res, https_res) = futures::future::join(fut_http, fut_https).await;
    let (_, _) = (http_res?, https_res?);

    Ok(())
}

特性

hyper-proxy公开了三个主要Cargo特性，用于配置它连接到代理时使用的TLS实现。它也可以在不支持TLS的情况下配置，通过完全不编译默认特性来实现。支持的配置列表为

1. 不支持TLS (default-features = false)
2. 通过native-tls支持TLS，链接到操作系统的本地TLS实现（默认）
3. 通过rustls支持TLS (default-features = false, features = ["rustls"])
4. 通过rustls支持TLS，使用静态编译的CA证书集绕过操作系统的默认存储（default-features = false, features = ["rustls-webpki"])

致谢

代码的大部分来自reqwest。核心部分已经被提取并稍作增强。

主要更改包括

• 支持身份验证
• 添加非安全隧道
• 添加连接到代理时添加额外头部的可能性