如何使用Golang实现文件上传_使用MultipartReader处理上传数据
Go语言文件上传核心是用MultipartReader解析multipart/form-data请求体，适合大文件流式处理；需手动提取boundary、调用NextPart()遍历part、校验Content-Disposition，并设置MaxMemory防内存溢出。
Go语言处理文件上传，核心是用http.Request的MultipartReader（或更常用的ParseMultipartForm + FormFile）解析multipart/form-data请求体。直接操作MultipartReader适合大文件、流式处理或自定义解析逻辑，但需手动管理边界和Part解析。
理解 MultipartReader 的作用
MultipartReader 是 Go 标准库提供的底层接口，用于逐个读取 multipart 请求中的每个 part（如文本字段、文件字段）。它不自动解析整个表单，而是返回一个可迭代的multipart.Reader，配合NextPart()按需获取每个 part 的 header 和 body。
相比ParseMultipartForm（会把所有内容加载进内存或临时文件），MultipartReader 更轻量、可控，适合：
- 上传超大文件（避免内存爆满）
- 只关心特定字段（跳过无关 part）
- 需要实时校验或转换（如边读边解密、转码）
基础用法：用 MultipartReader 解析上传
关键步骤：从*http.Request获取multipart.NewReader，循环调用NextPart()，根据Content-Disposition头判断是普通字段还是文件。
- 检查请求 Content-Type 是否为
multipart/form-data，并提取 boundary - 用
multipart.NewReader(r.Body, boundary)创建 reader - 在
for part := range reader.NextPart()循环中处理每个 part - 通过
part.FormName()获取字段名，part.FileName()判断是否为文件 - 用
io.Copy或分块读取将文件内容保存到磁盘或其它存储
注意边界与安全细节
手动处理 multipart 容易忽略几个关键点：
-
必须设置 MaxMemory：即使不用
ParseMultipartForm，Go 默认仍会为小文件使用内存缓冲；可通过r.ParseMultipartForm(32 提前设定上限（如 32MB），否则可能被恶意大字段拖垮内存 -
校验文件名和类型：
part.FileName()可被伪造，务必清洗路径（如用filepath.Base）、限制扩展名、检查 MIME 类型（用part.Header.Get("Content-Type")或读取前几字节） -
及时关闭 part.Body：每个 part 的 Body 是
io.ReadCloser，不关闭会导致资源泄漏 -
超时与限速：对大文件上传，建议配合
http.TimeoutHandler或在读取时加入 context 超时控制
简单示例：接收单个文件并保存
以下代码跳过 ParseMultipartForm，直接用 MultipartReader 处理：
func uploadHandler(w http.ResponseWriter, r *http.Request) {
if r.Method != "POST" {
http.Error(w, "Method not allowed", http.StatusMethodNotAllowed)
return
}
// 检查 Content-Type
contentType := r.Header.Get("Content-Type")
if !strings.HasPrefix(contentType, "multipart/form-data") {
http.Error(w, "Invalid content type", http.StatusBadRequest)
return
}
// 提取 boundary（也可用 mime.ParseMediaType 解析）
boundary, _ := mime.ParseMediaType(contentType)
mr, err := multipart.NewReader(r.Body, boundary["boundary"])
if err != nil {
http.Error(w, "Invalid multipart data", http.StatusBadRequest)
return
}
for {
part, err := mr.NextPart()
if err == io.EOF {
break
}
if err != nil {
http.Error(w, "Error reading part", http.StatusInternalServerError)
return
}
filename := part.FileName()
if filename != "" {
// 安全文件名
safeName := filepath.Base(filename)
outFile, _ := os.Create("./uploads/" + safeName)
defer outFile.Close()
_, copyErr := io.Copy(outFile, part)
if copyErr != nil {
http.Error(w, "Failed to save file", http.StatusInternalServerError)
return
}
fmt.Printf("Saved: %s\n", safeName)
}
}
w.WriteHeader(http.StatusOK)
w.Writ
e([]byte("Upload OK"))}
注意：生产环境需补充错误处理、目录创建、文件大小限制、并发安全等。
基本上就这些。用 MultipartReader 不复杂但容易忽略边界和安全细节，日常开发中若无特殊需求，优先用 r.FormFile 更简洁；需要精细控制时，再上手 MultipartReader。
e([]byte("Upload OK"))