如何在Golang中处理UDP数据包_Golang UDP数据包处理方法汇总

package main
<p>import (
"fmt"
"net"
)</p><p>func main() {
addr, err := net.ResolveUDPAddr("udp", ":8080")
if err != nil {
panic(err)
}</p><pre class='brush:php;toolbar:false;'>conn, err := net.ListenUDP("udp", addr)
if err != nil {
    panic(err)
}
defer conn.Close()

buffer := make([]byte, 1024)
for {
    n, clientAddr, err := conn.ReadFromUDP(buffer)
    if err != nil {
        fmt.Println("读取错误:", err)
        continue
    }

    fmt.Printf("收到来自 %s 的消息: %s\n", clientAddr, string(buffer[:n]))

    // 回复客户端
    response := "收到你的消息"
    conn.WriteToUDP([]byte(response), clientAddr)
}

package main
<p>import (
"fmt"
"net"
)</p><p>func main() {
serverAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
if err != nil {
panic(err)
}</p><pre class='brush:php;toolbar:false;'>conn, err := net.DialUDP("udp", nil, serverAddr)
if err != nil {
    panic(err)
}
defer conn.Close()

message := "Hello UDP Server"
_, err = conn.Write([]byte(message))
if err != nil {
    fmt.Println("发送失败:", err)
    return
}

// 接收响应
buffer := make([]byte, 1024)
n, err := conn.Read(buffer)
if err != nil {
    fmt.Println("接收响应失败:", err)
    return
}

fmt.Printf("收到回复: %s\n", string(buffer[:n]))

conn.SetReadDeadline(time.Now().Add(5 * time.Second))
n, clientAddr, err := conn.ReadFromUDP(buffer)
if err != nil {
    if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
        fmt.Println("接收超时")
    } else {
        fmt.Println("读取错误:", err)
    }
    continue
}

conn, err := net.ListenUDP("udp", addr)
if err != nil { ... }
err = conn.SetBroadcast(true) // 允许发送广播