Golang如何实现多文件并发上传-Golang-PHP中文网

Golang如何实现多文件并发上传

P粉602998670

发布： 2025-11-08 23:19:07

原创

184人浏览过

使用goroutine和channel实现Go语言多文件并发上传，通过限制并发数、设置超时与重试机制提升稳定性。

golang如何实现多文件并发上传

Go语言实现多文件并发上传，核心是结合HTTP客户端与并发控制机制。直接使用 goroutine 发起多个上传请求能提升效率，但需注意资源占用和连接管理。下面分步骤说明如何安全高效地实现。

1. 基础上传逻辑封装

每个文件上传可封装成独立函数，接收文件路径和目标URL。使用 multipart/form-data 格式编码数据：

func uploadFile(filePath, url, fieldName string) error {
    file, err := os.Open(filePath)
    if err != nil {
        return err
    }
    defer file.Close()
<pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">body := &bytes.Buffer{}
writer := multipart.NewWriter(body)
part, err := writer.CreateFormFile(fieldName, filepath.Base(filePath))
if err != nil {
    return err
}
_, err = io.Copy(part, file)
if err != nil {
    return err
}

err = writer.Close()
if err != nil {
    return err
}

req, err := http.NewRequest("POST", url, body)
if err != nil {
    return err
}
req.Header.Set("Content-Type", writer.FormDataContentType())

client := &http.Client{}
resp, err := client.Do(req)
if err != nil {
    return err
}
defer resp.Body.Close()

if resp.StatusCode != http.StatusOK {
    return fmt.Errorf("upload failed: %s", resp.Status)
}
return nil

登录后复制

}

2. 使用 Goroutine 并发执行

将多个文件的上传任务用 goroutine 启动，通过 channel 控制完成状态或错误反馈：

android rtsp流媒体播放介绍中文WORD版

本文档主要讲述的是android rtsp流媒体播放介绍；实时流协议（RTSP）是应用级协议，控制实时数据的发送。RTSP提供了一个可扩展框架，使实时数据，如音频与视频，的受控、点播成为可能。数据源包括现场数据与存储在剪辑中数据。该协议目的在于控制多个数据发送连接，为选择发送通道，如UDP、组播UDP与TCP，提供途径，并为选择基于RTP上发送机制提供方法。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看

查看详情

立即学习“go语言免费学习笔记（深入）”；

files := []string{"file1.jpg", "file2.pdf", "file3.txt"}
url := "https://example.com/upload"
sem := make(chan struct{}, 5) // 控制最大并发数为5
errCh := make(chan error, len(files))
<p>for _, f := range files {
go func(filePath string) {
sem <- struct{}{} // 获取信号量
defer func() { <-sem }()</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">    err := uploadFile(filePath, url, "file")
    if err != nil {
        errCh <- fmt.Errorf("%s: %w", filePath, err)
        return
    }
    errCh <- nil
}(f)

登录后复制

}

// 等待所有任务完成 for i := 0; i < len(files); i++ { if err := <-errCh; err != nil { log.Printf("Upload error: %v", err) } }

3. 优化建议

限制并发数量：避免创建过多 goroutine 导致系统负载过高，使用带缓冲的 channel 或第三方库如 golang.org/x/sync/semaphore 控制并发度。
设置超时：给 HTTP 客户端设置合理的超时时间，防止卡住：

client := &http.Client{
    Timeout: 30 * time.Second,
}

登录后复制

进度反馈：若需显示上传进度，可在 io.Copy 时包装 io.Reader，定期更新已传输字节数。
重试机制：对网络失败的请求添加有限重试，提升稳定性。

基本上就这些。Go 的轻量级协程加上良好的控制手段，能让多文件上传既快又稳。

以上就是Golang如何实现多文件并发上传的详细内容，更多请关注php中文网其它相关文章！

大家都在看：

Go语言中[]uint8字节切片与float64浮点数的高效互转指南深度解析CORS预检请求：解决自定义Header导致的OPTIONS请求失败 Go语言中正确终止子进程：使用进程组管理 Go语言中实现JSON字段名动态映射的教程 Go语言中检测用户管理员权限：操作系统层面的考量与实践