当前位置：首页 > article >正文

轻量级、高性能的 Rust HTTP 服务器库 —— Hyperlane

article 2025/3/18 23:01:31

轻量级、高性能的 Rust HTTP 服务器库 —— Hyperlane

在当今的 web 开发领域，选择一个高效、可靠的服务器框架对于项目的成功至关重要。今天，我要向大家推荐一款优秀的 Rust HTTP 服务器库 —— Hyperlane。

一、卓越性能，数据说话

Hyperlane 在性能方面表现出色，经过专业压测工具 wrk 和 ab 的测试，在高并发场景下展现出了惊人的处理能力。

wrk 压测结果

在使用 wrk 进行的压测中，Hyperlane 在 360 并发、持续 60 秒的测试条件下，取得了每秒 324323.71 次请求（QPS）的优异成绩。这一结果不仅体现了 Hyperlane 在高并发场景下的高效处理能力，更证明了其在面对大量请求时的稳定性。

ab 压测结果

而在使用 ab 进行的压测中，Hyperlane 在 1000 并发、100 万请求的测试环境下，每秒请求数（QPS）达到了 307568.90。这样的性能表现使其在众多框架中脱颖而出，为开发者提供了高效、稳定的服务器解决方案。

二、简洁易用，快速上手

Hyperlane 的安装和使用非常简单，只需运行一条命令即可开始使用：

cargo add hyperlane

同时，Hyperlane 提供了详细的快速入门教程和示例代码，帮助开发者快速熟悉其功能和用法。无论是新手还是有经验的开发者，都能轻松地将 Hyperlane 集成到自己的项目中。

三、功能丰富，满足多样需求

Hyperlane 不仅性能卓越，还具备丰富的功能，能够满足各种 web 开发需求。

HTTP 请求解析与响应构建

Hyperlane 支持 HTTP 请求的解析和响应的构建，让开发者能够轻松处理客户端请求并返回相应的响应。

TCP 通信

它还支持 TCP 通信，为开发者提供了底层的网络通信能力，方便实现更复杂的网络应用。

中间件支持

Hyperlane 支持请求和响应中间件，开发者可以在请求处理流程中添加自定义的中间件逻辑，实现如日志记录、身份验证等功能。

WebSocket 和服务器发送事件（SSE）

Hyperlane 实现了灵活高效的实时通信，支持 WebSocket 和服务器发送事件（SSE），适用于需要实时数据交互的应用场景。

四、示例代码，直观展示

以下是一个简单的 Hyperlane 使用示例，展示了如何定义请求中间件、响应中间件以及路由处理函数：

use hyperlane::*;

async fn request_middleware(controller_data: ControllerData) {
    let socket_addr: String = controller_data.get_socket_addr_or_default_string().await;
    controller_data
        .set_response_header(SERVER, HYPERLANE)
        .await
        .set_response_header(CONNECTION, CONNECTION_KEEP_ALIVE)
        .await
        .set_response_header(CONTENT_TYPE, content_type_charset(TEXT_PLAIN, UTF8))
        .await
        .set_response_header(DATE, current_date_gmt())
        .await
        .set_response_header("SocketAddr", socket_addr)
        .await;
}

async fn response_middleware(controller_data: ControllerData) {
    let _ = controller_data.send().await;
    let request: String = controller_data.get_request_string().await;
    let response: String = controller_data.get_response_string().await;
    controller_data
        .log_info(request, log_handler)
        .await
        .log_info(response, log_handler)
        .await;
}

async fn root_route(controller_data: ControllerData) {
    controller_data
        .set_response_status_code(200)
        .await
        .set_response_body("Hello hyperlane => /")
        .await;
}

async fn websocket_route(controller_data: ControllerData) {
    let request_body: Vec<u8> = controller_data.get_request_body().await;
    let _ = controller_data.send_response_body(request_body).await;
}

async fn run_server() {
    let mut server: Server = Server::new();
    server.host("0.0.0.0").await;
    server.port(60000).await;
    server.log_dir("./logs").await;
    server.enable_inner_log().await;
    server.enable_inner_print().await;
    server.log_size(100_024_000).await;
    server.log_interval_millis(1000).await;
    server.websocket_buffer_size(4096).await;
    server.request_middleware(request_middleware).await;
    server.response_middleware(response_middleware).await;
    server.route("/", root_route).await;
    server.route("/websocket", websocket_route).await;
    let test_string: String = "Hello hyperlane".to_owned();
    server
        .route(
            "/test/panic",
            async_func!(test_string, |data| {
                println_success!(test_string);
                println_success!(format!("Using external variables {:?}", data));
                panic!("Test panic");
            }),
        )
        .await;
    server.listen().await;
}