通八洲科技

UDP 通信双向交互的正确实现方式

日期:2025-12-26 00:00 / 作者:霞舞

udp 是无连接协议,`listenudp` 创建的连接无法直接使用 `write` 发送响应,必须通过 `readfromudp` 获取客户端地址,再用 `writetoudp` 显式指定目标地址才能实现双向通信。

在 Go 中,net.ListenUDP 返回的是一个 *net.UDPConn,它不维护连接状态,因此调用 conn.Write([]byte(...)) 时,系统缺乏目标 IP 和端口信息,数据包将被静默丢弃(Wireshark 无法捕获发送行为,正是此原因)。这并非“单向街道”,而是因 UDP 本身无连接特性导致——每次发送都需显式指定对端地址

正确做法是:使用 ReadFromUDP 接收数据并同时获取客户端网络地址;再用 WriteToUDP 将响应发回该地址。以下是修正后的 Node 1(服务端)完整示例:

package main

import (
    "fmt"
    "net"
)

func main() {
    addr := &net.UDPAddr{Port: 7000, IP: net.ParseIP("127.0.0.1")}
    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    fmt.Println("UDP server listening on :7000")
    for {
        buf := make([]byte, 1024) // 建议增大缓冲区,避免截断
        n, clientAddr, err := conn.ReadFromUDP(buf)
        if err != nil {
            fmt.Printf("Read error: %v\n", err)
            continue
        }
        msg := string(buf[:n])
        fmt.Printf("Received from %s: %q\n", clientAddr, msg)

        reply := []byte("sending back")
        _, err = conn.WriteToUDP(reply, clientAddr)
        if err != nil {
            fmt.Printf("Write to %s failed: %v\n", clientAddr, err)
        }
    }
}

对应地,Node 2(客户端)可保持简洁,但推荐使用 net.DialUDP 显式构造连接(更可控),或继续用 net.Dial("udp", ...)(底层仍为 UDP):

package main

import (
    "fmt"
    "net"
)

func main() {
    // 方式一:使用 DialUDP(推荐,类型安全)
    remoteAddr := &net.UDPAddr{IP: net.ParseIP("127.0.0.1"), Port: 7000}
    conn, err := net.DialUDP("udp", nil, remoteAddr)
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    _, _ = conn.Write([]byte("first send"))

    buf := make([]byte, 1024)
    n, _, _ := conn.ReadFromUDP(buf)
    fmt.Printf("Reply: %q\n", string(buf[:n]))

    // 方式二:若坚持用 Dial,需注意返回的是 Conn 接口,Write/Read 可用,但无地址感知能力
    // sock, _ := net.Dial("udp", "127.0.0.1:7000")
    // sock.Write([]byte("first send"))
    // sock.Read(buf)
}

⚠️ 关键注意事项:

总结:UDP 双向通信的本质是「请求-响应」模型,而非 TCP 的流式连接。Go 的 ReadFromUDP/WriteToUDP 正是为此设计——它们将地址信息与数据载荷解耦,赋予开发者完全的包级控制权。掌握这一模式,即可稳健构建高并发、低延迟的 UDP 应用(如 DNS、STUN、实时音视频信令等)。