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