如何使用 Go 的 http.Client 实现长连接-Golang-PHP中文网

如何使用 Go 的 http.Client 实现长连接

聖光之護

发布： 2025-08-31 22:04:01

原创

813人浏览过

如何使用 go 的 http.client 实现长连接

本文将介绍如何使用 Go 语言的 http.Client 建立并维护一个长连接。通过示例代码，我们将演示如何发起 HTTP 请求，以及如何正确地从响应体中读取数据，从而实现客户端与服务器之间的持久连接，提高数据传输效率。我们将重点关注数据读取过程中的错误处理和缓冲区大小的设置。

理解 HTTP 长连接

HTTP 长连接（也称为持久连接）允许客户端和服务器在单个 TCP 连接上进行多次 HTTP 请求和响应，而无需为每个请求都建立新的连接。这可以显著减少连接建立和关闭的开销，提高网络性能。在 Go 语言中，http.Client 默认支持 HTTP/1.1 的长连接特性。

使用 http.Client 发起长连接请求

以下是一个使用 http.Client 发起 HTTP GET 请求并保持长连接的示例代码：

ShopEx助理

一个类似淘宝助理、ebay助理的客户端程序，用来方便的在本地处理商店数据，并能够在本地商店、网上商店和第三方平台之间实现数据上传下载功能的工具。功能说明如下：1.连接本地商店：您可以使用ShopEx助理连接一个本地安装的商店系统，这样就可以使用助理对本地商店的商品数据进行编辑等操作，并且数据也将存放在本地商店数据库中。默认是选择“本地未安装商店”，本地还未安

查看详情

package main

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

func main() {
    // 创建一个 HTTP 请求
    request, err := http.NewRequest("GET", "http://www.example.com/", nil)
    if err != nil {
        log.Fatal(err)
    }

    // 创建一个 HTTP 客户端
    httpClient := &http.Client{}

    // 发送请求并获取响应
    response, err := httpClient.Do(request)
    if err != nil {
        log.Fatal(err)
    }
    defer response.Body.Close() // 确保关闭响应体

    // 读取响应体
    buf := make([]byte, 4096) // 创建一个缓冲区，用于存储读取的数据
    for {
        n, err := response.Body.Read(buf)
        if err != nil {
            if err == io.EOF { // 读取到文件末尾
                break
            }
            log.Fatal(err) // 其他错误
        }
        fmt.Printf("%s", buf[:n]) // 打印读取到的数据
    }
    fmt.Println()
}

登录后复制

代码解释：

创建 HTTP 请求： 使用 http.NewRequest 函数创建一个新的 HTTP 请求，指定请求方法（GET）、URL 和请求体（这里是 nil，因为是 GET 请求）。
创建 HTTP 客户端： 使用 &http.Client{} 创建一个 HTTP 客户端实例。 http.Client 默认情况下会重用 TCP 连接，实现长连接。
发送请求并获取响应： 使用 httpClient.Do(request) 发送请求并获取响应。 response.Body 是一个 io.ReadCloser 接口，可以从中读取响应数据。
读取响应体： 使用 response.Body.Read(buf) 从响应体中读取数据到缓冲区 buf 中。Read 方法返回读取的字节数 n 和一个 error。
- 如果 err 是 io.EOF，表示已经读取到响应体的末尾，循环结束。
- 如果 err 是其他错误，表示读取过程中发生了错误，程序退出。
打印读取到的数据： 使用 fmt.Printf("%s", buf[:n]) 打印读取到的数据。注意，这里只打印了 buf 中前 n 个字节，因为 n 是实际读取的字节数。
关闭响应体： 使用 defer response.Body.Close() 确保在函数退出前关闭响应体。这可以释放资源，避免内存泄漏。

注意事项

缓冲区大小： 缓冲区 buf 的大小会影响读取数据的效率。如果缓冲区太小，可能需要多次读取才能读取完整个响应体；如果缓冲区太大，可能会浪费内存。建议根据实际情况选择合适的缓冲区大小。
错误处理： 在读取响应体时，务必处理可能出现的错误。特别是 io.EOF 错误，表示已经读取到响应体的末尾。其他错误可能表示网络连接中断或服务器发生错误。
连接超时： http.Client 提供了多种超时设置，例如 Timeout、DialContext 等。可以根据实际需求设置合适的超时时间，避免程序长时间阻塞。
Keep-Alive: http.Client 默认启用 Keep-Alive，以重用 TCP 连接。可以通过修改 Transport 字段的参数来调整 Keep-Alive 的行为。