Одновременное обслуживание на нескольких портах (http, https) с использованием фреймворка warp в Rust

Я хочу обслуживать несколько подключений с помощью warp, чтобы я мог перенаправлять каждый HTTP-запрос на https. Вот чем я сейчас занимаюсь.

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

    let http_routes = warp::path("http").map(|| {
        println!("This is http server");
        warp::redirect(Uri::from_static("https://127.0.0.1:2443"))
    });

    let https_routes = warp::any().map(|| {
        println!("This is https server");
        "Hello, World! You are connected through tls connection."
    });

    let _http_warp = warp::serve(http_routes)
        .run(([127, 0, 0, 1], 2080)).await;

    let _https_warp = warp::serve(https_routes)
        .tls()
        .cert_path("sec/dmp.cert")
        .key_path("sec/dmp.key")
        .run(([127, 0, 0, 1], 2443)).await;
}

Это не работает должным образом. Он слушает только порт 2080, а не 2443

Я тоже пробовал future :: присоединиться

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

    ----snip----

    let (_http_addr, http_warp) = warp::serve(http_routes)
        .bind_ephemeral(([127, 0, 0, 1], 2080));

    let (_https_addr, https_warp) = warp::serve(https_routes)
        .tls()
        .cert_path("sec/dmp.cert")
        .key_path("sec/dmp.key")
        .bind_ephemeral(([127, 0, 0, 1], 2443));

    future::join(http_warp, https_warp).await?
}

Это дает ошибку

error[E0277]: the `?` operator can only be applied to values that implement `std::ops::Try`
  --> src/main.rs:27:5
   |
27 |     future::join(http_wrap, https_wrap).await?
   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ the `?` operator cannot be applied to type `((), ())`
   |
   = help: the trait `std::ops::Try` is not implemented for `((), ())`
   = note: required by `std::ops::Try::into_result`

future rust rust-warp

kanudo 25.04.2020 источник

Ответы (2)

arrow_upward
2
arrow_downward

Совершенно просто сделать этот прогон, а что удаляет? суффикс из оператора await в конце с точкой с запятой.

future::join(http_wrap, https_wrap).await? // FROM THIS
future::join(http_wrap, https_wrap).await; // TO THIS

Вот и все. Теперь оба фьючерса работают одновременно, поэтому он прослушивает оба порта.

kanudo 25.04.2020

comment

Для будущих читателей функция :: futures::future::join не то же самое, что макрос futures::join!. - Ron Thompson; 01.09.2020

arrow_upward
0
arrow_downward

вот решение kanudo в качестве полного рабочего примера перенаправления tls https в warp

cert.pem

key.rsa

Cargo.toml

[dependencies]
tokio = { version = "0.2", features = ["full"] }
warp = { version = "0.2", features = ["tls"] }
futures = "0.3.8"

main.rs

use warp::hyper::Uri;
use warp::Filter;
use futures::future;

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

    let http_routes = warp::path("http").map(|| {
        println!("This is http server");
        warp::redirect(Uri::from_static("https://127.0.0.1:2443"))
    });

    let https_routes = warp::any().map(|| {
        println!("This is https server");
        "Hello, World! You are connected through tls connection."
    });

    let (_http_addr, http_warp) = warp::serve(http_routes)
        .bind_ephemeral(([127, 0, 0, 1], 2080));

    let (_https_addr, https_warp) = warp::serve(https_routes)
        .tls()
        .cert_path("examples/tls/cert.pem")
        .key_path("examples/tls/key.rsa")
        .bind_ephemeral(([127, 0, 0, 1], 2443));

    future::join(http_warp, https_warp).await;
}

http: // localhost: 2080 / http перенаправляет на: https://127.0.0.1:2443/

Hello, World! You are connected through tls connection.

stuart 08.12.2020

Одновременное обслуживание на нескольких портах (http, https) с использованием фреймворка warp в Rust

Ответы (2)

Вопросы по теме