go进行http请求偶发EOF问题分析

package main

import (
	"bytes"
	"crypto/tls"
	"encoding/json"
	"errors"
	"fmt"
	"io"
	"io/ioutil"
	"net/http"
	"time"
)

func main() {
	// 创建自定义的 transport,设置连接池参数
	tr := &http.transport{
		tlsclientconfig: &tls.config{
			insecureskipverify: true, // 忽略 tls 证书验证
		},
		maxidleconns:        1,                // 限制最大空闲连接数为1
		maxidleconnsperhost: 1,                // 限制每个host最大空闲连接数为1
		idleconntimeout:     20 * time.second, // 本地空闲连接超时设置为20s
		disablekeepalives:   false,            // 启用 keep-alive
		maxconnsperhost:     1,                // 限制每个host的最大连接数为1，强制复用连接
		forceattempthttp2:   false,            // 禁用 http/2
	}

	// 创建 http 客户端
	client := &http.client{
		transport: tr,
		timeout:   5 * time.second, // 设置请求超时时间
	}

	// 准备请求参数
	url := "https://192.168.24.70:2018/api/zguard/sysmng/syscfg/basecfg/sysname/651d5b9f-225b-4c8c-9f06-80bfad3fa977"
	cookie := "session-id=f416b188c91bc72a06853b362d5cb7b3a6b68a43"

	// 准备请求体数据
	requestbody := map[string]string{
		"sys_name": "n-guard",
	}
	// 将 map 转换为 json
	jsonbody, err := json.marshal(requestbody)
	if err != nil {
		fmt.printf("json 编码失败: %v\n", err)
	}

	// 循环发送请求,模拟使用已关闭的连接
	for i := 0; i < 5; i++ { // 只测试两次请求即可

		// 每次请求都创建新的 bytes.buffer，确保 body 可以重复读取
		bodyreader := bytes.newbuffer(jsonbody)

		req, err := http.newrequest("put", url, bodyreader)
		if err != nil {
			fmt.printf("创建请求失败: %v\n", err)
			continue
		}

		// 设置 content-length
		req.contentlength = int64(len(jsonbody))
		// 设置请求头
		req.header.set("cookie", cookie)
		req.header.set("content-type", "application/json")

		fmt.printf("发送第 %d 个请求...\n", i+1)
		// 发送请求
		resp, err := client.do(req)
		if err != nil {
			fmt.printf("请求失败: %v\n", err)
			if errors.is(err, io.eof) {
				fmt.printf("连接不再可用: 重试：新的五元重新发起连接\n")
				bodyreader := bytes.newbuffer(jsonbody)

				reqretry, err := http.newrequest("put", url, bodyreader)
				if err != nil {
					fmt.printf("创建请求失败: %v\n", err)
					continue
				}

				// 设置 content-length
				reqretry.contentlength = int64(len(jsonbody))
				// 设置请求头
				reqretry.header.set("cookie", cookie)
				reqretry.header.set("content-type", "application/json")

				resp, err = client.do(reqretry)
				if err != nil {
					fmt.printf("err:\n", err)
					continue
				}
			} else {
				continue
			}
		}

		// 读取响应
		body, err := ioutil.readall(resp.body)
		if err != nil {
			fmt.printf("读取响应失败: %v\n", err)
		}
		resp.body.close()

		fmt.printf("请求 %d - 状态码: %d, 响应: %s\n", i+1, resp.statuscode, string(body))

		fmt.println("等待10秒后发送第二个请求...")
		time.sleep(10 * time.second) // 等待10秒，此时服务端已经关闭连接（10s）
		time.sleep(500 * time.millisecond)
	}
}