Golang UDP丢包检测与重传实现示例

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
    }
}
}

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)
}
}