< 返回版块

黑豆腐 发表于 2020-01-03 06:37

Tags:rust

现在说到写应用,网络框架肯定是必不可少的。今天就给大家简单介绍一下hyper。hyper是一个偏底层的http库,支持HTTP/1和HTTP/2,支持异步Rust,并且同时提供了服务端和客户端的API支持。很多同学可能觉得既然hyper是个偏底层的框架,那是不是就不需要去了解了呢?首先很多上层的框架,比如rocketironreqwest底层都是基于hyper的。(关于Rust中各种网络开发框架,这里有个很全面的综述和比较。)所以如果在使用这些框架的时候遇到了一些问题,对hyper的了解肯定是有一定的帮助的。再者学习Rust的我们都是奔着成为大佬的路线去的,很难说不会有直接操作偏底层框架的需求。

Hello World

我们首先来实现一个简单的服务器端和客户端,支持最简单的GET操作。

服务器端

首先是依赖,除了hyper本身之外,我们还需要tokio的runtime去执行async函数

[dependencies]
hyper = "0.13"
tokio = { version = "0.2", features = ["full"] }

然后就是main.rs

use std::{convert::Infallible, net::SocketAddr};
use hyper::{Body, Request, Response, Server};
use hyper::service::{make_service_fn, service_fn};

// 返回200
async fn handle(_: Request<Body>) -> Result<Response<Body>, Infallible> {
    Ok(Response::new("Hello, World!\n".into()))
}

#[tokio::main]
async fn main() {
    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));

    // 从handle创建一个服务
    let make_svc = make_service_fn(|_conn| async {
        Ok::<_, Infallible>(service_fn(handle))
    });

    let server = Server::bind(&addr).serve(make_svc);

    // 运行server
    if let Err(e) = server.await {
        eprintln!("server error: {}", e);
    }
}

客户端

依赖同服务器端

use hyper::Client;
use hyper::body::HttpBody as _;
use tokio::io::{stdout, AsyncWriteExt as _};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {

    // 构建一个client,调用GET
    let client = Client::new();
    let uri = "http://127.0.0.1:3000".parse()?;
    let mut resp = client.get(uri).await?;
    println!("Response: {}", resp.status());
    
    // 将response(是个stream)输出到stdout
    while let Some(chunk) = resp.body_mut().data().await {
        stdout().write_all(&chunk?).await?;
    }

    Ok(())
}

先启动服务端,然后启动客户端,就可以看到服务端成功相应客户端的GET请求啦~

Response: 200 OK
Hello, World!

更真实的例子

下面我们通过实现一个echo服务主要看一下服务器端如何进行路由,以及如何支持POST请求

服务器端

依赖

[dependencies]
hyper = "0.13"
tokio = { version = "0.2", features = ["full"] }
futures-util = { version = "0.3", default-features = false }

代码

use futures_util::TryStreamExt;
use hyper::service::{make_service_fn, service_fn};
use hyper::{Body, Method, Request, Response, Server, StatusCode};

async fn echo(req: Request<Body>) -> Result<Response<Body>, hyper::Error> {
    let mut response = Response::new(Body::empty());

    // 通过req.method()和req.uri().path()来识别方法和请求路径
    match (req.method(), req.uri().path()) {
        (&Method::GET, "/") => {
            *response.body_mut() = Body::from("Try POSTing data to /echo");
        },
        (&Method::POST, "/echo") => {
            // 将POST的内容保持不变返回
            *response.body_mut() = req.into_body();
        },
        (&Method::POST, "/echo/uppercase") => {
            // 把请求stream中的字母都变成大写,并返回
            let mapping = req
                .into_body()
                .map_ok(|chunk| {
                    chunk.iter()
                        .map(|byte| byte.to_ascii_uppercase())
                        .collect::<Vec<u8>>()
                });

            // 把stream变成body
            *response.body_mut() = Body::wrap_stream(mapping);
        },
        (&Method::POST, "/echo/reverse") => {
            // 这里需要完整的body,所以需要等待全部的stream并把它们变为bytes
            let full_body = hyper::body::to_bytes(req.into_body()).await?;

            // 把body逆向
            let reversed = full_body.iter()
                .rev()
                .cloned()
                .collect::<Vec<u8>>();

            *response.body_mut() = reversed.into();
        },
        _ => {
            *response.status_mut() = StatusCode::NOT_FOUND;
        },
    };

    Ok(response)
}

#[tokio::main]
async fn main() {
    let addr = ([127, 0, 0, 1], 3000).into();

    let make_svc = make_service_fn(|_conn| async {
        Ok::<_, hyper::Error>(service_fn(echo))
    });

    let server = Server::bind(&addr).serve(make_svc);

    if let Err(e) = server.await {
        eprintln!("server error: {}", e);
    }
}

客户端

依赖和之前客户端一样。我们这里的代码以向/echo/reverse提交内容为echo的POST请求为例:

use hyper::Client;
use hyper::{Body, Method, Request};

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error + Send + Sync>> {
    let req = Request::builder()
        .method(Method::POST)
        .uri("http://127.0.0.1:3000/echo/reverse")
        .body(Body::from("echo"))?;


    let client = Client::new();
    let resp = client.request(req).await?;
    println!("Response: {}", resp.status());
    println!("{:?}", hyper::body::to_bytes(resp.into_body()).await.unwrap());

    Ok(())
}

依次启动服务端和客户端,就可以看到服务端响应了客户端的POST请求啦~

Response: 200 OK
b"ohce"

好了,对hyper的介绍就到这里了。接下来就靠大家自己去深似海的网络编程世界中去摸索啦~

评论区

写评论
c5soft 2020-01-03 08:53

没找到直接用hyper如何搭建https server的方法,有谁会?

1 共 1 条评论, 1 页