如何在Golang中处理UDP通信_发送和接收数据包

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

Go语言通过net包原生支持UDP通信,使用简单、性能高效,适合实现轻量级服务(如DNS、SNMP、游戏心跳包等)。核心是net.UDPAddrnet.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配合循环读取,并确保连接关闭。

  • 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"