如何停止超级HTTP Web服务器并返回错误? [英] How can I stop the hyper HTTP web server and return an error?

问题描述

超级箱子的文档有一个简单的示例来启动网站服务器:

The docs for the hyper crate have a simple example to start a web server:

extern crate hyper;

use hyper::service::service_fn_ok;
use hyper::{Body, Response, Server};

fn main() {
    // Construct our SocketAddr to listen on...
    let addr = ([127, 0, 0, 1], 3000).into();

    // And a NewService to handle each connection...
    let new_service = || service_fn_ok(|_req| Response::new(Body::from("Hello World")));

    // Then bind and serve...
    let server = Server::bind(&addr).serve(new_service);

    // Finally, spawn `server` onto an Executor...
    hyper::rt::run(server.map_err(|e| {
        eprintln!("server error: {}", e);
    }));
}

我想将此Web服务器嵌入返回错误的过程中:

I want to embed this web server in a procedure that returns an error:

// Executes a web server. Returns a result object with an error object
// if the server stopped unexpectedly
fn run_and_stop_web_server(addr: std::net::SocketAddr) -> Result<(), Error> {
    let server_builder = Server::try_bind(&addr)?;
    let server = server_builder.serve(move || {
        let handler: Handler = Handler::new();
        hyper::service::service_fn(move |req| handler.serve(req))
    });

    // Run the server
    // HERE: I don't know how to handle the error so I can return it from
    //       the run_and_stop_web_server() function
    hyper::rt::run(server.map_err(|e| eprintln!("Ignored Server error: {}", e)));
    Result::Ok(())
}

我不知道如何处理该错误.我要使用run_and_stop_web_server函数返回错误，而不是使用eprintln!().

I don't know how I can handle the error. Instead of using eprintln!() I want to return the error from the run_and_stop_web_server function.

推荐答案

我相信我找到了直接使用tokio运行时的解决方案...它可以编译.请任何人告诉我我是否错在这里.

I believe I found a solution using the tokio runtime directly... It compiles. Please anyone tell me if I'm wrong here.

这个想法是使用tokio 运行时直接(文档有很多示例):

The idea is to use the tokio Runtime directly (docs have many examples):

use tokio::runtime::Runtime;

// Executes a web server. Returns a result object with an error object
// if the server stopped unexpectedly
fn run_and_stop_web_server(addr: std::net::SocketAddr) -> Result<(), Error> {
    let server_builder = Server::try_bind(&addr)?;
    let server = server_builder.serve(move || {
        let handler: Handler = Handler::new();
        hyper::service::service_fn(move |req| handler.serve(req))
    });

    let mut rt = Runtime::new()?;
    rt.block_on(server)?;
    rt.shutdown_now();

    Result::Ok(())
}

这篇关于如何停止超级HTTP Web服务器并返回错误?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！