GolangUDP客户端发送大数据示例-Golang-PHP中文网

GolangUDP客户端发送大数据示例

P粉602998670

发布： 2025-09-05 08:52:01

原创

1022人浏览过

答案：Golang中UDP发送大数据需手动分片，每片加序号和总数信息，建议单片不超过1400字节以避免IP分片，通过UDP连接逐个发送分片，接收端按序重组，示例中将5000字节数据以1400字节为块分片发送并打印进度，服务端需缓存并按序合并，因UDP不可靠，实际应用需处理丢包、乱序等问题。

golangudp客户端发送大数据示例

在使用 Golang 的 UDP 协议发送数据时，需要注意 UDP 的最大传输单元（MTU）限制。通常情况下，UDP 单个数据包建议不超过 1400 字节左右（以避免 IP 层分片）。如果要发送“大数据”，必须手动将数据分片，然后在接收端重组。下面是一个简单的 Golang UDP 客户端发送大数据的示例，包含分片逻辑。

UDP 分片发送原理

UDP 本身不保证可靠性，也不支持自动分包和重组。因此，发送超过 MTU 的数据时，需要：

将大数据切分为多个小于 MTU 的片段（如 1400 字节）
每个片段加上序号和总片段数等元信息
逐个发送片段
接收端根据序号重组数据

客户端分片发送代码示例

以下是一个发送大数据的 UDP 客户端实现：

package main
<p>import (
"encoding/binary"
"fmt"
"net"
"os"
)</p><p>// 数据片段结构
type Packet struct {
Index      uint16 // 当前片段索引
Total      uint16 // 总片段数
Data       []byte // 数据内容
}</p><p>// 分片发送大数据
func sendLargeData(conn *net.UDPConn, data []byte, chunkSize int) error {
total := (len(data) + chunkSize - 1) / chunkSize // 向上取整</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">for i := 0; i < total; i++ {
    start := i * chunkSize
    end := start + chunkSize
    if end > len(data) {
        end = len(data)
    }

    packet := Packet{
        Index: uint16(i),
        Total: uint16(total),
        Data:  data[start:end],
    }

    // 序列化发送
    buf := make([]byte, 4+len(packet.Data))
    binary.BigEndian.PutUint16(buf[0:2], packet.Index)
    binary.BigEndian.PutUint16(buf[2:4], packet.Total)
    copy(buf[4:], packet.Data)

    _, err := conn.Write(buf)
    if err != nil {
        return fmt.Errorf("发送片段 %d 失败: %v", i, err)
    }

    fmt.Printf("已发送片段 %d / %d, 大小: %d 字节\n", i+1, total, len(packet.Data))
}

return nil

登录后复制

}

func main() { serverAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080") if err != nil { fmt.Fprintf(os.Stderr, "解析地址失败: %v\n", err) return }

conn, err := net.DialUDP("udp", nil, serverAddr)
if err != nil {
    fmt.Fprintf(os.Stderr, "连接失败: %v\n", err)
    return
}
defer conn.Close()

// 生成 5000 字节测试数据
largeData := make([]byte, 5000)
for i := range largeData {
    largeData[i] = byte(i % 256)
}

fmt.Printf("开始发送 %d 字节数据...\n", len(largeData))
err = sendLargeData(conn, largeData, 1400)
if err != nil {
    fmt.Fprintf(os.Stderr, "发送失败: %v\n", err)
    return
}

fmt.Println("发送完成")

登录后复制

}