io.copyN 在首次调用失败后反复重试仍返回 0 字节，是因为 http 响应体（res.Body）为一次性读取流，已关闭或耗尽；重试必须重新发起 HTTP 请求，而非仅重试拷贝操作。
`io.copyn` 在首次调用失败后反复重试仍返回 0 字节，是因为 http 响应体（`res.body`）为一次性读取流，已关闭或耗尽；重试必须重新发起 http 请求，而非仅重试拷贝操作。
在 go 网络编程中，io.CopyN(dst, src, n) 是一个看似简单却极易误用的函数——它从 src（如 http.Response.Body）精确复制 n 字节到 dst（如文件），但其底层依赖 src 的可重复读取能力。而 http.Response.Body 是一个单次消费（one-shot）的 io.ReadCloser：一旦读取完毕、发生错误或被显式关闭，其内部缓冲即失效，后续任何读取（包括再次调用 io.CopyN）都将立即返回 0, io.EOF 或其他永久性错误。
观察原始代码中的关键问题：
- ✅ 正确获取了 res.ContentLength 并作为拷贝目标字节数；
- ❌ 错误地假设 res.Body 可多次读取 —— 实际上 res.Body 在首次 io.CopyN 返回错误（如网络中断、超时）后，连接已关闭或流已耗尽；
- ❌ 使用 goto download_again 循环重试 io.CopyN，但 res.Body 未重建，导致后续所有调用均读取 0 字节（如日志中 0.000000 KB(0 B) 所示）；
- ❌ 缺少对 res.Body 的显式关闭（虽 defer 通常处理，但在重试逻辑中易遗漏）。
正确做法：重试必须重建 HTTP 请求
核心原则：*每次重试都应生成全新的 `http.Response，从而获得全新的、可读的Body`**。以下是推荐的健壮实现方案：
func downloadImage(url, filename string, maxRetries int) error { var ( f *os.File err error ) // 创建文件（注意：应在每次重试前确保文件可写，或使用临时文件+原子重命名） if f, err = os.Create(filename); err != nil { return fmt.Errorf("failed to create file %s: %w", filename, err) } defer f.Close() var offset int64 = 0 delay := time.Second for i := 0; i <= maxRetries; i++ { // 每次重试：新建 HTTP 请求 resp, err := http.Get(url) if err != nil { if i == maxRetries { return fmt.Errorf("HTTP request failed after %d retries: %w", maxRetries, err) } fmt.Printf("Retry %d/%d: HTTP GET failed: %v, waiting %v...n", i+1, maxRetries, err, delay) time.Sleep(delay) delay *= 2 // 指数退避 continue } defer resp.Body.Close() // 注意：此处 defer 作用域为本次循环，安全 // 验证状态码 if resp.StatusCode < 200 || resp.StatusCode >= 300 { if i == maxRetries { return fmt.Errorf("HTTP %d for %s", resp.StatusCode, url) } fmt.Printf("Retry %d/%d: unexpected status %d, waiting %v...n", i+1, maxRetries, resp.StatusCode, delay) time.Sleep(delay) delay *= 2 continue } // 执行拷贝（此时 resp.Body 是全新、可用的） n, err := io.CopyN(f, resp.Body, resp.ContentLength) if err == nil && n == resp.ContentLength { fmt.Printf("✅ Success: downloaded %s (%d bytes)n", filename, n) return nil } // 拷贝失败：记录进度并重试（注意：此处不 seek，因文件是新创建的，offset 始终为 0） if i == maxRetries { return fmt.Errorf("copy failed after %d retries: copied %d/%d bytes, error: %w", maxRetries, n, resp.ContentLength, err) } fmt.Printf("⚠️ Retry %d/%d: copy only %d/%d bytes: %v, waiting %v...n", i+1, maxRetries, n, resp.ContentLength, err, delay) time.Sleep(delay) delay *= 2 } return nil }进阶建议：支持断点续传（Resumable Download）
若需下载大文件且服务端支持 Range 请求（如 nginx、apache），可进一步优化为断点续传，避免重复传输已成功部分：
func downloadWithResume(dst *os.File, url string, startOffset int64) (int64, error) { req, err := http.NewRequest("GET", url, nil) if err != nil { return startOffset, err } if startOffset > 0 { req.Header.Set("Range", fmt.Sprintf("bytes=%d-", startOffset)) } resp, err := http.DefaultClient.Do(req) if err != nil { return startOffset, err } defer resp.Body.Close() // 若服务端不支持 Range，则 StatusPartialContent 不会返回；需跳过已下载部分 if startOffset > 0 && resp.StatusCode != http.StatusPartialContent { _, err = io.CopyN(io.Discard, resp.Body, startOffset) if err != nil { return startOffset, err } } n, err := io.CopyN(dst, resp.Body, resp.ContentLength) return startOffset + n, err }调用时维护 offset 并循环重试即可实现真正的断点续传。
注意事项总结
- 永远不要复用 resp.Body：它是不可重置的一次性流，重试必新建请求；
- 及时关闭 resp.Body：使用 defer 时注意作用域（推荐在每次请求块内 defer resp.Body.Close()）；
- 避免 goto 控制流：Go 官方明确建议用 for/break 替代 goto，提升可读性与可维护性；
- 检查 ContentLength 可靠性：部分服务器可能不返回该 Header，此时应改用 io.Copy 并配合 io.LimitReader 防止 OOM；
- 考虑使用 io.Copy + context.WithTimeout：对超时控制更精细，比单纯重试 CopyN 更健壮。
通过理解 Go I/O 流的本质约束，并遵循“请求即资源、失败即重建”的设计原则，即可彻底规避 io.CopyN 多次调用失效的陷阱，构建出高可靠性的文件下载模块。