如何在Golang中使用net包实现TCP通信-Golang-PHP中文网

如何在Golang中使用net包实现TCP通信

P粉602998670

发布： 2025-10-22 17:00:07

原创

362人浏览过

使用net包实现TCP通信，服务器通过net.Listen监听端口，accept连接后用goroutine处理；客户端用net.Dial连接，通过Read/Write收发数据，注意消息边界与错误处理。

如何在golang中使用net包实现tcp通信

在Golang中，net包提供了对网络I/O的支持，包括TCP、UDP和Unix域套接字等。实现TCP通信主要依赖于net.Listen和net.Dial两个核心函数。下面介绍如何使用net包完成一个简单的TCP客户端与服务器通信。

创建TCP服务器

TCP服务器需要监听指定的地址和端口，等待客户端连接。每当有新连接建立时，启动一个协程处理该连接，保证服务器可以同时服务多个客户端。

示例代码：

package main

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

func main() {
    // 监听本地8080端口
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println("监听失败:", err)
        return
    }
    defer listener.Close()
    fmt.Println("服务器已启动，监听 :8080...")

    for {
        // 接受客户端连接
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("接受连接失败:", err)
            continue
        }

        // 启动协程处理连接
        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()
    scanner := bufio.NewScanner(conn)
    for scanner.Scan() {
        message := strings.TrimSpace(scanner.Text())
        fmt.Printf("收到消息: %s\n", message)

        // 回显消息给客户端
        response := fmt.Sprintf("你发送的是: %s\n", message)
        conn.Write([]byte(response))
    }
}

登录后复制

创建TCP客户端

客户端通过net.Dial连接到服务器，然后可以发送数据并读取响应。

android rtsp流媒体播放介绍中文WORD版

本文档主要讲述的是android rtsp流媒体播放介绍；实时流协议（RTSP）是应用级协议，控制实时数据的发送。RTSP提供了一个可扩展框架，使实时数据，如音频与视频，的受控、点播成为可能。数据源包括现场数据与存储在剪辑中数据。该协议目的在于控制多个数据发送连接，为选择发送通道，如UDP、组播UDP与TCP，提供途径，并为选择基于RTP上发送机制提供方法。希望本文档会给有需要的朋友带来帮助；感兴趣的朋友可以过来看看

查看详情

示例代码：

package main

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

func main() {
    // 连接到本地8080端口
    conn, err := net.Dial("tcp", "127.0.0.1:8080")
    if err != nil {
        fmt.Println("连接失败:", err)
        return
    }
    defer conn.Close()

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

    // 从标准输入读取用户输入
    input := bufio.NewScanner(os.Stdin)
    for {
        fmt.Print("请输入消息: ")
        if !input.Scan() {
            break
        }

        line := input.Text()
        if line == "quit" {
            break
        }

        // 发送数据到服务器
        _, err := conn.Write([]byte(line + "\n"))
        if err != nil {
            fmt.Println("发送失败:", err)
            break
        }

        // 读取服务器响应
        buffer := make([]byte, 1024)
        n, err := conn.Read(buffer)
        if err != nil {
            fmt.Println("读取响应失败:", err)
            break
        }

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

登录后复制