当前位置：首页 > 文章列表 > Golang > Go教程 > Golang实现UDP通信教程详解

Golang实现UDP通信教程详解

2025-11-29 16:33:29 0浏览收藏

本文详细介绍了如何使用 Golang 实现 UDP 客户端与服务器的通信。通过 Go 语言的 `net` 包，轻松构建基于 UDP 协议的应用程序，适用于心跳包、日志传输等轻量级通信场景。教程提供了完整的服务器端和客户端代码示例，服务器端监听 8080 端口，接收并回显客户端发送的数据；客户端则发送消息并接收服务器的响应。文章还包含了详细的运行说明和注意事项，例如 UDP 的不可靠性以及数据报大小限制等，帮助开发者快速上手并理解 UDP 通信机制，代码简洁易懂，是学习 Golang UDP 编程的绝佳教程。

UDP服务器监听8080端口接收数据并回显，客户端发送消息并接收响应，使用Go的net包实现，适用于轻量级通信场景。

用Golang实现一个基于UDP协议的简单客户端和服务器

下面是一个基于UDP协议的简单客户端和服务器程序，使用Golang实现。UDP是无连接的协议，适合轻量级通信场景，比如心跳包、日志传输等。

1. UDP服务器实现

服务器监听指定端口，接收客户端发来的数据，并原样返回响应。

package main

import (
    "fmt"
    "net"
)

func main() {
    // 绑定地址和端口
    addr, err := net.ResolveUDPAddr("udp", "127.0.0.1:8080")
    if err != nil {
        fmt.Println("地址解析错误:", err)
        return
    }

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

    fmt.Println("UDP服务器已启动，监听 8080 端口...")

    buffer := make([]byte, 1024)
    for {
        // 读取客户端数据
        n, clientAddr, err := conn.ReadFromUDP(buffer)
        if err != nil {
            fmt.Println("读取数据出错:", err)
            continue
        }

        fmt.Printf("收到来自 %s 的消息: %s\n", clientAddr, string(buffer[:n]))

        // 回复客户端
        _, err = conn.WriteToUDP([]byte("已收到: "+string(buffer[:n])), clientAddr)
        if err != nil {
            fmt.Println("发送响应失败:", err)
        }
    }
}

2. UDP客户端实现

客户端向服务器发送消息，并接收服务器的响应。

package main

import (
    "fmt"
    "net"
    "bufio"
    "os"
    "strings"
)

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

    // 连接到服务器
    conn, err := net.DialUDP("udp", nil, addr)
    if err != nil {
        fmt.Println("连接失败:", err)
        return
    }
    defer conn.Close()

    fmt.Println("已连接到UDP服务器")

    // 读取用户输入
    input := bufio.NewReader(os.Stdin)
    for {
        fmt.Print("请输入消息: ")
        message, _ := input.ReadString('\n')
        message = strings.TrimSpace(message)

        if message == "quit" {
            break
        }

        // 发送数据
        _, err := conn.Write([]byte(message))
        if err != nil {
            fmt.Println("发送失败:", err)
            continue
        }

        // 接收响应
        buffer := make([]byte, 1024)
        n, err := conn.Read(buffer)
        if err != nil {
            fmt.Println("接收响应失败:", err)
            continue
        }

        fmt.Printf("服务器回复: %s\n", string(buffer[:n]))
    }
}