当前位置：首页 > 文章列表 > Golang > Go教程 > GolangUDP通信教程及数据发送实例

GolangUDP通信教程及数据发送实例

2025-09-30 12:57:54 0浏览收藏

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《Golang UDP通信教程与数据发送实例》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

Golang实现UDP通信适用于实时性高、允许丢包的场景，如游戏和直播。代码展示了客户端与服务器间的简单通信：服务器监听8080端口接收数据并响应，客户端发送消息并设置超时等待回复。应对UDP丢包，可采用应用层重传、前向纠错、选择性重传、流量控制和QoS等策略。性能优化包括调整缓冲区大小、并发处理、连接复用、数据压缩、非阻塞I/O和多路复用技术。常见错误处理策略有重试、日志记录、关闭连接、返回错误码、设置超时和数据校验，确保程序稳定可靠。

GolangUDP通信基础与数据发送示例

UDP通信，简单来说，就是一种不需要建立连接的通信方式，像寄信，你直接把信扔出去，能不能到、什么时候到，你都管不了。Golang实现UDP通信非常方便，适合对实时性要求高，但允许丢包的应用场景，比如游戏、视频直播等。

直接上干货。

package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    // 监听地址
    addr, err := net.ResolveUDPAddr("udp", ":8080")
    if err != nil {
        fmt.Println("ResolveUDPAddr error:", err)
        return
    }

    // 创建UDP连接
    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        fmt.Println("ListenUDP error:", err)
        return
    }
    defer conn.Close()

    fmt.Println("UDP server listening on :8080")

    // 接收数据
    buffer := make([]byte, 1024)
    for {
        n, remoteAddr, err := conn.ReadFromUDP(buffer)
        if err != nil {
            fmt.Println("ReadFromUDP error:", err)
            continue
        }

        fmt.Printf("Received %d bytes from %s: %s\n", n, remoteAddr, string(buffer[:n]))

        // 模拟处理数据，并发送响应
        response := fmt.Sprintf("Server received: %s", string(buffer[:n]))
        _, err = conn.WriteToUDP([]byte(response), remoteAddr)
        if err != nil {
            fmt.Println("WriteToUDP error:", err)
        }
    }
}

// 客户端代码
package main

import (
    "fmt"
    "net"
    "time"
)

func main() {
    // 服务器地址
    serverAddr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
    if err != nil {
        fmt.Println("ResolveUDPAddr error:", err)
        return
    }

    // 本地地址 (可以不指定，系统会自动分配)
    localAddr, err := net.ResolveUDPAddr("udp", ":0")
    if err != nil {
        fmt.Println("ResolveUDPAddr error:", err)
        return
    }

    // 创建UDP连接
    conn, err := net.DialUDP("udp", localAddr, serverAddr)
    if err != nil {
        fmt.Println("DialUDP error:", err)
        return
    }
    defer conn.Close()

    // 发送数据
    message := "Hello UDP Server!"
    _, err = conn.Write([]byte(message))
    if err != nil {
        fmt.Println("Write error:", err)
        return
    }

    fmt.Println("Sent:", message)

    // 接收响应
    buffer := make([]byte, 1024)
    conn.SetReadDeadline(time.Now().Add(5 * time.Second)) // 设置读取超时
    n, err := conn.Read(buffer)
    if err != nil {
        fmt.Println("Read error:", err)
        return
    }

    fmt.Printf("Received: %s\n", string(buffer[:n]))
}

这段代码展示了一个简单的UDP客户端-服务器模型。服务器监听8080端口，接收客户端发送的数据，并回复一个确认消息。客户端发送消息后，等待服务器的响应。注意客户端设置了读取超时，避免一直阻塞。

Golang UDP通信中如何处理数据包丢失？

UDP本身就是不可靠的协议，丢包是常态。应对UDP丢包，常见的策略包括：

应用层重传： 客户端在发送数据后，如果在一定时间内没有收到服务器的确认，就重新发送数据。这需要在应用层实现序列号、确认机制等。
前向纠错（FEC）： 在发送数据时，额外发送一些冗余数据，即使部分数据包丢失，也能通过冗余数据恢复原始数据。
选择性重传（SR）： 客户端只重传丢失的数据包，而不是重传所有数据。这需要客户端能够检测到哪些数据包丢失。
流量控制： 控制发送速率，避免网络拥塞导致丢包。
QoS（服务质量）： 如果网络环境允许，可以尝试配置QoS，提高UDP数据包的优先级。

具体选择哪种策略，取决于你的应用场景。例如，实时性要求非常高的场景，可能更倾向于容忍少量丢包，而不是重传。

如何优化Golang UDP通信的性能？

优化UDP性能，主要考虑以下几个方面：

缓冲区大小： 调整UDP连接的接收和发送缓冲区大小，可以提高吞吐量。可以使用conn.SetReadBuffer和conn.SetWriteBuffer方法设置缓冲区大小。
并发处理： 使用goroutine并发处理接收到的数据，可以提高服务器的并发能力。
连接复用： 避免频繁创建和销毁UDP连接，可以减少开销。
数据压缩： 对传输的数据进行压缩，可以减少网络带宽占用。
避免阻塞： 使用非阻塞I/O，避免因为等待I/O操作而阻塞goroutine。可以使用conn.SetReadDeadline设置读取超时。
多路复用： 使用epoll或kqueue等多路复用技术，可以同时监听多个UDP连接。