本文解析 io.CopyN 在 HTTP 下载中首次失败后持续返回 0 字节的根源，指出关键在于 HTTP 响应体不可重放，并提供基于 Range 请求与偏移量管理的可重试、断点续传式下载实现。
本文解析 `io.copyn` 在 http 下载中首次失败后持续返回 0 字节的根源，指出关键在于 http 响应体不可重放，并提供基于 range 请求与偏移量管理的可重试、断点续传式下载实现。
在 Go 网络编程中，一个常见误区是认为只要反复调用 io.CopyN(dst, src, n) 即可实现下载重试——但实际运行时，若首次复制失败（如网络中断、连接关闭），后续重试往往始终读取到 0 字节，如日志所示：copy_byte 恒为 0，且 res.ContentLength 与实际写入严重不符。根本原因在于：http.Response.Body 是一次性、不可重放的 io.ReadCloser 流。一旦 res.Body 被部分读取或关闭（即使隐式因错误而终止），其底层连接已失效或数据已丢弃；再次对其调用 io.CopyN 不会重新发起 HTTP 请求，而是试图从已耗尽/已关闭的流中读取，自然返回 0, io.EOF 或其他 I/O 错误。
因此，正确的重试逻辑必须重建整个 HTTP 请求链路，而非仅重试拷贝操作。理想方案应支持断点续传（Resume Download），即利用 HTTP Range 头请求剩余字节，既节省带宽又提升可靠性。
以下是一个生产就绪的可重试下载函数实现：
import (
"fmt"
"io"
"net/http"
"time"
)
// downloadFile 尝试从 URL 下载数据到 dst 文件，支持断点续传
// offset 表示已成功写入的字节数，函数返回累计写入总字节数及错误
func downloadFile(dst *os.File, url string, offset int64) (int64, error) {
req, err := http.NewRequest("GET", url, nil)
if err != nil {
return offset, fmt.Errorf("failed to create request: %w", err)
}
// 若已有偏移量，添加 Range 请求头（服务端支持时启用断点续传）
if offset > 0 {
req.Header.Set("Range", fmt.Sprintf("bytes=%d-", offset))
}
client := &http.Client{Timeout: 30 * time.Second}
res, err := client.Do(req)
if err != nil {
return offset, fmt.Errorf("HTTP request failed: %w", err)
}
defer res.Body.Close()
// 处理 Range 不支持场景：服务端返回 200 而非 206，需跳过已下载部分
if offset > 0 && res.StatusCode != http.StatusPartialContent {
// 注意：此处应使用 io.Discard 而非 ioutil.Discard（后者已弃用）
_, err = io.CopyN(io.Discard, res.Body, offset)
if err != nil {
return offset, fmt.Errorf("failed to skip %d bytes: %w", offset, err)
}
}
// 执行实际拷贝：注意 res.ContentLength 可能为 -1（未知长度），建议配合 io.Copy + 校验
n, err := io.CopyN(dst, res.Body, res.ContentLength)
if err != nil && err != io.EOF {
return offset, fmt.Errorf("copy failed: %w", err)
}
return offset + n, nil
}使用该函数构建健壮下载流程时，应配合指数退避重试策略，并显式管理文件偏移量：
func robustDownload(filepath, url string, maxRetries int) error {
f, err := os.OpenFile(filepath, os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0644)
if err != nil {
return fmt.Errorf("failed to open file: %w", err)
}
defer f.Close()
// 获取当前文件大小作为起始偏移量（支持续传）
fi, err := f.Stat()
if err != nil {
return fmt.Errorf("failed to stat file: %w", err)
}
offset := fi.Size()
delay := time.Second
for i := 0; i < maxRetries; i++ {
total, err := downloadFile(f, url, offset)
if err == nil {
fmt.Printf("Download completed: %s (%d bytes)\n", filepath, total)
return nil
}
fmt.Printf("Retry %d/%d failed: %v (offset: %d), retrying in %v...\n",
i+1, maxRetries, err, offset, delay)
time.Sleep(delay)
delay *= 2 // 指数退避
offset = total // 更新偏移量，确保下次从最新位置续传
}
return fmt.Errorf("download failed after %d retries", maxRetries)
}关键注意事项：
- ✅ 永远避免 goto 实现循环：它破坏控制流可读性，易引发资源泄漏（如 defer 失效）和逻辑错误；应使用 for 循环替代。
- ✅ res.ContentLength 可能为 -1（如分块传输编码），此时 io.CopyN 会 panic；更安全的做法是使用 io.Copy 并在结束后校验文件大小或哈希值。
- ✅ 生产环境应设置 http.Client.Timeout 和 Transport 参数（如 MaxIdleConnsPerHost），防止连接耗尽。
- ✅ 对于无 Range 支持的服务器，downloadFile 会回退至全量下载并跳过已写入部分，虽非最优但保证最终一致性。
综上，解决 io.CopyN 重试失效问题，本质是正确认知 HTTP 响应体的生命周期约束，并通过重建请求 + 偏移量管理 + 服务端协作（Range）构建弹性下载机制。
