解决Golang HTTP连续请求中的EOF错误：连接管理深度解析

package main

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

// 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() {
    // 示例：连续发送两个请求
    // 假设这里有一个本地的HTTP服务器在运行
    // 如果服务器在响应后立即关闭连接，或者连接池管理不当，
    // 第二个请求可能会遇到EOF错误。

    // 第一个请求
    _, err := SendRequest("GET", "http://localhost:8080/data/1", nil)
    if err != nil {
        fmt.Printf("第一个请求失败: %v\n", err)
    } else {
        fmt.Println("第一个请求成功")
    }

    // 第二个请求
    _, err = SendRequest("POST", "http://localhost:8080/data", strings.NewReader(`{"key":"value"}`))
    if err != nil {
        fmt.Printf("第二个请求失败: %v\n", err) // 这里可能出现EOF
    } else {
        fmt.Println("第二个请求成功")
    }
}

package main

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

// 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，强制客户端在响应结束后关闭连接
    req.Close = true 

    // 可以选择使用自定义的http.Client，以更好地控制超时等行为
    client := &http.Client{
        Timeout: 10 * time.Second, // 设置请求超时
    }

    resp, err := client.Do(req) // 使用自定义client发送请求
    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() {
    // 示例：连续发送两个请求，使用强制关闭连接的模式
    // 假设这里有一个本地的HTTP服务器在运行

    // 第一个请求
    _, err := SendRequestWithClose("GET", "http://localhost:8080/data/1", nil)
    if err != nil {
        fmt.Printf("第一个请求失败: %v\n", err)
    } else {
        fmt.Println("第一个请求成功")
    }

    // 第二个请求
    _, err = SendRequestWithClose("POST", "http://localhost:8080/data", strings.NewReader(`{"key":"value"}`))
    if err != nil {
        fmt.Printf("第二个请求失败: %v\n", err) 
    } else {
        fmt.Println("第二个请求成功")
    }
}