Golang实现TCP服务器教程

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

for {
    conn, err := listener.Accept()
    if err != nil {
        log.Println("接受连接出错:", err)
        continue
    }
    // 每个连接开启一个协程处理
    go handleConnection(conn)
}

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

    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            log.Println("连接断开:", err)
            return
        }

        data := buffer[:n]
        log.Printf("收到消息: %s", data)

        // 回显给客户端
        _, err = conn.Write([]byte("echo: " + string(data)))
        if err != nil {
            log.Println("发送响应失败:", err)
            return
        }
    }
}

package main

import (
    "log"
    "net"
)

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal("监听失败:", err)
    }
    defer listener.Close()
    log.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()
    buffer := make([]byte, 1024)

    for {
        n, err := conn.Read(buffer)
        if err != nil {
            return
        }

        received := buffer[:n]
        log.Printf("来自 %s: %s", conn.RemoteAddr(), received)
        conn.Write([]byte("echo: " + string(received)))
    }
}

telnet localhost 8080