当前位置：首页 > 文章列表 > Golang > Go问答 > Golang：TCP 客户端/服务器数据分隔符

Golang：TCP 客户端/服务器数据分隔符

来源：Golang技术栈 2023-04-30 12:16:43 0浏览收藏

Golang不知道大家是否熟悉？今天我将给大家介绍《Golang：TCP 客户端/服务器数据分隔符》，这篇文章主要会讲到golang等等知识点，如果你在看完本篇文章后，有更好的建议或者发现哪里有问题，希望大家都能积极评论指出，谢谢！希望我们能一起加油进步！

问题内容

不知道如何制定这个问题，如果它真的只与 Go 语言有关，但我想做的是有一个 tcp 服务器和客户端在它们之间交换数据，基本上客户端会将大量数据流式传输到更小的块到服务器，服务器将等待读取每个数据块，然后回复一个状态码，客户端将读取该状态码并基于该状态码执行其他工作。

我使用下面的函数作为 ** 测试** 从客户端和服务器读取数据（请注意，我知道这并不完美，但它只是测试）：

func createBufferFromConn(conn net.Conn) *bytes.Buffer {
    buffer := &bytes.Buffer{}
    doBreak := false
    for {
        incoming := make([]byte, BUFFER_SIZE)

        conn.SetReadDeadline(time.Now().Add(time.Second * 2))
        bytesRead, err := conn.Read(incoming)
        conn.SetReadDeadline(time.Time{})

        if err != nil {
            if err == io.EOF {
                fmt.Println(err)
            } else if neterr, ok := err.(net.Error); ok && neterr.Timeout() {
                fmt.Println(err)
            }
            doBreak = true
        }

        if doBreak == false && bytesRead == 0 {
            continue
        }

        if bytesRead > 0 {
            buffer.Write(incoming[:bytesRead])
            if bytes.HasSuffix(buffer.Bytes(), []byte("|")) {
                bb := bytes.Trim(buffer.Bytes(), "|")
                buffer.Reset()
                buffer.Write(bb)
                doBreak = true
            }
        }

        if doBreak {
            break
        }
    }
    return buffer
}

现在在我的情况下，如果我通过 telnet 连接（go 代码还包括连接client()到Trim() 调用）。 server()``test 12345|

如果我if bytes.HasSuffix(buffer.Bytes(), []byte("|")) {从代码中删除该块，那么我将在 2 秒后再次超时，正如预期的那样，因为在这段时间内没有收到任何数据并且服务器关闭连接，并且如果我没有设置读取截止日期连接，它将永远等待读取数据，并且永远不知道何时停止。

我想我的问题是，如果我发送多个数据块，我是否必须指定自己的分隔符，以便我知道何时停止读取连接并避免永远等待或等待服务器超时连接？