Golangnet包实现TCP通信详解

package main

import (
    "bufio"
    "fmt"
    "log"
    "net"
")

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

    fmt.Printf("来自 %s 的连接已建立\n", conn.RemoteAddr().String())

    reader := bufio.NewReader(conn)
    for {
        message, err := reader.ReadString('\n')
        if err != nil {
            fmt.Printf("连接断开: %s\n", conn.RemoteAddr().String())
            break
        }

        fmt.Printf("收到消息: %s", message)

        // 回显消息给客户端
        conn.Write([]byte("echo: " + message))
    }
}

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal("监听失败:", err)
    }
    defer listener.Close()

    fmt.Println("TCP 服务器启动，监听端口 :8080")

    for {
        conn, err := listener.Accept()
        if err != nil {
            log.Println("接受连接出错:", err)
            continue
        }

        // 每个连接开启一个 goroutine 处理
        go handleConnection(conn)
    }
}

package main

import (
    "bufio"
    "fmt"
    "log"
    "net"
    "os"
")

func main() {
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        log.Fatal("连接失败:", err)
    }
    defer conn.Close()

    fmt.Println("已连接到服务器")

    go func() {
        reader := bufio.NewReader(conn)
        for {
            msg, err := reader.ReadString('\n')
            if err != nil {
                return
            }
            fmt.Print("服务端回显: ", msg)
        }
    }()

    // 从标准输入读取用户输入
    inputReader := bufio.NewReader(os.Stdin)
    for {
        line, _ := inputReader.ReadString('\n')
        conn.Write([]byte(line))
    }
}