Go语言原生支持UDP通信,核心为net.UDPAddr和net.UDPConn;可用net.DialUDP建立连接式socket,或net.ListenUDP监听端口;需手动处理丢包、超时,推荐goroutine并发读取并及时关闭连接。

Go语言通过net包原生支持UDP通信,使用简单、性能高效,适合实现轻量级服务(如DNS、SNMP、游戏心跳包等)。核心是net.UDPAddr和net.UDPConn,无需额外依赖。
创建UDP连接并发送数据
使用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")),返回实际写入字节数 - 注意:UDP不保证送达,无重传机制,应用层需自行处理超时、丢包或确认逻辑
监听UDP端口并接收数据
服务端通常用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配合循环读取,并确保连接关闭。
立即学习“go语言免费学习笔记(深入)”;
- 用
for循环+ReadFromUDP持续接收,不要在单次调用后退出 - 每个收到的数据包可起goroutine处理:
go handlePacket(buf[:n], clientAddr),避免长耗时操作阻塞后续读取 - 程序退出前调用
conn.Close(),防止端口占用;也可用defer conn.Close()确保释放 - 注意缓冲区大小:过小会截断数据,过大浪费内存;常见设为1500(以太网MTU)或4096,根据协议需求调整
简单示例:回显服务
以下是一个完整可运行的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"










