如何在for循环及递归API调用中正确使用response.Body.Close()？

我希望在for循环中使用response.Body.Close()，但担心在TCP连接关闭前就发起新的API调用会有问题。请问最优的使用方式是什么？另外，在循环中调用res.body.Close()会有什么影响吗？

参考代码片段：

// Function call
serviceList := RecursiveResourceMapApiCall(resourceItem)
.
.
.
func RecursiveResourceMapApiCall(resourceItem types.ResourceItem) (serviceList []types.Services) {
    fmt.Println("RecursiveResourceMapApiCall")
    // var err error
    if len(resourceItem.ServiceRefs) == 0 {
        fmt.Println("service at this point: ", resourceItem.ID)
        serviceDetail := types.Services {
            Name:    resourceItem.ID,
            Version: resourceItem.Version,
        }
        serviceList = append(serviceList, serviceDetail)
        // Should I close the response body here? I have
        // to change the return type of function then
        return serviceList
    }
    var resourceMapResponse types.ResourceMapResponse
    for i := 0; i < len(resourceItem.ServiceRefs); i++ {
        // FetchDetailsFromResourceMapService is the API call
        response, err := allocatorStore.FetchDetailsFromResourceMapService(resourceItem.ServiceRefs[i])
        if err == nil && response.StatusCode == 200 {
            data, _ := ioutil.ReadAll(response.Body)
            err := json.Unmarshal(data, &resourceMapResponse)
            if err != nil {
                fmt.Println("error in unmarshalling resource map response", err)
            }
            fmt.Println("Length of data in response: ", len(resourceMapResponse.Data.Resources), "Resource Data received: ", resourceMapResponse.Data.Resources)
            if resourceMapResponse.StatusCode == 0 {
                // Making recursive call here as there
                // is data to process still
                serviceList = RecursiveResourceMapApiCall(resourceMapResponse.Data.Resources[0])
            } else if err != nil {
                fmt.Println("Error on resource request", err.Error())
            } else {
                fmt.Println("Error on resource request", response.StatusCode, response.Body)
            }
            response.Body.Close()
        }
    }
    return serviceList
}

1. 正确的response.Body.Close()使用时机 #

你当前代码里的response.Body.Close()位置本身没问题，但要注意：必须确保在读取完响应体后关闭，无论后续逻辑是否出错。哪怕已经用ioutil.ReadAll()读完所有数据，调用Close都是必要的——它会释放底层TCP连接（或放回连接池，取决于HTTP客户端配置）。

你的递归调用是在读完响应体之后发起的，这时候关闭Body完全不影响后续API调用：递归里的新请求会建立新连接（或复用连接池中的空闲连接），和当前已处理完的响应体没有关联。

2. 优化建议：用defer保证Body必被关闭 #

最稳妥的方式是在成功获取response后，立刻用defer注册关闭操作，这样哪怕后续代码panic、提前return，都能保证资源不泄漏。修改循环内的代码如下：

response, err := allocatorStore.FetchDetailsFromResourceMapService(resourceItem.ServiceRefs[i])
if err != nil {
    fmt.Println("API call failed:", err)
    continue
}
defer response.Body.Close() // 用defer确保无论后续逻辑如何，Body都会被关闭

if response.StatusCode != 200 {
    fmt.Println("Error on resource request", response.StatusCode)
    continue
}

data, err := ioutil.ReadAll(response.Body)
if err != nil {
    fmt.Println("Failed to read response body:", err)
    continue
}

err = json.Unmarshal(data, &resourceMapResponse)
if err != nil {
    fmt.Println("error in unmarshalling resource map response", err)
    continue
}

fmt.Println("Length of data in response: ", len(resourceMapResponse.Data.Resources), "Resource Data received: ", resourceMapResponse.Data.Resources)
if resourceMapResponse.StatusCode == 0 {
    serviceList = RecursiveResourceMapApiCall(resourceMapResponse.Data.Resources[0])
} else {
    fmt.Println("Error on resource request, status code:", resourceMapResponse.StatusCode)
}

3. 循环中调用response.Body.Close()的影响 #

循环里每次处理完请求就关闭Body是完全合理的：

• 对于HTTP/1.1，默认开启连接复用（keep-alive），调用Close后连接会放回连接池，供后续请求复用，不会直接关闭TCP连接；
• 即使连接未被复用，关闭Body也会正确释放TCP连接资源，避免出现大量TIME_WAIT状态连接或资源泄漏；
• 递归调用的新请求会独立建立连接（或复用池内连接），和已关闭的Body无关联，不会影响新请求发起。

4. 关于递归基准条件的疑问 #

基准条件里完全不需要处理response.Body的关闭——因为触发基准条件时，当前节点没有发起新的API请求，自然没有对应的response需要关闭。你之前的担心是多余的，基准条件只需处理当前节点的业务逻辑即可。

内容的提问来源于stack exchange，提问作者Utsav Mishra