当前位置：首页 > 文章列表 > Golang > Go教程 > GolangTCP数据收发实战详解

GolangTCP数据收发实战详解

2025-10-14 19:17:54 0浏览收藏

本文是一篇实战教程，旨在帮助开发者掌握 Golang TCP 数据收发技术。文章首先通过一个基础示例，演示了如何使用 Go 语言实现客户端和服务端之间的数据通信。随后，深入探讨了 TCP 通信中常见的粘包和拆包问题，并给出了使用消息头携带长度信息这一常用解决方案的示例代码。此外，文章还介绍了如何利用 goroutine 池和多路复用等技术来提升高并发 TCP 连接的处理性能。最后，着重强调了错误处理和日志记录的重要性，并提供了心跳检测的实现方法，以确保 TCP 连接的可靠性。通过本教程的学习，读者将能够掌握 Golang TCP 编程的核心技术，并能将其应用到实际项目中。

答案：通过Go语言实现TCP通信，使用消息头携带长度信息解决粘包拆包问题，结合goroutine池和多路复用提升高并发性能，并通过心跳检测与日志记录保障连接可靠性。

GolangTCP数据包发送与接收示例

Golang TCP数据包发送与接收，简单来说，就是用Go语言实现客户端和服务端通过TCP协议进行数据通信。下面给出一个基本的示例，展示如何发送和接收数据包。

// 服务端
package main

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

const (
    SERVER_HOST = "localhost"
    SERVER_PORT = "9988"
    SERVER_TYPE = "tcp"
)

