Golangnet包实现TCPUDP通信教程

Go语言的net包以简洁高效的设计原生支持TCP和UDP网络编程，通过监听端口、建立连接（TCP）或收发数据包（UDP），结合goroutine实现高并发处理，配合严谨的错误处理与资源管理，让开发者无需依赖第三方库即可快速构建可靠、低延迟的网络服务——无论你是想搭建一个回显服务器还是实时音视频通信后端，net包都提供了坚实而灵活的基础支撑。

Go语言的net包提供了对网络I/O的支持，包括TCP和UDP通信。使用它可以在不依赖第三方库的情况下实现高性能的网络服务。下面分别介绍如何用net包进行TCP和UDP编程。

TCP通信

TCP是面向连接的协议，适合需要可靠传输的场景。Go中通过net.Listen监听端口，使用Accept接收连接，每个连接返回一个net.Conn接口。

创建TCP服务器的基本流程是：监听地址 → 接受连接 → 处理数据 → 关闭连接。

package main

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

func handleConn(conn net.Conn) {
    defer conn.Close()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        text := strings.TrimSpace(scanner.Text())
        fmt.Fprintf(conn, "Echo: %s\n", text)
    }
}

func main() {
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        panic(err)
    }
    defer listener.Close()

    fmt.Println("Server listening on :8080")
    for {
        conn, err := listener.Accept()
        if err != nil {
            continue
        }
        go handleConn(conn)
    }
}

使用net.Dial连接服务器，发送请求并读取响应。

package main

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

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

    go func() {
        scanner := bufio.NewScanner(conn)
        for scanner.Scan() {
            fmt.Println("收到:", scanner.Text())
        }
    }()

    input := bufio.NewScanner(os.Stdin)
    for input.Scan() {
        fmt.Fprintf(conn, "%s\n", input.Text())
    }
}

UDP通信

UDP是无连接协议，适用于低延迟、能容忍丢包的场景，比如音视频传输或心跳包。Go中使用net.ListenPacket监听UDP端口，返回net.PacketConn接口。

服务端绑定地址后循环读取数据包，并可回发响应。

package main

import (
    "fmt"
    "net"
)

func main() {
    addr, err := net.ResolveUDPAddr("udp", ":9000")
    if err != nil {
        panic(err)
    }

    conn, err := net.ListenUDP("udp", addr)
    if err != nil {
        panic(err)
    }
    defer conn.Close()

    fmt.Println("UDP server listening on :9000")
    buffer := make([]byte, 1024)
    for {
        n, clientAddr, err := conn.ReadFromUDP(buffer)
        if err != nil {
            continue
        }

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

        response := fmt.Sprintf("Echo: %s", data)
        conn.WriteToUDP([]byte(response), clientAddr)
    }
}

客户端同样使用net.DialUDP或WriteToUDP发送数据包。

package main

import (
    "fmt"
    "net"
)

func main() {
    serverAddr, err := net.ResolveUDPAddr("udp", "localhost:9000")
    if err != nil {
        panic(err)
    }

    conn, err := net.DialUDP("udp", nil, serverAddr)
    if err != nil {
        panic(err)
    }
    defer conn.Close()

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

    response := make([]byte, 1024)
    n, _, err := conn.ReadFromUDP(response)
    if err != nil {
        fmt.Println("读取响应失败:", err)
        return
    }

    fmt.Println("收到响应:", string(response[:n]))
}

关键点说明

掌握以下几点有助于更好使用net包：

• 并发处理：TCP服务器通常为每个连接启动一个goroutine，避免阻塞后续连接。
• 错误处理：网络操作容易出错，如连接中断、超时等，需合理处理error。
• 资源释放：始终用defer conn.Close()确保连接关闭。
• 协议选择：根据业务需求选TCP（可靠）或UDP（快速）。
• 地址格式：使用IP:Port形式，如:8080表示本机所有IP的8080端口。

今天关于《Golangnet包实现TCPUDP通信教程》的内容介绍就到此结束，如果有什么疑问或者建议，可以在golang学习网公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！