使用 Go 语言构建 TCP 客户端/服务器应用-Golang-PHP中文网

使用 Go 语言构建 TCP 客户端/服务器应用

花韻仙語

发布： 2025-09-23 19:51:01

原创

488人浏览过

使用 go 语言构建 tcp 客户端/服务器应用

本文旨在指导开发者使用 Go 语言构建一个简单的 TCP 客户端/服务器应用程序。我们将涵盖服务器的监听、客户端的连接、数据的发送与接收，以及并发处理多个客户端连接的关键技术。通过本文，你将了解 Go 语言网络编程的基本概念，并掌握创建基本客户端/服务器应用的方法。

服务器端实现

服务器端的核心任务是监听指定端口，接受客户端连接，并处理接收到的数据。以下是一个基础的服务器端代码示例：

package main

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

func main() {
    // 监听端口
    listener, err := net.Listen("tcp", ":8080")
    if err != nil {
        fmt.Println("Error listening:", err.Error())
        os.Exit(1)
    }
    defer listener.Close()

    fmt.Println("Server listening on :8080")

    for {
        // 接受连接
        conn, err := listener.Accept()
        if err != nil {
            fmt.Println("Error accepting: ", err.Error())
            continue
        }

        // 处理连接（使用 goroutine 实现并发）
        go handleConnection(conn)
    }
}

// 处理单个连接
func handleConnection(conn net.Conn) {
    defer conn.Close()

    buffer := make([]byte, 1024)
    for {
        // 读取数据
        n, err := conn.Read(buffer)
        if err != nil {
            fmt.Println("Error reading:", err.Error())
            return
        }

        // 处理数据
        fmt.Printf("Received: %s", string(buffer[:n]))

        // 发送响应
        _, err = conn.Write([]byte("Message received!\n"))
        if err != nil {
            fmt.Println("Error writing:", err.Error())
            return
        }
    }
}

登录后复制

代码解释：

net.Listen("tcp", ":8080"): 在 TCP 协议的 8080 端口上启动监听器。
listener.Accept(): 接受客户端的连接请求，返回一个 net.Conn 对象，代表一个连接。
go handleConnection(conn): 使用 goroutine 并发地处理每个连接。这使得服务器可以同时处理多个客户端连接。
handleConnection(conn net.Conn): 从连接中读取数据，打印接收到的消息，并向客户端发送响应。

客户端实现

客户端需要连接到服务器，发送数据，并接收服务器的响应。以下是一个简单的客户端代码示例：

AppMall应用商店

AI应用商店，提供即时交付、按需付费的人工智能应用服务

查看详情

package main

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

func main() {
    // 连接到服务器
    conn, err := net.Dial("tcp", "localhost:8080")
    if err != nil {
        fmt.Println("Error connecting:", err.Error())
        os.Exit(1)
    }
    defer conn.Close()

    fmt.Println("Connected to server")

    reader := bufio.NewReader(os.Stdin)

    for {
        // 读取用户输入
        fmt.Print("Enter text: ")
        line, _ := reader.ReadString('\n')
        line = strings.TrimRight(line, "\n")

        // 发送数据
        _, err = conn.Write([]byte(line + "\n"))
        if err != nil {
            fmt.Println("Error writing:", err.Error())
            break
        }

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

        fmt.Printf("Received: %s", string(buffer[:n]))
    }
}

登录后复制

代码解释：