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

在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
        }
    }
}

解决方案

请参考我这篇文章的回答 TCP client for Android: text is not received in full

基本上，您必须定义数据的存储/格式化方式。 例如：

1. 我们将前缀长度存储为 int32 （4 字节），采用小端字节序。这和你的不一样。

2. 根据您的解决方案，长度是 string，很难固定长度。 对于您的解决方案，您必须使用固定长度的字符串。例如：10个字符，并添加前导零。

回答您的问题。

1. 它并不适用于只有前缀长度的所有情况。它有它的局限性，例如如果我们使用int32作为前缀长度，那么消息的长度必须小于Integer32.max，对吧？

2. 是的，我们必须拆分甚至合并（请参阅上面链接中我的解释）。

3. 如果我们关心长度限制，我们有很多方法来处理它（实际上，几乎应用程序协议都有最大请求大小）。 您可以再使用一位来指示消息是否超过最大长度来解决它，对吗？

本篇关于《在Golang中实现TCP固定大小报文分帧的方法》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！