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 多次调用失效的陷阱，构建出高可靠性的文件下载模块。
