Rust + Warp 构建高性能 REST API 全程指南

一、为什么选择 Warp？

• 异步原生：基于 Tokio，性能极致
• 类型安全：组合子路由，编译期保证
• 轻量简洁：零样板，快速上手
• 生态成熟：内置 JSON、WebSocket、JWT 等中间件

💡 AI 助攻
想自动生成带注释的 Cargo.toml？用「代码生成」提示词，30 秒即可拿到模板，再交给「代码优化」砍掉冗余特性，编译速度提升 20%！

二、技术栈与版本

三、项目初始化与依赖

cargo new neat-api --bin
cd neat-api

Cargo.toml 关键依赖：

[dependencies]
warp = "0.3"
tokio = { version = "1", features = ["full"] }
serde = { version = "1.0", features = ["derive"] }
parking_lot = "0.12"

四、Hello, Warp! —— 最小可运行示例

use warp::Filter;

#[tokio::main]
async fn main() {
    let hello = warp::path!("hello" / String)
        .map(|name| format!("Hello, {}!", name));

    warp::serve(hello)
        .run(([127, 0, 0, 1], 3030))
        .await;
}

运行 & 测试：

cargo run
# 另开终端
curl http://localhost:3030/hello/warp
# → Hello, warp!

🔍 AI 审查
把「路由组合子」提交评审？「代码审查助手」可自动检查路径参数类型、并发安全，提前发现 80% 潜在 Bug！

五、CRUD 实战：杂货清单 API

1. 定义模型与存储

use parking_lot::RwLock;
use std::collections::HashMap;
use std::sync::Arc;
use serde::{Deserialize, Serialize};

type Items = HashMap<String, i32>;

#[derive(Debug, Deserialize, Serialize, Clone)]
struct Item {
    name: String,
    quantity: i32,
}

#[derive(Clone)]
struct Store {
    grocery_list: Arc<RwLock<Items>>,
}

impl Store {
    fn new() -> Self {
        Store {
            grocery_list: Arc::new(RwLock::new(HashMap::new())),
        }
    }
}

2. 添加商品（POST）

async fn add_grocery_list_item(
    item: Item,
    store: Store,
) -> Result<impl warp::Reply, warp::Rejection> {
    store.grocery_list.write().insert(item.name, item.quantity);
    Ok(warp::reply::with_status(
        "Item added to the grocery list",
        warp::http::StatusCode::CREATED,
    ))
}

fn json_body() -> impl Filter<Extract = (Item,), Error = warp::Rejection> + Clone {
    warp::body::content_length_limit(1024 * 16).and(warp::body::json())
}

路由注册：

let add_items = warp::post()
    .and(warp::path("v1"))
    .and(warp::path("groceries"))
    .and(warp::path::end())
    .and(json_body())
    .and(store_filter.clone())
    .and_then(add_grocery_list_item);

3. 获取清单（GET）

async fn get_grocery_list(
    store: Store,
) -> Result<impl warp::Reply, warp::Rejection> {
    let result = store.grocery_list.read();
    Ok(warp::reply::json(&*result))
}

let get_items = warp::get()
    .and(warp::path("v1"))
    .and(warp::path("groceries"))
    .and(warp::path::end())
    .and(store_filter.clone())
    .and_then(get_grocery_list);

测试：

curl http://localhost:3030/v1/groceries

4. 更新与删除（PUT & DELETE）

更新商品

async fn update_grocery_list(
    item: Item,
    store: Store,
) -> Result<impl warp::Reply, warp::Rejection> {
    store.grocery_list.write().insert(item.name, item.quantity);
    Ok(warp::reply::with_status(
        "Item updated in the grocery list",
        warp::http::StatusCode::OK,
    ))
}

删除商品

#[derive(Debug, Deserialize, Serialize, Clone)]
struct Id {
    name: String,
}

async fn delete_grocery_list_item(
    id: Id,
    store: Store,
) -> Result<impl warp::Reply, warp::Rejection> {
    store.grocery_list.write().remove(&id.name);
    Ok(warp::reply::with_status(
        "Item removed from the grocery list",
        warp::http::StatusCode::OK,
    ))
}

路由合并：

let routes = add_items
    .or(get_items)
    .or(update_item)
    .or(delete_item);

warp::serve(routes)
    .run(([127, 0, 0, 1], 3030))
    .await;

六、完整测试命令

# 1. 添加
curl -X POST localhost:3030/v1/groceries \
  -H "Content-Type: application/json" \
  -d '{"name":"apple","quantity":3}'

# 2. 查询
curl localhost:3030/v1/groceries

# 3. 更新
curl -X PUT localhost:3030/v1/groceries \
  -H "Content-Type: application/json" \
  -d '{"name":"apple","quantity":5}'

# 4. 删除
curl -X DELETE localhost:3030/v1/groceries \
  -H "Content-Type: application/json" \
  -d '{"name":"apple"}'

✅ AI 补救
把「curl 测试命令」写进 README 太麻烦？用「代码文档生成器」提示词，自动在函数头部生成标准注释，提醒后续接入 Postman 集合，文档一键达标！

七、进阶路线图

八、总结与下一步

通过本教程，你已掌握：

• Warp 异步路由与过滤器组合
• 线程安全共享状态（Arc<RwLock<T>>）
• JSON 自动序列化/反序列化
• 完整 CRUD 端点实现

下一步可添加认证、分页、OpenAPI 文档等功能，打造生产级后端。祝编码愉快！

今晚就 push 到 GitHub，明天就能用 Fly.io 一键部署！🚀

原文链接: https://blog.logrocket.com/building-rest-api-rust-warp/