Golang net包UDP数据传输操作示例
UDP（用户数据报协议）是一种无连接的传输层协议，注重传输速度和低延迟，适用于实时音视频、在线游戏、DNS查询等场景。Go语言标准库中的 net 包提供了对UDP协议的完整支持，开发者可以方便地构建UDP服务器和客户端。本文将详细介绍如何使用 net 包进行UDP数据的收发操作，并给出完整的示例代码。
核心类型与函数
在进行UDP编程时，我们主要使用以下几个类型和函数：
net.ResolveUDPAddr：解析UDP地址字符串，返回*net.UDPAddr。net.ListenUDP：在指定的UDP地址上监听，返回*net.UDPConn。net.DialUDP：向指定的UDP地址发起连接（实际上UDP无连接，但会创建本地地址绑定），返回*net.UDPConn。(*net.UDPConn).ReadFromUDP：从连接读取数据，并返回发送方的地址。(*net.UDPConn).WriteToUDP：向指定地址发送数据。(*net.UDPConn).SetReadDeadline/SetWriteDeadline：设置读写超时。
UDP服务器示例
下面是一个简单的UDP回声服务器，它监听本地端口 8888，接收客户端发来的数据，原样返回并附加上前缀 "Echo: "。
package main
import (
"fmt"
"net"
"time"
)
func main() {
// 解析UDP地址
addr, err := net.ResolveUDPAddr("udp", ":8888")
if err != nil {
fmt.Println("地址解析失败:", err)
return
}
// 监听UDP端口
conn, err := net.ListenUDP("udp", addr)
if err != nil {
fmt.Println("监听失败:", err)
return
}
defer conn.Close()
fmt.Println("UDP服务器已启动，监听端口:", addr.Port)
// 设置读取超时为10秒，避免ReadFromUDP永久阻塞
conn.SetReadDeadline(time.Now().Add(10 * time.Second))
buffer := make([]byte, 1024)
for {
// 读取客户端数据
n, clientAddr, err := conn.ReadFromUDP(buffer)
if err != nil {
// 如果超时或其他错误，重置超时并继续
netErr, ok := err.(net.Error)
if ok && netErr.Timeout() {
fmt.Println("读取超时，重置...")
conn.SetReadDeadline(time.Now().Add(10 * time.Second))
continue
}
fmt.Println("读取错误:", err)
break
}
// 处理数据：回显并加上前缀
received := string(buffer[:n])
response := fmt.Sprintf("Echo: %s", received)
fmt.Printf("收到来自 %s 的数据: %s\n", clientAddr, received)
// 发送回客户端
_, err = conn.WriteToUDP([]byte(response), clientAddr)
if err != nil {
fmt.Println("发送失败:", err)
}
}
}代码说明：
使用
net.ResolveUDPAddr解析地址，":8888"表示监听所有可用IP地址的8888端口。net.ListenUDP返回一个*net.UDPConn，用于读写操作。为防止
ReadFromUDP永久阻塞，通过SetReadDeadline设置了每次读取的超时时间，超时后可以灵活处理（此处重置超时继续监听）。读取数据时，同时获得客户端地址
clientAddr，之后用WriteToUDP向该地址回复数据。
UDP客户端示例
客户端向服务器发送一条消息，然后等待接收服务器的回应。
package main
import (
"fmt"
"net"
"time"
)
func main() {
// 解析服务器地址
serverAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8888")
if err != nil {
fmt.Println("地址解析失败:", err)
return
}
// 建立本地UDP连接（不会真正建立连接，但会绑定本地地址）
conn, err := net.DialUDP("udp", nil, serverAddr)
if err != nil {
fmt.Println("拨号失败:", err)
return
}
defer conn.Close()
// 发送数据
message := []byte("Hello UDP Server!")
_, err = conn.Write(message)
if err != nil {
fmt.Println("发送失败:", err)
return
}
fmt.Println("已发送:", string(message))
// 设置读取超时时间
conn.SetReadDeadline(time.Now().Add(5 * time.Second))
// 接收服务器的回复
buffer := make([]byte, 1024)
n, _, err := conn.ReadFromUDP(buffer)
if err != nil {
fmt.Println("接收失败:", err)
return
}
fmt.Println("收到回复:", string(buffer[:n]))
}说明：
net.DialUDP的第二个参数为本地地址，设为nil表示由系统自动分配。Write方法直接向拨号时指定的远程地址发送数据。ReadFromUDP可以获取发送方的地址（此处忽略），同样需要设置超时。
错误处理与超时
UDP通信可能遇到网络超时、缓冲区满等错误。Go中可以通过 net.Error 接口判断错误类型：
if netErr, ok := err.(net.Error); ok {
if netErr.Timeout() {
fmt.Println("操作超时")
}
if netErr.Temporary() {
fmt.Println("临时错误，可以重试")
}
}合理使用 SetReadDeadline 和 SetWriteDeadline 可以避免goroutine被长时间阻塞，使服务器能够优雅地处理无数据到达的情况。
并发UDP服务器
与TCP不同，UDP服务器不需要为每个客户端创建单独的goroutine，因为所有数据都通过同一个套接字收发。但为了提升数据处理的并行度，可以将具体的业务逻辑放入goroutine：
// 在读取循环中
n, clientAddr, err := conn.ReadFromUDP(buffer)
if err != nil {
// 错误处理...
continue
}
// 将数据拷贝一份，避免buffer被覆盖
data := make([]byte, n)
copy(data, buffer[:n])
go handleClient(conn, clientAddr, data)这样主循环继续监听新数据，而每个客户端的处理工作在独立的goroutine中执行，能够充分利用多核性能。
注意事项
数据报大小限制：UDP数据报理论最大长度为65535字节，但实际受路径MTU限制，通常建议控制在1472字节以内，避免IP分片。
无连接特性：UDP不保证数据到达和顺序，需要在应用层自行处理丢包、重传等问题。
端口复用：如果需要在同一地址快速重启服务器，可以设置
syscall.SO_REUSEADDR，但Go标准库并未直接提供，可以通过net.ListenConfig配合Control函数实现。广播与组播：Go的
net包也支持UDP广播和组播，可通过设置Socket选项实现。
总结
本文通过两个完整示例演示了如何在Go语言中使用 net 包进行UDP数据的发送和接收。UDP编程比TCP简单，但需要开发者自行处理超时、丢包等可靠性问题。在实际项目（如DNS服务器、日志收集、实时通信）中，可以基于上述模式构建健壮的UDP服务。
所有示例代码均可直接编译运行，读者可修改地址、端口和数据处理逻辑，快速构建自己的UDP应用。