使用Rust中的warp框架同时在多个端口(http，https)上提供服务

我想使用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 上侦听

我也尝试过未来：：加入

#[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`

运行这个程序完全是一件简单的事情，那就是删除？将await语句的后缀放在末尾，并放置分号。

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

就是这样。现在两个期货同时运行，因此它在两个端口上都侦听。

以下是kanudo的解决方案，作为warp 中tls-https重定向的完整工作示例

cert.pem

密钥.rsa

货物.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.

相关内容

最新更新

热门标签：