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)
}⚠️ 关键注意事项:
alUDP 建立“伪连接”时有效(即已绑定远端地址),而 ListenUDP 返回的监听连接没有远端地址,调用 Write 会返回 write: invalid argument 或类似错误(Go 版本差异可能表现不同);总结:UDP 双向通信的本质是「请求-响应」模型,而非 TCP 的流式连接。Go 的 ReadFromUDP/WriteToUDP 正是为此设计——它们将地址信息与数据载荷解耦,赋予开发者完全的包级控制权。掌握这一模式,即可稳健构建高并发、低延迟的 UDP 应用(如 DNS、STUN、实时音视频信令等)。