当前位置：首页 > 文章列表 > Golang > Go问答 > 在Golang中实现TCP固定大小报文分帧的方法

在Golang中实现TCP固定大小报文分帧的方法

来源：stackoverflow 2024-02-24 12:57:25 0浏览收藏

在IT行业这个发展更新速度很快的行业，只有不停止的学习，才不会被行业所淘汰。如果你是Golang学习者，那么本文《在Golang中实现TCP固定大小报文分帧的方法》就很适合你！本篇内容主要包括##content_title##，希望对大家的知识积累有所帮助，助力实战开发！

问题内容

我无法理解使用固定大小前缀长度标头的消息帧是如何工作的。

据说固定大小的字节数组将包含要发送的消息的长度。但是如何定义固定大小的字节数组，特别是在 golang 中。

说这是我的消息：

hello

它的长度是5。

因此，如果我想通过 tcp 流发送此消息，为了确保在另一端收到所有消息，我必须告诉它应该读取多少字节。

一个简单的标头是 length:message:

5:hello // [53 58 104 101 108 108 111]

但是如果消息长度每次增长 10 倍，就会有更多的字节。因此标头大小是动态的。

36:hello, this is just a dumb question. // [51 54 58 72 101 108 108 111 44 32 116 104 105 115 32 105 115 32 106 117 115 116 32 97 32 100 117 109 98 32 113 117 101 115 116 105 111 110 46]

所以这里 36 占用 2 个字节。

我想到的一种方法是考虑协议的最大消息长度。假设 10kb = 10240 字节。然后将前导 0 添加到消息长度中。这样我就可以确定我将拥有一个固定的 5 字节标头。

这适用于所有情况吗？

如果是，如果我的消息超过 10kb，我应该将其分成 2 条消息吗？

如果没有，还有什么其他解决方案？

我想在 golang 中实现这些解决方案。

更新1：

我读到了有关 endian 的内容，尽管我无法理解它们是如何导致固定长度字节的。但我在python中找到了一个例子，并尝试用go这样写：

客户：

    const maxlengthbytes = 8
    conn, err := net.dial("tcp", "127.0.0.1:9999")
    if err != nil {
        fmt.println(err)
        return
    }
    message := "hello, this is just a dumb question"
    bs := make([]byte, maxlengthbytes)
    binary.littleendian.putuint64(bs, uint64(len(text)))
    bytes := append(bs, []byte(text)...)
    conn.write(bytes)

服务器：

    listener, err := net.ListenTCP("tcp", &net.TCPAddr{Port: 9999})
    if err != nil {
        fmt.Println(err)
        return
    }
    for {
        tcp, err := listener.AcceptTCP()
        if err != nil {
            fmt.Println(err)
            continue
        }
        go Reader(tcp)
    }

func Reader(conn *net.TCPConn) {
    foundLength := false
    messageLength := 0
    for {
        if !foundLength {
            var b = make([]byte, maxLengthBytes)
            read, err := conn.Read(b)
            if err != nil {
                fmt.Println(err)
                continue
            }
            if read != 8 {
                fmt.Println("invalid header")
                continue
            }
            foundLength = true
            messageLength = int(binary.LittleEndian.Uint64(b))
        } else {
            var message = make([]byte, messageLength)
            read, err := conn.Read(message)
            if err != nil {
                fmt.Println(err)
                continue
            }
            if read != messageLength {
                fmt.Println("invalid data")
                continue
            }
            fmt.Println("Received:", string(message))
            foundLength = false
            messageLength = 0
        }
    }
}