当前位置：首页 > 文章列表 > Golang > Go教程 > Golang文件上传进度实现方法

Golang文件上传进度实现方法

2026-01-18 13:53:35 0浏览收藏

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《Golang文件上传进度实现教程》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

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

Golang如何实现文件上传进度显示_Golang文件上传进度项目实战

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，并在回调中打印或处理进度信息。

实际调用示例：

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)