Go语言中UDP服务器的构建与ReadFromUDP方法的正确使用

package main

import (
    "fmt"
    "net"
    "time" // 引入time包用于设置超时
)

func main() {
    addr, err := net.ResolveUDPAddr("udp", "localhost:10234")
    if err != nil {
        fmt.Println("解析地址失败:", err)
        return
    }

    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        fmt.Println("监听UDP失败:", err)
        return
    }
    defer conn.Close()

    fmt.Println("UDP服务器在", addr.String(), "上监听...")

    var buf []byte // 错误：buf是一个nil切片，长度为0

    // 设置读取超时，避免无限阻塞在没有数据时
    // conn.SetReadDeadline(time.Now().Add(5 * time.Second)) 

    for {
        n, remoteAddr, err := conn.ReadFromUDP(buf) // 尝试将数据写入nil切片
        if err != nil {
            // 如果是超时错误，可以继续循环或处理
            if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
                fmt.Println("读取超时，继续等待...")
                continue
            }
            fmt.Println("读取数据错误:", err)
            break
        }
        // 由于buf是nil，n通常会是0，或者写入失败
        fmt.Printf("从 %s 收到 %d 字节数据: %s\n", remoteAddr.String(), n, string(buf[:n]))
        time.Sleep(100 * time.Millisecond) // 模拟处理时间，防止CPU空转过快
    }
}

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    // 1. 解析UDP地址
    addr, err := net.ResolveUDPAddr("udp", "localhost:10234")
    if err != nil {
        fmt.Println("解析UDP地址失败:", err)
        return
    }

    // 2. 监听UDP地址
    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        fmt.Println("监听UDP失败:", err)
        return
    }
    defer conn.Close() // 确保连接在程序结束时关闭

    fmt.Println("UDP服务器在", addr.String(), "上监听...")

    // 3. 预分配一个足够大的缓冲区
    // UDP数据报最大长度约为65507字节，这里分配1024字节作为示例
    buf := make([]byte, 1024) 

    for {
        // 4. 调用ReadFromUDP读取数据
        // n: 实际读取的字节数
        // remoteAddr: 发送数据的远程地址
        // err: 错误信息
        n, remoteAddr, err := conn.ReadFromUDP(buf)
        if err != nil {
            // 处理可能的网络错误
            if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
                // 如果设置了超时，这里可以处理超时错误
                fmt.Println("读取超时，继续等待下一个数据报...")
                continue
            }
            fmt.Println("读取UDP数据错误:", err)
            break // 发生严重错误时退出循环
        }

        // 5. 处理接收到的数据
        // 确保只处理实际读取到的n个字节
        receivedMessage := string(buf[:n])
        fmt.Printf("从 %s 收到 %d 字节数据: %s\n", remoteAddr.String(), n, receivedMessage)

        // 可以在这里添加业务逻辑，例如回显数据
        // _, err = conn.WriteToUDP([]byte("Echo: "+receivedMessage), remoteAddr)
        // if err != nil {
        //     fmt.Println("回写数据错误:", err)
        // }
    }
}