Golang HTTP 请求连续失败并返回 EOF 错误的解决方案

package main

import (
    "fmt"
    "io"
    "io/ioutil"
    "net/http"
    "time" // 引入 time 包用于模拟延迟
)

// SendRequest 模拟发送 HTTP 请求的函数
func SendRequest(method, url string, body io.Reader) ([]byte, error) {
    req, err := http.NewRequest(method, url, body)
    if err != nil {
        return nil, fmt.Errorf("创建请求失败: %w", err)
    }

    // 使用 http.DefaultClient 发送请求
    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        return nil, fmt.Errorf("发送请求失败: %w", err)
    }
    defer resp.Body.Close() // 确保响应体关闭

    if resp.StatusCode != http.StatusOK {
        return nil, fmt.Errorf("HTTP 响应状态码异常: %v", resp.Status)
    }

    b, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return nil, fmt.Errorf("读取响应体失败: %w", err)
    }

    return b, nil
}

// 示例：模拟连续请求
func main() {
    // 假设有一个本地的测试服务器或一个稳定的外部 API
    // 为了演示 EOF 错误，我们假设目标服务器可能在某些情况下提前关闭连接
    // 实际环境中，DefaultClient 的连接复用机制是导致此问题的主要原因
    urls := []string{
        "http://localhost:8080/data/1",
        "http://localhost:8080/data/2",
        "http://localhost:8080/data/3",
    }

    for i, url := range urls {
        fmt.Printf("--- 发送第 %d 个请求到 %s ---\n", i+1, url)
        _, err := SendRequest("GET", url, nil)
        if err != nil {
            fmt.Printf("请求失败: %v\n", err)
        } else {
            fmt.Println("请求成功")
        }
        time.Sleep(100 * time.Millisecond) // 模拟请求间隔
    }
}

package main

import (
    "fmt"
    "io"
    "io/ioutil"
    "net/http"
)

// SendRequestWithClose 强制关闭连接的 HTTP 请求函数
func SendRequestWithClose(method, url string, body io.Reader) ([]byte, error) {
    req, err := http.NewRequest(method, url, body)
    if err != nil {
        return nil, fmt.Errorf("创建请求失败: %w", err)
    }

    // 核心解决方案：强制关闭连接
    req.Close = true 

    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        return nil, fmt.Errorf("发送请求失败: %w", err)
    }
    defer resp.Body.Close()

    if resp.StatusCode != http.StatusOK {
        return nil, fmt.Errorf("HTTP 响应状态码异常: %v", resp.Status)
    }

    b, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return nil, fmt.Errorf("读取响应体失败: %w", err)
    }

    return b, nil
}

package main

import (
    "fmt"
    "io"
    "io/ioutil"
    "net/http"
    "time"
)

// CustomHTTPClient 预先配置好的自定义 HTTP 客户端
var CustomHTTPClient *http.Client

func init() {
    // 配置 Transport
    tr := &http.Transport{
        MaxIdleConns:        100,              // 最大空闲连接数
        IdleConnTimeout:     90 * time.Second, // 空闲连接的超时时间
        DisableKeepAlives:   false,            // 默认启用 Keep-Alive
        TLSHandshakeTimeout: 10 * time.Second, // TLS 握手超时时间
        // 如果需要禁用 HTTP/2，可以设置：
        // ForceAttemptHTTP2: false,
    }

    CustomHTTPClient = &http.Client{
        Timeout:   30 * time.Second, // 整个请求的超时时间
        Transport: tr,
    }
}

// SendRequestWithCustomClient 使用自定义客户端发送 HTTP 请求
func SendRequestWithCustomClient(method, url string, body io.Reader) ([]byte, error) {
    req, err := http.NewRequest(method, url, body)
    if err != nil {
        return nil, fmt.Errorf("创建请求失败: %w", err)
    }

    // 使用自定义客户端发送请求
    resp, err := CustomHTTPClient.Do(req)
    if err != nil {
        return nil, fmt.Errorf("发送请求失败: %w", err)
    }
    defer resp.Body.Close()

    if resp.StatusCode != http.StatusOK {
        return nil, fmt.Errorf("HTTP 响应状态码异常: %v", resp.Status)
    }

    b, err := ioutil.ReadAll(resp.Body)
    if err != nil {
        return nil, fmt.Errorf("读取响应体失败: %w", err)
    }

    return b, nil
}