当前位置：首页 > 文章列表 > Golang > Go教程 > GolangUDP丢包检测与重传实现方法

GolangUDP丢包检测与重传实现方法

2026-01-01 12:25:35 0浏览收藏

“纵有疾风来，人生不言弃”，这句话送给正在学习Golang的朋友们，也希望在阅读本文《Golang UDP丢包检测与重传实现示例》后，能够真的帮助到大家。我也会在后续的文章中，陆续更新Golang相关的技术文章，有好的建议欢迎大家在评论留言，非常感谢！

首先实现UDP可靠传输需在应用层引入序列号、ACK确认与超时重传机制，示例采用停等协议确保数据送达，发送方递增序列号并等待带序列号的ACK，超时则重发；接收方解析序列号并回传对应ACK，基础方案可进一步优化为滑动窗口、动态超时等以提升效率与鲁棒性。

Golang UDP数据包丢失检测与重发示例

UDP协议本身不保证数据包的可靠传输，因此在使用Golang开发需要确保数据送达的应用时，必须自行实现丢包检测与重发机制。下面介绍一种简单的实现思路，并提供可运行的示例代码。

基本设计思路

为了实现UDP丢包重传，我们需要在应用层模拟类似TCP的部分机制，主要包括：

序列号标记：每个发送的数据包带上唯一递增的ID，用于接收方确认和发送方识别是否被响应。
ACK确认机制：接收方收到包后返回一个确认（ACK）包。
超时重传：发送方启动定时器，若在指定时间内未收到ACK，则重新发送该包。
停止等待协议（Stop-and-Wait）：一次只允许一个未确认的包在途，简化逻辑。

发送方实现：带超时重传的UDP客户端

以下是一个简单客户端实现，发送消息并等待ACK，超时则重发。

package main
import (
"encoding/binary"
"fmt"
"net"
"time"
)
func main() {
addr,  := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
conn,  := net.DialUDP("udp", nil, addr)
defer conn.Close()
var seq uint32 = 1
data := []byte("Hello, reliable UDP!")

for {
    // 构造数据包：4字节序列号 + 数据
    packet := make([]byte, 4+len(data))
    binary.BigEndian.PutUint32(packet[0:4], seq)
    copy(packet[4:], data)

    // 发送数据包
    conn.Write(packet)
    fmt.Printf("已发送包，序列号: %d\n", seq)

    // 设置读取超时（例如 2 秒）
    conn.SetReadDeadline(time.Now().Add(2 * time.Second))

    // 等待 ACK
    var buf [1024]byte
    n, _, err := conn.ReadFromUDP(buf[:])
    if err != nil {
        if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
            fmt.Printf("序列号 %d 超时，正在重传...\n", seq)
            continue // 重传
        }
        fmt.Println("读取错误:", err)
        return
    }

    // 检查是否是期望的ACK
    ackSeq := binary.BigEndian.PutUint32(buf[:4])
    if ackSeq == seq {
        fmt.Printf("收到ACK，序列号: %d，发送完成。\n", seq)
        break
    }
}
}

接收方实现：返回ACK的UDP服务端

服务端接收数据包，提取序列号，并回传ACK。

package main
import (
"encoding/binary"
"fmt"
"net"
)
func main() {
addr,  := net.ResolveUDPAddr("udp", ":8080")
conn,  := net.ListenUDP("udp", addr)
defer conn.Close()
fmt.Println("UDP服务器已启动，监听端口 8080...")

var buf [1024]byte
for {
    n, clientAddr, err := conn.ReadFromUDP(buf[:])
    if err != nil {
        fmt.Println("读取错误:", err)
        continue
    }

    // 解析序列号
    seq := binary.BigEndian.Uint32(buf[:4])
    data := buf[4:n]

    fmt.Printf("收到数据，序列号: %d, 内容: %s\n", seq, string(data))

    // 回传ACK（原样返回序列号）
    ack := make([]byte, 4)
    binary.BigEndian.PutUint32(ack, seq)
    conn.WriteToUDP(ack, clientAddr)
}
}