Golang中的TCP固定大小报文成帧方法

Question

我不能理解如何使用固定大小的前缀长度头的消息帧工作。

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

Hello

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

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字节的头。

这对所有的案子都管用吗？

golang prettyprint-override">    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
        }
    }
}

Answer 1

请参考我在这篇文章中的回答TCP客户端for Android：文本未完整接收

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

>

我们将前缀长度存储为int32(4个字节），并使用少量的endian。和你的不一样。

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