使用goroutine和channel实现并发文件上传，通过限制并发数控制资源消耗。1. 将文件路径发送到任务channel；2. 启动固定数量worker执行uploadFile；3. 用WaitGroup等待所有任务完成；4. 设置HTTP超时与错误重试机制，确保稳定性。
在Golang中实现并发文件上传，关键在于合理使用goroutine、channel和HTTP客户端，同时控制资源消耗。下面是一个实用且安全的实现方式，适用于批量上传多个文件到远程服务器。
使用Goroutine并发上传文件
每个文件上传任务可以交给独立的goroutine处理，这样能显著提升整体上传速度，尤其是网络延迟较高的场景。
核心思路是：
- 将待上传的文件路径放入一个通道（channel）
- 启动固定数量的工作goroutine从通道中读取任务并执行上传
- 通过WaitGroup等待所有任务完成
示例代码片段：
立即学习“go语言免费学习笔记（深入）”；
func uploadFile(client *http.Client, filePath, serverURL string) error {
file, err := os.Open(filePath)
if err != nil {
return err
}
defer file.Close()
body := &bytes.Buffer{}
writer := multipart.NewWriter(body)
part, _ := writer.CreateFormFile("file", filepath.Base(filePath))
io.Copy(part, file)
writer.Close()
req, _ := http.NewRequest("POST", serverURL, body)
req.Header.Set("Content-Type", writer.FormDataContentType())
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}
控制并发数避免资源耗尽
直接为每个文件起一个goroutine可能导致系统打开太多连接，造成内存暴涨或被服务器限流。应使用带缓冲的channel或工作池限制并发数量。
推荐做法：
赣极购物商城网店建站软件系统
大小仅1兆左右 ，足够轻便的商城系统； 易部署，上传空间即可用，安全，稳定； 容易操作，登陆后台就可设置装饰网站； 并且使用异步技术处理网站数据，表现更具美感。 前台呈现页面，兼容主流浏览器，DIV+CSS页面设计； 如果您有一定的网页设计基础，还可以进行简易的样式修改，二次开发， 发布新样式，调整网站结构，只需修改css目录中的css.css文件即可。 商城网站完全独立，网站源码随时可供您下载
下载
- 定义一个大小固定的goroutine池
- 用channel作为任务队列分发文件路径
- 使用sync.WaitGroup同步主协程等待
控制并发的主逻辑：
func uploadFilesConcurrent(filePaths []string, serverURL string, concurrency int) {
var wg sync.WaitGroup
taskCh := make(chan string, len(filePaths))
// 填充任务
for _, fp := range filePaths {
taskCh <- fp
}
close(taskCh)
// 启动worker
client := &http.Client{Timeout: 30 * time.Second}
for i := 0; i < concurrency; i++ {
wg.Add(1)
go func() {
defer wg.Done()
for filePath := range taskCh {
if err := uploadFile(client, filePath, serverURL); err != nil {
log.Printf("Failed to upload %s: %v", filePath, err)
} else {
log.Printf("Uploaded %s successfully", filePath)
}
}
}()
}
wg.Wait()}
处理错误与超时
网络操作不可靠，并发上传必须妥善处理失败情况。
建议：
- 为http.Client设置合理的超时时间，防止goroutine阻塞
- 记录每个文件的上传错误，便于后续重试
- 可结合重试机制（如指数退避）提升稳定性
小贴士： 如果上传量极大，可以考虑引入context.Context来支持整体取消或超时控制。
基本上就这些。并发上传不复杂但容易忽略资源控制，按上述方式能平衡效率与稳定性。
