Go语言通过goroutine和channel实现并发，利用HTTP Range头分块下载文件，结合HEAD请求获取文件信息，按字节范围并发下载多个片段，使用信号量控制协程数量，每块独立下载后合并，并支持错误重试机制。
在Go语言中，并没有传统意义上的“多线程”概念，而是通过goroutine和channel实现高效的并发处理。文件下载的并发优化通常采用分块并发下载的方式，即将一个大文件分成多个部分，每个部分由独立的goroutine并发下载，最后合并成完整文件。
1. 原理：HTTP Range 请求实现分块下载
要实现多段并发下载，核心是利用HTTP协议的Range头。服务器支持时，可以通过指定字节范围获取文件的一部分：
GET /file.zip HTTP/1.1Host: example.com
Range: bytes=0-999
响应状态码为206 Partial Content7>，返回指定字节范围的数据。
实现前需先发送HEAD请求，获取文件总大小和是否支持Range：
立即学习“go语言免费学习笔记（深入）”；
resp, err := http.Head(url)
if err != nil || resp.StatusCode != 200 {
log.Fatal("不支持下载或无法获取文件信息")
}
if resp.Header.Get("Accept-Ranges") != "bytes" {
log.Fatal("服务器不支持分块下载")
}
fileSize := resp.ContentLength
2. 分块策略与并发控制
将文件按大小分块，每块由一个goroutine负责下载。避免开启过多goroutine导致系统资源耗尽，使用信号量模式或固定worker池控制并发数。
示例：将文件分为10块，最多同时运行4个下载协程：
const numWorkers = 4 const numChunks = 10var wg sync.WaitGroup sem := make(chan struct{}, numWorkers) // 控制并发
for i := 0; i < numChunks; i++ { start := fileSize i / numChunks end := fileSize (i+1) / numChunks - 1 if i == numChunks-1 { end = fileSize - 1 // 最后一块包含剩余字节 }
wg.Add(1) go func(partID int, start, end int64) { defer wg.Done() sem <- struct{}{} // 获取信号量 defer func() { <-sem }() downloadChunk(url, partID, start, end) }(i, start, end)} wg.Wait() // 等待所有块下载完成
3. 下载单个数据块并写入临时文件
每个goroutine发起带Range头的GET请求，将数据写入对应的临时文件（如 file.part0、file.part1）：
func downloadChunk(url string, partID int, start, end int64) error { client := &http.Client{} req, _ := http.NewRequest("GET", url, nil) req.Header.Set("Range", fmt.Sprintf("bytes=%d-%d", start, end))resp, err := client.Do(req) if err != nil || resp.StatusCode > 299 { return fmt.Errorf("下载失败: %v", err) } defer resp.Body.Close() file, err := os.Create(fmt.Sprintf("file.part%d", partID)) if err != nil { return err } defer file.Close() io.Copy(file, resp.Body) return nil}
4. 合并分块文件
所有分块下载完成后，按顺序合并到最终文件：
outFile, _ := os.Create("output.file") defer outFile.Close()for i := 0; i < numChunks; i++ { partFile, _ := os.Open(fmt.Sprintf("file.part%d", i)) io.Copy(outFile, partFile) partFile.Close() os.Remove(fmt.Sprintf("file.part%d", i)) // 删除临时文件 }
合并时确保顺序正确，否则文件内容会错乱。
5. 错误处理与重试机制
网络不稳定可能导致某个块下载失败。可为每个块设置重试逻辑：
for i := 0; i < 3; i++ { err := downloadChunk(...) if err == nil { break } time.Sleep(time.Second << i) // 指数退避 }也可记录失败块，在主流程结束后统一重试。
基本上就这些。Golang通过轻量级goroutine让并发下载变得简单高效，结合HTTP Range和合理的并发控制，能显著提升大文件下载速度。实际项目中可封装成通用库，支持断点续传、进度显示等功能。不复杂但容易忽略细节，比如Range边界、文件合并顺序和并发安全。
