package main

import (
    "bufio"
    "fmt"
    "net"
    "strings"
)

func handleConnection(conn net.Conn) {
    defer conn.Close()
    addr := conn.RemoteAddr().String()
    fmt.Println("客戶端連接:", addr)

    reader := bufio.NewReader(conn)
    for {
        data, err := reader.ReadString('\n')
        if err != nil {
            fmt.Println("客戶端斷開(kāi):", addr)
            return
        }
        msg := strings.TrimSpace(data)
        fmt.Printf("收到[%s]: %s\n", addr, msg)

        // 回復(fù)消息
        response := fmt.Sprintf("服務(wù)端收到: %s\n", msg)
        conn.Write([]byte(response))
    }
}

func main() {
    listener, err := net.Listen("tcp", ":8888")
    if err != nil {
        fmt.Println("啟動(dòng)失敗:", err)
        return
    }
    defer listener.Close()

    fmt.Println("TCP服務(wù)器已啟動(dòng)，監(jiān)聽(tīng)端口 8888...")
    for {
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("連接失敗:", err)
            continue
        }
        go handleConnection(conn)
    }
}

package main

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

func main() {
    conn, err := net.Dial("tcp", "127.0.0.1:8888")
    if err != nil {
        fmt.Println("連接服務(wù)器失敗:", err)
        return
    }
    defer conn.Close()

    fmt.Println("已連接到服務(wù)器。請(qǐng)輸入消息，輸入 exit 退出：")

    reader := bufio.NewReader(os.Stdin)
    for {
        fmt.Print(">> ")
        input, _ := reader.ReadString('\n')
        input = strings.TrimSpace(input)
        if input == "exit" {
            fmt.Println("斷開(kāi)連接")
            return
        }

        // 發(fā)送消息
        conn.Write([]byte(input + "\n"))

        // 接收服務(wù)器響應(yīng)
        response, _ := bufio.NewReader(conn).ReadString('\n')
        fmt.Println("服務(wù)器響應(yīng):", strings.TrimSpace(response))
    }
}

go run server.go

TCP服務(wù)器已啟動(dòng)，監(jiān)聽(tīng)端口 8888...

go run client.go

>> hello
服務(wù)器響應(yīng): 服務(wù)端收到: hello

客戶端連接: 127.0.0.1:53458
收到[127.0.0.1:53458]: hello