Golang如何使用net包进行TCP/UDP通信

P粉602998670

发布时间：2025-10-14 11:14:02

453人浏览过

来源于php中文网

原创

Go语言通过net包实现TCP和UDP编程，支持高性能网络服务。1. TCP通信：使用net.Listen监听端口，Accept接收连接，每个连接由goroutine处理，确保并发；客户端用net.Dial建立连接，收发数据后关闭。2. UDP通信：通过net.ListenPacket或net.DialUDP创建无连接服务，适用于低延迟场景，服务端读取数据包并回发响应。3. 关键点：合理利用goroutine实现并发处理，妥善处理错误，及时释放资源，根据需求选择协议，正确使用IP:Port地址格式。Go的net包简洁高效，易于构建高并发网络应用。

golang如何使用net包进行tcp/udp通信

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连接服务器，发送请求并读取响应。

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

MusicLM

谷歌平台的AI作曲工具，用文字生成音乐

下载

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接口。

UDP服务端示例：

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

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)
    }
}

UDP客户端示例：

客户端同样使用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]))
}