Go语言原生支持UDP通信,核心为net.UDPAddr和net.UDPConn;可用net.DialUDP建立连接式socket,或net.ListenUDP监听端口;需手动处理丢包、超时,推荐goroutine并发读取并及时关闭连接。
Go语言通过net包原生支持UDP通信,使用简单、性能高效,适合实现轻量级服务(如DNS、SNMP、游戏心跳包等)。核心是net.UDPAddr和net.UDPConn,无需额外依赖。
使用net.DialUDP可建立连接式UDP socket(自动绑定本地端口),适合点对点单次/多次通信;若需监听多个地址或自定义绑定,用net.ListenUDP更灵活。
前需构造目标地址:addr, _ := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
conn, err := net.DialUDP("udp", nil, addr),第二个参数为本地绑定地址,传nil由系统自动分配n, err := conn.Write([]byte("hello")),返回实际写入字节数服务端通常用net.ListenUDP绑定指定地址,然后循环读取数据包。每个UDP数据包独立,需按需解析长度和内容。
laddr, _ := net.ResolveUDPAddr("udp", ":9999")(:9999表示监听所有网卡的9999端口)conn, err := net.ListenUDP("udp", laddr)
buf := make([]byte, 1024),然后n, clientAddr, err := conn.ReadFromUDP(buf)
clientAddr包含发送方IP和端口,可用于回包;n是有效数据长度,buf[:n]才是真实内容UDP本身无连接状态,但高并发场景下需避免阻塞主线程。推荐用goroutine配合循环读取,并确保连接关闭。
for循环+ReadFromUDP持续接收,不要在单次调用后退出go handlePacket(buf[:n], clientAddr),避免长耗时操作阻塞后续读取conn.Close(),防止端口占用;也可用defer conn.Close()确保释放以下是一个完整可运行的UDP回显服务(接收什么就发回什么):
服务端:conn, _ := net.ListenUDP("udp", &net.UDPAddr{Port: 8080})
defer conn.Close()
buf := make([]byte, 1024)
for {
n, addr, _ := conn.ReadFromUDP(buf)
conn.WriteToUDP(buf[:n], addr) // 原样返回
}
客户端:
conn, _ := net.DialUDP("udp", nil, &net.UDPAddr{IP: net.ParseIP("127.0.0.1"), Port: 8080})
defer conn.Close()
conn.Write([]byte("ping"))
buf := make([]byte, 1024)
n, _ := conn.Read(buf)
fmt.Println(string(buf[:n])) // 输出 "ping"