GolangUDP通信教程：发送接收详解

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《Golang UDP通信教程：发送接收示例详解》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

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

• 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 太小，超出部分会被直接丢弃，且不报错——这是最隐蔽的问题之一。

常见错误现象：发送端确认发了 2048 字节，接收端只收到前 512 字节，且无任何 error 提示。

• 务必让接收缓冲区足够大，例如 buf := make([]byte, 65536)
• 检查返回的 n 值是否等于 len(buf)，若相等，说明可能被截断（虽然罕见，但在高负载或低 ulimit 下可能发生）
• UDP 本身不保证可靠和有序，应用层如需分片/重组、校验、重传，必须自行实现，标准库不提供

一个最小可行的 echo 示例（带超时和错误处理）

以下代码同时包含 sender 和 receiver 逻辑，适合本地测试。注意它使用 time.AfterFunc 模拟超时退出，避免无限阻塞。

package main
<p>import (
"log"
"net"
"time"
)</p><p>func main() {
// 启动接收端
go func() {
conn, err := net.ListenUDP("udp", &net.UDPAddr{Port: 8080})
if err != nil {
log.Fatal(err)
}
defer conn.Close()</p><pre class="brush:php;toolbar:false;">    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 可能永久挂起。

以上就是《GolangUDP通信教程：发送接收详解》的详细内容，更多关于的资料请关注golang学习网公众号！