答案:通过自定义ProgressReader包装文件流,结合multipart请求实现上传进度监控。首先创建实现io.Reader接口的ProgressReader,读取时累计字节数并触发回调;然后用multipart.Writer构建表单,将ProgressReader注入文件字段;最后通过http.Client发送请求,在update函数中实时输出进度百分比。需注意大文件分块、资源释放与错误处理。

Go语言实现文件上传进度显示,关键在于监控上传过程中的数据传输量。虽然标准库net/http不直接提供进度回调机制,但通过自定义io.Reader包装器,我们可以实时捕获已发送的字节数,并结合HTTP客户端完成进度反馈。
1. 使用自定义Reader监控上传进度
核心思路是创建一个包装原始文件流的ProgressReader,在读取过程中累计已传输字节数,并调用回调函数更新进度。
type ProgressReader struct {
file io.Reader
total int64
read int64
update func(read, total int64)
}
func (pr *ProgressReader) Read(p []byte) (n int, err error) {
n, err = pr.file.Read(p)
pr.read += int64(n)
if pr.update != nil {
pr.update(pr.read, pr.total)
}
return
}
2. 构建multipart/form-data请求
上传文件通常使用multipart/form-data格式。我们需要手动构造请求体,并将ProgressReader注入到文件字段中。
步骤包括:
- 创建
bytes.Buffer作为请求体缓冲区 - 使用
multipart.Writer写入表单字段 - 为文件字段写入时,用
ProgressReader包装原始文件 - 设置请求头
Content-Type为生成的boundary值
3. 发送HTTP请求并显示进度
将包装后的请求体传给http.Post或http.Client.Do,并在回调中打印或处理进度信息。
立即学习“go语言免费学习笔记(深入)”;
实际调用示例:
file, _ := os.Open("example.zip")
defer file.Close()
fileStat, _ := file.Stat()
body := &bytes.Buffer{}
writer := multipart.NewWriter(body)
// 添加其他字段
writer.WriteField("user", "gopher")
// 包装文件流
progressReader := &ProgressReader{
file: file,
total: fileStat.Size(),
update: func(read, total int64) {
fmt.Printf("\r上传进度: %.2f%%", float64(read)/float64(total)*100)
},
}
fileWriter, _ := writer.CreateFormFile("upload", "example.zip")
io.Copy(fileWriter, progressReader)
writer.Close()
req, _ := http.NewRequest("POST", "https://api.example.com/upload", body)
req.Header.Set("Content-Type", writer.FormDataContentType())
client := &http.Client{}
resp, err := client.Do(req)
if err != nil {
log.Fatal(err)
}
defer resp.Body.Close()
fmt.Println("\n上传完成,状态码:", resp.Status)
4. 注意事项与优化建议
在真实项目中还需考虑以下几点:
- 大文件上传建议分块处理,避免内存溢出
- 可结合
context实现上传超时和取消功能 - 进度回调可用于UI更新(如CLI进度条、Web前端通信)
- 生产环境应增加错误重试和断点续传逻辑
- 注意关闭所有资源,防止文件描述符泄漏










