Go语言中net.Conn.Read()行为与高CPU占用分析及正确处理方法

func TCPHandler(conn net.Conn) {
    request := make([]byte, 4096)
    for {
        read_len, err := conn.Read(request)

        if err != nil {
            if err.Error() == "use of closed network connection" {
                LOG("Conn closed, error might happened")
                break // 连接已关闭，退出循环
            }

            neterr, ok := err.(net.Error);
            if ok && neterr.Timeout() {
                fmt.Println(neterr)
                LOG("Client timeout!")
                break // 客户端超时，退出循环
            }
            // 其他错误处理
            LOG(fmt.Sprintf("Read error: %v", err))
            break
        }

        if read_len == 0 {
            // 错误处理：当read_len == 0时，表示对端已关闭连接
            // 继续循环会导致高CPU占用
            LOG("Nothing read") // 此处是问题所在
            continue // 导致忙等待
        } else {
            // 处理读取到的数据
            // do something with request[:read_len]
        }
        // 注意：每次循环都重新分配request切片是不必要的，且会增加GC压力
        // request := make([]byte, 4096)
    }
    // 确保连接在处理完成后被关闭
    conn.Close()
}

func TCPHandler(conn net.Conn) {
    // 确保在函数退出时关闭连接，无论发生什么
    defer conn.Close()

    request := make([]byte, 4096)
    for {
        read_len, err := conn.Read(request)

        if err != nil {
            // 检查是否是连接关闭或超时错误
            if err == nil || err.Error() == "use of closed network connection" {
                LOG("Connection closed gracefully by peer or locally.")
                break // 连接已关闭，退出循环
            }

            neterr, ok := err.(net.Error);
            if ok && neterr.Timeout() {
                LOG("Client read timeout!")
                break // 客户端超时，退出循环
            }
            // 其他非EOF错误，记录并退出
            LOG(fmt.Sprintf("Unexpected read error: %v", err))
            break
        }

        if read_len == 0 {
            // 当read_len == 0 且 err == nil 时，表示对端已优雅关闭连接 (EOF)
            LOG("Peer closed the connection gracefully (EOF).")
            break // 退出循环，由 defer conn.Close() 关闭连接
        } else {
            // 成功读取到数据，进行业务处理
            // 例如：processData(request[:read_len])
            LOG(fmt.Sprintf("Received %d bytes: %s", read_len, string(request[:read_len])))
            // 可以在此处重置 request 切片，但通常不需要，除非数据处理会修改其容量
            // request = make([]byte, 4096) // 如果需要，请确保在处理完当前数据后再重新分配
        }
    }
    LOG("TCPHandler goroutine finished for connection.")
}