Go TCP客户端即时数据发送：Nagle算法与服务器端影响

package main

import (
    "fmt"
    "net"
    "time" // 引入time包用于模拟延迟
)

func main() {
    addr, err := net.ResolveTCPAddr("tcp", "localhost:5432")
    if err != nil {
        fmt.Println("ResolveTCPAddr fail:", err)
        return
    }

    conn, err := net.DialTCP("tcp", nil, addr)
    if err != nil {
        fmt.Println("DialTCP fail:", err)
        return
    }
    defer conn.Close()

    // 禁用Nagle算法，尝试立即发送数据
    err = conn.SetNoDelay(true)
    if err != nil {
        fmt.Println("SetNoDelay fail:", err.Error())
    } else {
        fmt.Println("SetNoDelay set to true.")
    }

    fmt.Println("Connected to server. Type messages to send, press Enter. Type empty line to exit.")

    for {
        var message string
        fmt.Print("> ")
        _, err := fmt.Scanln(&message)
        if err != nil && err.Error() != "unexpected newline" {
            fmt.Println("Input finished:", err)
            break
        }

        if message == "" {
            fmt.Println("No input, ending connection.")
            break
        }

        // 方式一：使用conn.Write发送字节切片
        // conn.Write([]byte(message + "\n")) // 加上换行符以便服务器端区分消息

        // 方式二：使用fmt.Fprintf发送字符串
        // fmt.Fprintf(conn, message + "\n") // 加上换行符

        // 选择一种方式发送数据
        _, err = conn.Write([]byte(message + "\n")) // 推荐使用Write，更直接
        if err != nil {
            fmt.Println("Send message fail:", err)
            break
        }
        fmt.Printf("Sent: '%s'\n", message)

        // 模拟一些处理时间，避免CPU空转
        time.Sleep(100 * time.Millisecond)
    }
    fmt.Println("Client disconnected.")
}

package main

import (
    "io"
    "log"
    "net"
    "os"
)

func main() {
    // 监听本地5432端口
    l, err := net.Listen("tcp", "localhost:5432")
    if err != nil {
        log.Fatal("Listen error:", err)
    }
    defer l.Close()
    log.Println("TCP server listening on localhost:5432")

    for {
        // 接受新的连接
        conn, err := l.Accept()
        if err != nil {
            log.Println("Accept error:", err)
            continue
        }
        log.Printf("Accepted connection from %s\n", conn.RemoteAddr())

        // 为每个连接启动一个goroutine处理
        go func(c net.Conn) {
            defer c.Close()
            defer log.Printf("Connection from %s closed\n", c.RemoteAddr())

            // 将连接中读取到的所有数据直接复制到标准输出
            // io.Copy会持续读取直到EOF或错误
            _, err := io.Copy(os.Stdout, c)
            if err != nil && err != io.EOF {
                log.Printf("Error during io.Copy for %s: %v\n", c.RemoteAddr(), err)
            }
        }(conn)
    }
}