跳转到主内容
websoft网络软件专家 - 深耕网络技术,打造实用软件!

如何使用Golang进行UDP通信_Golang net UDP发送接收示例

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

相关文章