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

使用 Go 语言构建简单的 TCP 客户端-服务器应用

聖光之護

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

原创

500人浏览过

使用 go 语言构建简单的 tcp 客户端-服务器应用

本文档旨在引导读者使用 Go 语言构建一个基本的 TCP 客户端-服务器应用。我们将介绍服务器端监听端口、客户端连接服务器，以及简单的数据交互。通过本文，读者将了解 Go 语言网络编程的基础知识，并能搭建起一个简单的客户端-服务器通信框架。

服务器端实现

服务器端的主要职责是监听指定的端口，接受客户端的连接请求，并处理客户端发送的数据。以下是一个简单的 TCP 服务器端示例：

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
        }

        fmt.Println("Client connected")
        go handleConnection(conn) // 使用 goroutine 处理每个连接
    }
}

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 from client: %s\n", string(buffer[:n]))

        _, err = conn.Write([]byte("Server received: " + string(buffer[: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): 读取客户端发送的数据，并向客户端发送响应。

注意事项：

服务器端应该使用 goroutine 并发处理每个连接，避免阻塞主线程。
defer conn.Close() 确保在连接处理完成后关闭连接，释放资源。
错误处理至关重要，应该检查每个可能出错的地方，并进行适当的处理。

客户端实现

客户端的主要职责是连接服务器，发送数据，并接收服务器的响应。以下是一个简单的 TCP 客户端示例：

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, "\r\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 from server: %s\n", string(buffer[:n]))
    }
}

登录后复制

代码解释：