Go语言并发TCP服务器：正确处理net.Conn接口

// 错误的传递方式
go handleClient(&con) // con 是 net.Conn 类型，&con 是 *net.Conn

func handleClient(con *net.Conn) {
    // 此时访问 con.RemoteAddr() 会报错：
    // con.RemoteAddr undefined (type *net.Conn has no field or method RemoteAddr)
}

package main

import (
    "fmt"
    "io"
    "log"
    "net"
    "time" // 引入time包，用于模拟一些操作或设置超时
)

func main() {
    // 1. 监听TCP端口
    // "localhost:8080" 表示监听本地所有可用IP地址的8080端口
    listener, err := net.Listen("tcp", "localhost:8080")
    if err != nil {
        log.Fatalf("服务器启动失败: %v", err)
    }
    defer listener.Close() // 确保监听器在main函数退出时关闭
    log.Println("TCP服务器已启动，监听在 localhost:8080")

    // 2. 循环接受客户端连接
    for {
        conn, err := listener.Accept() // conn 是 net.Conn 类型
        if err != nil {
            log.Printf("接受连接失败: %v", err)
            // 如果是临时错误，可以考虑短暂休眠后继续
            if ne, ok := err.(net.Error); ok && ne.Temporary() {
                time.Sleep(time.Millisecond * 100)
                continue
            }
            // 对于非临时错误，通常表示监听器有问题，应退出
            return
        }

        // 3. 为每个新连接启动一个goroutine进行处理
        log.Printf("接受到来自 %s 的新连接", conn.RemoteAddr().String())
        go handleClient(conn) // 直接传递 net.Conn 类型
    }
}

// handleClient 函数负责处理单个客户端连接的逻辑
// 参数类型为 net.Conn，可以直接访问其方法
func handleClient(conn net.Conn) {
    // 确保连接在函数退出时关闭，无论正常结束还是发生错误
    defer func() {
        log.Printf("关闭来自 %s 的连接", conn.RemoteAddr().String())
        conn.Close()
    }()

    // 设置读取超时，防止客户端长时间不发送数据导致阻塞
    conn.SetReadDeadline(time.Now().Add(5 * time.Minute)) // 5分钟无数据则超时

    buffer := make([]byte, 1024) // 创建一个缓冲区用于读取数据
    for {
        // 从连接中读取数据
        n, err := conn.Read(buffer)
        if err != nil {
            if err == io.EOF {
                // 客户端正常关闭连接
                log.Printf("客户端 %s 已断开连接", conn.RemoteAddr().String())
            } else {
                // 读取错误
                log.Printf("从 %s 读取数据失败: %v", conn.RemoteAddr().String(), err)
            }
            break // 退出循环，关闭连接
        }

        receivedData := buffer[:n]
        log.Printf("从 %s 接收到 %d 字节: %s", conn.RemoteAddr().String(), n, string(receivedData))

        // 将接收到的数据回显给客户端
        response := fmt.Sprintf("服务器已收到: %s\n", string(receivedData))
        _, err = conn.Write([]byte(response))
        if err != nil {
            log.Printf("向 %s 写入数据失败: %v", conn.RemoteAddr().String(), err)
            break // 写入失败，退出循环
        }

        // 每次成功读写后，重置读取超时时间
        conn.SetReadDeadline(time.Now().Add(5 * time.Minute))
    }
}