Golang net TCP与UDP网络通信实践-Golang-PHP中文网

Golang net TCP与UDP网络通信实践

P粉602998670

发布： 2025-09-30 10:06:03

原创

620人浏览过

Go语言中net包支持TCP与UDP编程。1. TCP通过net.Listen监听，Accept接收连接，每连接启goroutine处理；2. UDP用net.ListenUDP监听，ReadFromUDP收包，WriteToUDP回包；3. 注意错误处理、TCP粘包、UDP大小限制及资源释放。

golang net tcp与udp网络通信实践

Go语言标准库中的net包为TCP和UDP网络编程提供了简洁而强大的支持。无论是构建高性能服务器还是轻量级客户端，Golang都能以极少的代码实现稳定通信。下面通过实际示例展示TCP与UDP的基本用法和关键细节。

TCP通信：可靠连接的基础

TCP是面向连接的协议，适合需要确保数据完整性和顺序的应用场景，比如HTTP服务、文件传输等。

1. TCP服务器
使用net.Listen监听端口，接受客户端连接并处理数据：

func startTCPServer() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()
    log.Println("TCP服务器启动，监听 :8080")

    for {
        conn, err := listener.Accept()
        if err != nil {
            log.Println("接受连接失败:", err)
            continue
        }
        go handleTCPConn(conn)
    }
}

func handleTCPConn(conn net.Conn) {
    defer conn.Close()
    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            log.Println("读取结束或出错:", err)
            return
        }
        log.Printf("收到: %s", string(buffer[:n]))
        // 回显数据
        conn.Write([]byte("echo: " + string(buffer[:n])))
    }
}

登录后复制

2. TCP客户端
连接服务器并发送消息：

func tcpClient() {
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    conn.Write([]byte("Hello TCP Server"))
    
    buf := make([]byte, 1024)
    n, _ := conn.Read(buf)
    log.Printf("回显: %s", string(buf[:n]))
}

登录后复制

TCP的关键在于连接管理。服务器通常为每个连接启动一个goroutine，利用Go的轻量级并发模型高效处理多个客户端。

UDP通信：无连接的高效传输

UDP不建立连接，适合对实时性要求高、可容忍少量丢包的场景，如音视频流、心跳包等。

立即学习“go语言免费学习笔记（深入）”；

微信 WeLM

WeLM不是一个直接的对话机器人，而是一个补全用户输入信息的生成模型。

查看详情

1. UDP服务器
使用net.ListenUDP绑定地址，接收任意来源的数据包：

func startUDPServer() {
    addr, _ := net.ResolveUDPAddr("udp", ":9090")
    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()
    log.Println("UDP服务器启动，监听 :9090")

    buffer := make([]byte, 1024)
    for {
        n, clientAddr, err := conn.ReadFromUDP(buffer)
        if err != nil {
            log.Println("读取失败:", err)
            continue
        }
        log.Printf("来自 %s: %s", clientAddr, string(buffer[:n]))
        // 回复客户端
        conn.WriteToUDP([]byte("UDP echo"), clientAddr)
    }
}

登录后复制

2. UDP客户端
直接向目标地址发送数据包：

func udpClient() {
    serverAddr, _ := net.ResolveUDPAddr("udp", "localhost:9090")
    conn, err := net.DialUDP("udp", nil, serverAddr)
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    conn.Write([]byte("Hello UDP Server"))

    response := make([]byte, 1024)
    n, _, _ := conn.ReadFromUDP(response)
    log.Printf("收到回复: %s", string(response[:n]))
}

登录后复制

UDP通信中，服务器通过ReadFromUDP获取客户端地址，再用WriteToUDP回复。客户端则可通过DialUDP建立虚拟连接简化收发流程。