当前位置：首页 > 文章列表 > Golang > Go教程 > Go语言构建TCP客户端与服务器教程

Go语言构建TCP客户端与服务器教程

2025-10-15 18:42:36 0浏览收藏

**用 Go 构建 TCP 客户端与服务器教程：新手入门指南** 想学习如何使用 Go 语言构建网络应用吗？本文将手把手教你构建一个简单的 TCP 客户端/服务器应用程序。我们将深入讲解服务器端的端口监听、客户端的连接建立，以及数据的发送与接收等核心步骤。同时，你还将学习如何利用 Go 语言的 goroutine 实现并发处理，轻松应对多客户端连接。通过本教程，你不仅能掌握 Go 语言网络编程的基本概念，还能获得创建基础客户端/服务器应用的实战经验。快来一起探索 Go 语言网络编程的魅力吧！

使用 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): 从连接中读取数据，打印接收到的消息，并向客户端发送响应。

客户端实现

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

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

代码解释：