UDP通信前必须绑定本地地址,Go中net.ListenUDP创建已绑定的*net.UDPConn;指定地址需确保可绑定,否则出现connection refused;ReadFromUDP/WriteToUDP对应recvfrom/sendto,不可用conn.Read/Write。

UDP通信前必须绑定本地地址
Go 的 net.ListenUDP 不是“开启端口”就完事,它实际会创建一个已绑定的 *net.UDPConn。如果传入 ":0",系统自动分配空闲端口;但若指定 "127.0.0.1:8080",则必须确保该地址可绑定(比如不能用 0.0.0.0:8080 绑定后又试图向 127.0.0.1:8080 发送——这在某些防火墙或容器环境下会失败)。
常见错误现象:dial udp 127.0.0.1:8080: connect: connection refused,往往是因为接收端没真正 bind 成功,或 bind 地址与发送目标不匹配。
- 接收端应显式绑定到
"0.0.0.0:8080"或"127.0.0.1:8080",避免用localhost:8080(DNS 解析可能引入延迟或失败) - 发送端用
net.DialUDP时,laddr参数可为nil,让系统自动选源地址和端口 - 若需复用同一个本地端口收发(例如打洞场景),接收端必须用
net.ListenUDP,再通过其WriteToUDP发送,而非另起DialUDP
recvfrom 和 sendto 的等价写法:ReadFromUDP vs WriteToUDP
UDP 是无连接协议,Go 抽象为两个核心方法:ReadFromUDP 返回数据和对端地址,WriteToUDP 需显式传入目标地址。它们对应系统调用的 recvfrom 和 sendto,不是 read/write。
容易踩的坑:用 conn.Read() 读 UDP 会 panic,因为底层没有关联的“默认远端”;同样,conn.Write() 会报错 "use of closed network connection" 或 "protocol wrong type for socket"。
立即学习“go语言免费学习笔记(深入)”;
-
ReadFromUDP(buf []byte)返回n, addr, err,addr是*net.UDPAddr,可用于后续回复 -
WriteToUDP(b []byte, addr *net.UDPAddr)中的addr必须是非 nil,且格式正确(不能是"host:port"字符串,得是解析后的*net.UDPAddr) - 若反复向同一地址发送,可提前用
net.ResolveUDPAddr("udp", "127.0.0.1:8080")缓存解析结果,避免每次调用都走 DNS
如何处理 UDP 包截断和缓冲区溢出
UDP 数据报有 MTU 限制(通常 IPv4 为 65507 字节有效载荷),但 Go 的 ReadFromUDP 默认只读取当前系统 socket 缓冲区里的第一个完整数据报。如果应用层缓冲区 buf 太小,超出部分会被直接丢弃,且不报错——这是最隐蔽的问题之一。
常见错误现象:发送端确认发了 2048 字节,接收端只收到前 512 字节,且无任何 error 提示。
- 务必让接收缓冲区足够大,例如
buf := make([]byte, 65536) - 检查返回的
n值是否等于len(buf),若相等,说明可能被截断(虽然罕见,但在高负载或低 ulimit 下可能发生) - UDP 本身不保证可靠和有序,应用层如需分片/重组、校验、重传,必须自行实现,标准库不提供
一个最小可行的 echo 示例(带超时和错误处理)
以下代码同时包含 sender 和 receiver 逻辑,适合本地测试。注意它使用 time.AfterFunc 模拟超时退出,避免无限阻塞。
package mainimport ( "log" "net" "time" )
func main() { // 启动接收端 go func() { conn, err := net.ListenUDP("udp", &net.UDPAddr{Port: 8080}) if err != nil { log.Fatal(err) } defer conn.Close()
buf := make([]byte, 65536) log.Println("UDP server listening on :8080") for { n, addr, err := conn.ReadFromUDP(buf) if err != nil { log.Printf("read error: %v", err) continue } log.Printf("received %d bytes from %v: %s", n, addr, string(buf[:n])) // 回复原地址 _, err = conn.WriteToUDP(buf[:n], addr) if err != nil { log.Printf("write error to %v: %v", addr, err) } } }() // 等待服务启动 time.Sleep(100 * time.Millisecond) // 发送端 conn, err := net.DialUDP("udp", nil, &net.UDPAddr{IP: net.ParseIP("127.0.0.1"), Port: 8080}) if err != nil { log.Fatal(err) } defer conn.Close() _, err = conn.Write([]byte("hello udp")) if err != nil { log.Fatal(err) } // 设置读超时 conn.SetReadDeadline(time.Now().Add(2 * time.Second)) buf := make([]byte, 65536) n, err := conn.Read(buf) if err != nil { log.Fatal("read timeout or error:", err) } log.Printf("echo reply: %s", string(buf[:n]))}
关键点:接收端用
ListenUDP,发送端用DialUDP;缓冲区统一设为 64KB;所有 I/O 都检查 error;发送后必须设 read deadline,否则Read可能永久挂起。










