如何提升Golang网络编程性能 调整TCP参数与连接池配置

TCP_NODELAY

SO_REUSEADDR

SO_RCVBUF

SO_SNDBUF

SetNoDelay(true)

TCP_NODELAY

SO_REUSEADDR

TIME_WAIT

SO_RCVBUF

SO_SNDBUF

net.Conn

SetReadBuffer

SetWriteBuffer

net.ipv4.tcp_rmem

net.ipv4.tcp_wmem

package main

import (
    "log"
    "net"
    "time"
)

func main() {
    ln, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal(err)
    }
    defer ln.Close()

    log.Println("Server listening on :8080")

    for {
        conn, err := ln.Accept()
        if err != nil {
            log.Println("Accept error:", err)
            continue
        }
        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()

    // 尝试设置TCP_NODELAY
    if tcpConn, ok := conn.(*net.TCPConn); ok {
        if err := tcpConn.SetNoDelay(true); err != nil {
            log.Println("Failed to set TCP_NODELAY:", err)
        }
        // 尝试设置SO_RCVBUF和SO_SNDBUF
        if err := tcpConn.SetReadBuffer(64 * 1024); err != nil { // 64KB
            log.Println("Failed to set read buffer:", err)
        }
        if err := tcpConn.SetWriteBuffer(64 * 1024); err != nil { // 64KB
            log.Println("Failed to set write buffer:", err)
        }
        // 尝试设置TCP_KEEPALIVE
        if err := tcpConn.SetKeepAlive(true); err != nil {
            log.Println("Failed to set TCP_KEEPALIVE:", err)
        }
        if err := tcpConn.SetKeepAlivePeriod(30 * time.Second); err != nil { // 30秒
            log.Println("Failed to set TCP_KEEPALIVE_PERIOD:", err)
        }
    }

    log.Printf("New connection from %s, TCP_NODELAY: %v", conn.RemoteAddr(), true) // 假设设置成功

    // 简单的回显逻辑
    buf := make([]byte, 1024)
    for {
        n, err := conn.Read(buf)
        if err != nil {
            log.Println("Read error:", err)
            return
        }
        _, err = conn.Write(buf[:n])
        if err != nil {
            log.Println("Write error:", err)
            return
        }
    }
}

net/http

http.DefaultTransport

http.Transport

MaxIdleConns

MaxIdleConnsPerHost

IdleConnTimeout

package main

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

func main() {
    // 自定义Transport，配置连接池参数
    tr := &http.Transport{
        MaxIdleConns:        100,              // 客户端所有主机最大空闲连接数
        MaxIdleConnsPerHost: 20,               // 每个主机最大空闲连接数
        IdleConnTimeout:     90 * time.Second, // 空闲连接的超时时间
        DisableKeepAlives:   false,            // 确保开启Keep-Alive
    }

    client := &http.Client{Transport: tr}

    // 模拟多次请求同一个地址
    for i := 0; i < 5; i++ {
        resp, err := client.Get("http://localhost:8080") // 假设本地有一个简单的HTTP服务
        if err != nil {
            log.Printf("Request %d error: %v\n", i, err)
            time.Sleep(1 * time.Second) // 避免请求过快
            continue
        }
        defer resp.Body.Close()
        body, _ := ioutil.ReadAll(resp.Body)
        log.Printf("Request %d status: %s, body length: %d\n", i, resp.Status, len(body))
        time.Sleep(100 * time.Millisecond) // 稍微等待，观察连接复用
    }
}

http.Client

Transport

netstat -an | grep 8080

MaxIdleConnsPerHost

sync.Pool

SO_RCVBUF

SO_SNDBUF

net.core.somaxconn

net.ipv4.tcp_tw_reuse

somaxconn

pprof

SetReadDeadline

SetWriteDeadline