在Golang中实现多文件并发上传，核心是利用goroutine开启多个并发任务分别处理单个文件的上传，再通过sync.WaitGroup控制所有任务完成后的流程，最后用channel收集每个文件的上传结果。这种方式可以大幅提升多文件上传的整体效率，避免单个文件上传阻塞后续任务。
核心依赖与概念说明
实现多文件并发上传需要用到以下几个核心组件：
- goroutine：Golang的轻量级线程，用来开启并发的上传任务，每个goroutine处理一个文件的上传逻辑。
- sync.WaitGroup：用来等待所有goroutine执行完成，避免主线程提前退出导致任务未完成。
- channel：用来在goroutine和主线程之间传递每个文件的上传结果，比如上传是否成功、文件路径等信息。
完整实现代码示例
下面的代码模拟了从本地读取多个文件，然后并发上传到服务器的逻辑，上传逻辑用模拟函数代替，实际使用时可以替换为真实的上传接口调用。
package main
import (
"fmt"
"io/ioutil"
"path/filepath"
"sync"
"time"
)
// 模拟单个文件上传的函数，实际使用时替换为真实的上传逻辑
func uploadFile(filePath string, resultChan chan<- string, wg *sync.WaitGroup) {
// 函数执行完成后，WaitGroup计数器减1
defer wg.Done()
// 模拟上传耗时
time.Sleep(time.Second * 2)
// 模拟上传结果，实际可以返回上传后的文件地址或者错误信息
result := fmt.Sprintf("文件 %s 上传成功", filePath)
// 将结果发送到channel
resultChan <- result
}
func main() {
// 需要上传的文件目录，实际使用时替换为真实路径
fileDir := "./upload_files"
// 读取目录下所有文件
files, err := ioutil.ReadDir(fileDir)
if err != nil {
fmt.Printf("读取文件目录失败：%vn", err)
return
}
// 如果没有文件则直接返回
if len(files) == 0 {
fmt.Println("目标目录下没有可上传的文件")
return
}
// 创建结果channel，用来收集每个文件的上传结果
resultChan := make(chan string, len(files))
// 创建WaitGroup，用来等待所有上传任务完成
var wg sync.WaitGroup
// 遍历所有文件，开启goroutine并发上传
for _, file := range files {
// 拼接完整文件路径
filePath := filepath.Join(fileDir, file.Name())
// WaitGroup计数器加1
wg.Add(1)
// 开启goroutine执行上传
go uploadFile(filePath, resultChan, &wg)
}
// 开启一个goroutine等待所有任务完成，然后关闭结果channel
go func() {
wg.Wait()
close(resultChan)
}()
// 从channel中读取所有上传结果并打印
for result := range resultChan {
fmt.Println(result)
}
fmt.Println("所有文件上传任务完成")
}
代码逻辑解析
1. 文件读取与前置校验
首先通过ioutil.ReadDir读取指定目录下的所有文件，判断目录是否存在以及是否有可上传的文件，避免后续逻辑出现异常。如果目录读取失败或者没有文件，直接返回错误信息。
2. 并发任务控制
遍历所有文件时，每处理一个文件就调用wg.Add(1)增加WaitGroup的计数器，然后开启goroutine执行uploadFile函数，在函数开头使用defer wg.Done()保证任务完成后计数器减1。这样可以准确跟踪所有并发任务的状态。
3. 结果收集与流程收尾
每个上传任务完成后会将结果发送到resultChan，同时单独开启一个goroutine等待所有任务完成（wg.Wait()），之后再关闭resultChan，避免主线程读取channel时出现死锁。主线程通过for range循环读取channel中的所有结果，直到channel关闭，最后输出所有任务完成的提示。
注意事项
- 如果上传的文件数量非常多，不建议无限制开启goroutine，可以通过带缓冲的channel实现 goroutine 池，控制并发数量，避免占用过多系统资源。
- 实际的上传逻辑中需要添加错误处理，比如文件读取失败、上传接口调用失败等情况，需要将错误信息也通过channel传递出来，方便后续排查问题。
- 如果上传需要携带认证信息或者其他公共参数，可以通过闭包或者参数传递的方式给每个goroutine传入对应的参数，避免参数共享导致的并发问题。
Golang多文件并发上传goroutinechannelsync_WaitGroup修改时间：2026-07-23 14:03:21