首页 > 后端开发 > Golang > 正文

GolangTCP数据包发送与接收示例

P粉602998670
发布: 2025-09-18 10:40:02
原创
209人浏览过
答案:通过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是面向流的协议,这意味着数据在传输过程中可能会发生粘包和拆包。简单来说,粘包就是多个小数据包被合并成一个大数据包发送,而拆包就是一个大数据包被拆分成多个小数据包发送。

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

  1. 固定长度消息: 每个数据包都使用固定长度,接收方按照固定长度读取数据。这实现简单,但不够灵活,浪费带宽。

    立即学习go语言免费学习笔记(深入)”;

  2. 使用分隔符: 在每个数据包的末尾添加一个特殊的分隔符,接收方通过查找分隔符来分割数据包。例如,使用换行符

    \n
    登录后复制
    作为分隔符。

  3. 消息头包含长度信息: 在每个数据包的头部添加一个字段,用于表示数据包的长度。接收方首先读取头部,获取数据包长度,然后按照长度读取数据。这是最常用的方法,也比较灵活。

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

// 服务端 (修改后的 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等多路复用技术来提高性能。

  1. Goroutine 池: 预先创建一组goroutine,并将连接分配给这些goroutine处理。这样可以避免频繁创建和销毁goroutine的开销。

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

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

    android rtsp流媒体播放介绍 中文WORD版 0
    查看详情 android rtsp流媒体播放介绍 中文WORD版
  2. 多路复用 (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编程中非常重要的一部分。需要对各种可能出现的错误进行处理,例如连接错误、读取错误、写入错误等。同时,为了方便调试和排查问题,需要进行日志记录。

  1. 错误处理: 使用

    if err != nil
    登录后复制
    来检查错误,并根据错误类型进行处理。例如,可以关闭连接、记录日志、返回错误信息等。

  2. 日志记录: 使用

    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数据包发送与接收示例的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号