Golang TCP连接建立教程与代码示例

package main

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

func main() {
    // 监听本地8080端口
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal("监听失败:", err)
    }
    defer listener.Close()
    fmt.Println("服务器启动，监听 :8080...")

    for {
        // 接受客户端连接
        conn, err := listener.Accept()
        if err != nil {
            log.Println("接受连接失败:", err)
            continue
        }
        // 启动协程处理连接
        go handleConnection(conn)
    }
}

// 处理客户端请求
func handleConnection(conn net.Conn) {
    defer conn.Close()
    reader := bufio.NewReader(conn)
    for {
        // 读取客户端消息
        msg, err := reader.ReadString('\n')
        if err != nil {
            log.Println("读取失败:", err)
            return
        }
        fmt.Printf("收到消息: %s", msg)
        // 回应客户端
        conn.Write([]byte("已收到: " + msg))
    }
}

package main

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

func main() {
    // 连接本地服务器
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("连接失败:", err)
        return
    }
    defer conn.Close()
    fmt.Println("已连接到服务器")

    // 从标准输入读取用户输入
    inputReader := bufio.NewReader(os.Stdin)
    for {
        fmt.Print("请输入消息: ")
        line, _ := inputReader.ReadString('\n')
        line = strings.TrimSpace(line)

        if line == "quit" {
            break
        }

        // 发送消息到服务器
        conn.Write([]byte(line + "\n"))

        // 读取服务器响应
        response, err := bufio.NewReader(conn).ReadString('\n')
        if err != nil {
            fmt.Println("读取响应失败:", err)
            break
        }
        fmt.Printf("服务器回应: %s", response)
    }
}