如何使用Rust Warp Multipart上传并保存图片？

AI 小北

2026-7-21

Rust Warp Multipart图片上传错误修复方案

错误原因

failed to lock multipart state错误是因为你先通过form.try_collect().await一次性收集所有Multipart Part到Vec中，这会消耗并锁定FormData的内部状态，导致后续访问单个Part的stream时出现状态锁定冲突。Warp的FormData是异步流，必须逐个处理Part，而非提前批量收集。

修正后的代码

use warp::{multipart::Part, Reply, Rejection};
use std::fs;
use std::io::Write;

pub async fn photos(mut form: warp::multipart::FormData) -> Result<impl Reply, Rejection> {
    // 提前创建uploads目录，避免重复执行
    fs::create_dir_all("uploads").map_err(|e| {
        eprintln!("创建uploads目录失败: {}", e);
        warp::reject::reject()
    })?;

    // 逐个处理每个Multipart Part
    while let Some(part) = form.try_next().await.map_err(|e| {
        eprintln!("表单解析错误: {}", e);
        warp::reject::reject()
    })? {
        eprintln!("{:#?}", part);

        let filename = part.filename().unwrap_or("photo.png");
        let filepath = format!("uploads/{}", filename);

        // 创建目标文件
        let mut file = fs::File::create(&filepath).map_err(|e| {
            eprintln!("创建文件失败: {}", e);
            warp::reject::reject()
        })?;

        // 遍历Part的所有数据块，写入文件
        let mut stream = part.stream();
        while let Some(chunk) = stream.try_next().await.map_err(|e| {
            eprintln!("数据流读取错误: {}", e);
            warp::reject::reject()
        })? {
            file.write_all(&chunk).map_err(|e| {
                eprintln!("写入文件失败: {}", e);
                warp::reject::reject()
            })?;
        }
    }

    Ok("上传成功!")
}