使用原始 tcp 时确保传递整个消息的好方法是什么？

Question

假设我有一个在后端的应用程序，我想使用原始 tcp 以便我可以在不同的服务之间进行双向通信。在这个应用程序中，我想发送一个由 json 对象组成的有效负载，当发送 json 数据时，每隔几条消息，它就会被截断，其余的将聚集到下一个响应中。由于用于从 http 升级的时间，我不想使用诸如 websockets 之类的东西。什么是确保该 json 对象将从一个节点作为整个json 对象从另一个节点读取的好（并且希望是最好的）方法？

我知道发送和接收设置大小的缓冲区和用于 heartbeet 的消息是经验法则，但我可以看一个例子吗？最好使用 Javascript（节点的 net stdlib）或 Golang（它是 net stdlib），因为这些是我最精通的语言，尽管我并不真正关心它最终是用什么语言完成的。

（我知道有一些问题在询问有关确保使用 tcp 传递消息的类似问题，但没有人要求提供我发现的示例）

我知道 tcp 是一个流。我只是要求一种方法来确保在将特定的 json 对象写入此流时，如何确保在另一端获得相同的 json 对象，如“从节点 a 发送 json 对象 X，好的节点 b”收到同一个对象X"

Answer 1

您不需要心跳或固定大小的消息来确认交付。如果您需要确保交付，则需要应用程序级别的确认。如果您需要确保传递正确的消息，则需要包含一个唯一的消息 ID 以进行确认。如果您需要确保消息未更改，则需要包含校验和或 MAC。在这里，您似乎在消息框架方面遇到了问题。虽然有很多方法来构建您的消息（简单的长度前缀、类型长度值、HTTP/1.1 等），但一个简单的解决方案是使用内置的json.Encoder和json.Decoder。示例客户端，每秒发送一条“PING”消息：type Message struct {    Payload string}func sendMessages(c net.Conn) {    message := Message{}    encoder := json.NewEncoder(c)    for i := 0; ; i++ {        message.Payload = fmt.Sprintf("PING %d", i)        err := encoder.Encode(message)        if err != nil {            log.Fatal(err)        }        time.Sleep(time.Second)    }}示例服务器：type Message struct {    Payload string}func receiveMessages(c net.Conn) {    m := Message{}    decoder := json.NewDecoder(c)    for {        err := decoder.Decode(&m)        if err != nil {            log.Fatal(err)        }        fmt.Printf("Received: %#v\n", m)    }}