func main() {
    fmt.Println("Server Running...")
    server, err := net.Listen(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
    if err != nil {
        fmt.Println("Error listening:", err.Error())
        os.Exit(1)
    }
    defer server.Close()
    fmt.Println("Listening on " + SERVER_HOST + ":" + SERVER_PORT)
    fmt.Println("Waiting for client...")
    for {
        connection, err := server.Accept()
        if err != nil {
            fmt.Println("Error accept:", err.Error())
            return
        }
        fmt.Println("Client connected")
        go processClient(connection)
    }
}

func processClient(connection net.Conn) {
    buffer := make([]byte, 1024)
    mLen, err := connection.Read(buffer)
    if err != nil {
        fmt.Println("Error reading:", err.Error())
        return
    }
    fmt.Println("Received: ", string(buffer[:mLen]))
    _, err = connection.Write([]byte("Message received."))
    if err != nil {
        fmt.Println("Error writing:", err.Error())
        return
    }
    connection.Close()
}

// 客户端
package main

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

const (
    SERVER_HOST = "localhost"
    SERVER_PORT = "9988"
    SERVER_TYPE = "tcp"
)

func main() {
    connection, err := net.Dial(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
    if err != nil {
        fmt.Println("Error dialing:", err.Error())
        os.Exit(1)
    }
    defer connection.Close()

    fmt.Println("Connected to server")
    _, err = connection.Write([]byte("Hello Server!"))
    if err != nil {
        fmt.Println("Error writing:", err.Error())
        os.Exit(1)
    }

    buffer := make([]byte, 1024)
    mLen, err := connection.Read(buffer)
    if err != nil {
        fmt.Println("Error reading:", err.Error())
        os.Exit(1)
    }

    fmt.Println("Received: ", string(buffer[:mLen]))
}

如何处理TCP连接中的粘包和拆包问题？

TCP是面向流的协议，这意味着数据在传输过程中可能会发生粘包和拆包。简单来说，粘包就是多个小数据包被合并成一个大数据包发送，而拆包就是一个大数据包被拆分成多个小数据包发送。

解决粘包和拆包的常见方法有：

固定长度消息： 每个数据包都使用固定长度，接收方按照固定长度读取数据。这实现简单，但不够灵活，浪费带宽。
使用分隔符： 在每个数据包的末尾添加一个特殊的分隔符，接收方通过查找分隔符来分割数据包。例如，使用换行符\n作为分隔符。
消息头包含长度信息： 在每个数据包的头部添加一个字段，用于表示数据包的长度。接收方首先读取头部，获取数据包长度，然后按照长度读取数据。这是最常用的方法，也比较灵活。

下面是一个使用消息头包含长度信息的示例：

// 服务端 (修改后的 processClient 函数)
func processClient(connection net.Conn) {
    for {
        headerBuffer := make([]byte, 4) // 假设长度信息使用 4 字节
        _, err := connection.Read(headerBuffer)
        if err != nil {
            fmt.Println("Error reading header:", err)
            return
        }

        messageLength := binary.BigEndian.Uint32(headerBuffer) // 将字节转换为 uint32

        messageBuffer := make([]byte, messageLength)
        _, err = connection.Read(messageBuffer)
        if err != nil {
            fmt.Println("Error reading message:", err)
            return
        }

        fmt.Println("Received:", string(messageBuffer))

        // 发送响应
        response := "Message received."
        responseBytes := []byte(response)
        responseLength := uint32(len(responseBytes))

        responseHeader := make([]byte, 4)
        binary.BigEndian.PutUint32(responseHeader, responseLength)

        _, err = connection.Write(responseHeader)
        if err != nil {
            fmt.Println("Error writing response header:", err)
            return
        }

        _, err = connection.Write(responseBytes)
        if err != nil {
            fmt.Println("Error writing response:", err)
            return
        }
    }
}

// 客户端 (修改后的 main 函数)
func main() {
    connection, err := net.Dial(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
    if err != nil {
        fmt.Println("Error dialing:", err.Error())
        os.Exit(1)
    }
    defer connection.Close()

    fmt.Println("Connected to server")

    message := "Hello Server! This is a longer message."
    messageBytes := []byte(message)
    messageLength := uint32(len(messageBytes))

    header := make([]byte, 4)
    binary.BigEndian.PutUint32(header, messageLength) // 将长度转换为字节

    _, err = connection.Write(header)
    if err != nil {
        fmt.Println("Error writing header:", err)
        os.Exit(1)
    }

    _, err = connection.Write(messageBytes)
    if err != nil {
        fmt.Println("Error writing message:", err)
        os.Exit(1)
    }

    // 读取响应
    headerBuffer := make([]byte, 4)
    _, err = connection.Read(headerBuffer)
    if err != nil {
        fmt.Println("Error reading response header:", err)
        os.Exit(1)
    }

    responseLength := binary.BigEndian.Uint32(headerBuffer)
    responseBuffer := make([]byte, responseLength)

    _, err = connection.Read(responseBuffer)
    if err != nil {
        fmt.Println("Error reading response:", err)
        os.Exit(1)
    }

    fmt.Println("Received:", string(responseBuffer))
}

这个示例中，使用了 encoding/binary 包来处理字节序。客户端和服务端都先发送一个 4 字节的头部，表示消息的长度，然后再发送消息内容。

如何处理高并发TCP连接？

在高并发场景下，单个goroutine处理一个连接的方式效率较低。可以使用goroutine池来复用goroutine，或者使用epoll等多路复用技术来提高性能。

Goroutine 池： 预先创建一组goroutine，并将连接分配给这些goroutine处理。这样可以避免频繁创建和销毁goroutine的开销。
多路复用 (epoll, kqueue)： 使用操作系统提供的多路复用机制，可以在单个goroutine中同时监听多个socket连接。Go语言的net包已经封装了这些机制，可以直接使用。

一个简单的goroutine池的实现思路：

package main

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

const (
    SERVER_HOST = "localhost"
    SERVER_PORT = "9988"
    SERVER_TYPE = "tcp"
    POOL_SIZE   = 10 // Goroutine池大小
)

type Job struct {
    Conn net.Conn
}

var jobQueue chan Job

func worker(jobQueue chan Job, wg *sync.WaitGroup) {
    defer wg.Done()

    for job := range jobQueue {
        processConnection(job.Conn)
    }
}

func processConnection(conn net.Conn) {
    defer conn.Close()

    buffer := make([]byte, 1024)
    mLen, err := conn.Read(buffer)
    if err != nil {
        fmt.Println("Error reading:", err.Error())
        return
    }
    fmt.Println("Received: ", string(buffer[:mLen]))
    _, err = conn.Write([]byte("Message received."))
    if err != nil {
        fmt.Println("Error writing:", err.Error())
        return
    }
}

func main() {
    fmt.Println("Server Running...")
    server, err := net.Listen(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
    if err != nil {
        fmt.Println("Error listening:", err.Error())
        os.Exit(1)
    }
    defer server.Close()
    fmt.Println("Listening on " + SERVER_HOST + ":" + SERVER_PORT)
    fmt.Println("Waiting for client...")

    jobQueue = make(chan Job, 100) // 缓冲大小为 100

    var wg sync.WaitGroup

    // 启动 goroutine 池
    for i := 0; i < POOL_SIZE; i++ {
        wg.Add(1)
        go worker(jobQueue, &wg)
    }

    for {
        connection, err := server.Accept()
        if err != nil {
            fmt.Println("Error accept:", err.Error())
            return
        }
        fmt.Println("Client connected")

        jobQueue <- Job{Conn: connection} // 将连接放入 jobQueue
    }

    close(jobQueue) // 关闭 jobQueue
    wg.Wait()        // 等待所有 worker 完成
}

这个例子中，创建了一个固定大小的goroutine池，每个连接都作为一个Job放入jobQueue中，由goroutine池中的worker来处理。

如何进行错误处理和日志记录？

错误处理是TCP编程中非常重要的一部分。需要对各种可能出现的错误进行处理，例如连接错误、读取错误、写入错误等。同时，为了方便调试和排查问题，需要进行日志记录。

错误处理： 使用if err != nil来检查错误，并根据错误类型进行处理。例如，可以关闭连接、记录日志、返回错误信息等。
日志记录： 使用log包或者第三方日志库（如logrus、zap）来记录日志。日志级别可以分为debug、info、warn、error等，根据需要选择合适的日志级别。

package main

import (
    "fmt"
    "log"
    "net"
    "os"
    "time"
)

const (
    SERVER_HOST = "localhost"
    SERVER_PORT = "9988"
    SERVER_TYPE = "tcp"
)

func main() {
    // 初始化日志
    logFile, err := os.OpenFile("server.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
    if err != nil {
        fmt.Println("Error opening log file:", err)
        os.Exit(1)
    }
    defer logFile.Close()
    log.SetOutput(logFile)
    log.SetFlags(log.Ldate | log.Ltime | log.Lshortfile)

    fmt.Println("Server Running...")
    server, err := net.Listen(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
    if err != nil {
        log.Println("Error listening:", err.Error())
        os.Exit(1)
    }
    defer server.Close()
    fmt.Println("Listening on " + SERVER_HOST + ":" + SERVER_PORT)
    fmt.Println("Waiting for client...")
    for {
        connection, err := server.Accept()
        if err != nil {
            log.Println("Error accept:", err.Error())
            continue // 继续监听
        }
        fmt.Println("Client connected")
        go processClient(connection)
    }
}

func processClient(connection net.Conn) {
    defer connection.Close()

    buffer := make([]byte, 1024)
    connection.SetReadDeadline(time.Now().Add(10 * time.Second)) // 设置读取超时
    mLen, err := connection.Read(buffer)
    if err != nil {
        log.Println("Error reading:", err.Error())
        return
    }
    log.Printf("Received: %s from %s\n", string(buffer[:mLen]), connection.RemoteAddr().String())

    _, err = connection.Write([]byte("Message received."))
    if err != nil {
        log.Println("Error writing:", err.Error())
        return
    }
}

这个例子中，使用了log包将日志记录到文件中。同时，使用SetReadDeadline设置了读取超时，防止连接一直阻塞。

如何实现心跳检测？

心跳检测用于检测客户端和服务端之间的连接是否仍然有效。客户端定期向服务端发送心跳包，服务端如果在一定时间内没有收到心跳包，则认为连接已断开。

// 服务端 (修改后的 processClient 函数)
func processClient(connection net.Conn) {
    defer connection.Close()

    for {
        connection.SetReadDeadline(time.Now().Add(30 * time.Second)) // 设置读取超时为 30 秒
        buffer := make([]byte, 1024)
        mLen, err := connection.Read(buffer)
        if err != nil {
            log.Println("Error reading:", err.Error())
            return // 连接超时或发生错误，退出循环
        }

        message := string(buffer[:mLen])
        if message == "heartbeat" {
            log.Println("Received heartbeat from", connection.RemoteAddr())
            // 可以选择发送一个响应，表示收到心跳
            _, err = connection.Write([]byte("heartbeat_ack"))
            if err != nil {
                log.Println("Error writing heartbeat ack:", err.Error())
                return
            }
        } else {
            log.Printf("Received: %s from %s\n", message, connection.RemoteAddr().String())
            _, err = connection.Write([]byte("Message received."))
            if err != nil {
                log.Println("Error writing:", err.Error())
                return
            }
        }
    }
}

// 客户端 (修改后的 main 函数)
func main() {
    connection, err := net.Dial(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
    if err != nil {
        fmt.Println("Error dialing:", err.Error())
        os.Exit(1)
    }
    defer connection.Close()

    fmt.Println("Connected to server")

    // 定期发送心跳
    ticker := time.NewTicker(10 * time.Second) // 每 10 秒发送一次心跳
    defer ticker.Stop()

    for range ticker.C {
        _, err := connection.Write([]byte("heartbeat"))
        if err != nil {
            fmt.Println("Error writing heartbeat:", err.Error())
            return // 连接断开，退出循环
        }
        fmt.Println("Sent heartbeat")

        // 可以选择读取服务器的响应
        buffer := make([]byte, 1024)
        connection.SetReadDeadline(time.Now().Add(5 * time.Second)) // 设置读取超时
        _, err = connection.Read(buffer)

        if err != nil {
            fmt.Println("Error reading heartbeat ack:", err.Error())
            // 可以选择重试或者退出
            continue
        }
        fmt.Println("Received heartbeat ack:", string(buffer))

    }
}

在这个例子中，客户端每10秒发送一次心跳包，服务端如果在30秒内没有收到心跳包，则认为连接已断开。客户端也设置了读取超时，防止一直阻塞。

这些示例代码只是最基本的实现，实际应用中还需要根据具体需求进行修改和完善。例如，可以添加更完善的错误处理、日志记录、数据校验等功能。

本篇关于《GolangTCP数据收发实战详解》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！

错误处理 Goroutine池心跳检测粘包拆包 GolangTCP