使用socket编程接收消息时的问题

Question

首先，很抱歉我无法给您举一个最小的例子。代码开始变得非常复杂，我认为我无法再编写代码了。

但如果我简单地告诉你我在做什么，这段代码允许我通过套接字编程在我编写的应用程序和另一个外部应用程序之间进行通信。

我向该外部程序发送一个文件路径，并将该路径添加到其自己的设置中。

奇怪的是，如果我第一次发送消息（即文件路径），就没有问题。但是当我第二次发送它时，外部应用程序没有收到消息（并且我没有收到任何错误）。此时事情开始变得更加奇怪，因为如果我第三次发送消息，这次它会将我第二次发送的消息/文件路径获取到它自己的设置。
案例：

sent message: A
message received: A

sent message: B
message received: (message not received)

sent message: B
message received: B

sent message : C
message received: (message not received)

sent message: C
message received: (message not received)

sent message: C
message received: C

.
.
.

("message not received" keeps increasing)

我使用的功能：

def send_message(socket: QTcpSocket, message: str = "", message_type: str = "message"):
    socket_stream = QDataStream(socket)
    socket_stream.setVersion(QDataStream.Qt_5_10)

    header_array = QByteArray()
    message_size = len(message.encode("utf-8"))
    header = f"messageType:{message_type},messageSize:{message_size},"
    header_array.prepend(header.encode("utf-8"))
    header_array.resize(128)

    byte_array = QByteArray(message.encode("utf-8"))
    byte_array.prepend(header_array)

    socket_stream << byte_array
    socket_stream.writeString(message)

def read_socket(self):
    buffer = QByteArray()

    socket_stream = QDataStream(self.socket)
    socket_stream.setVersion(QDataStream.Qt_5_10)

    socket_stream.startTransaction()
    socket_stream >> buffer

    header = buffer.mid(0, 128)
    ...
    message = socket_stream.readString()

什么样的情况会导致这个问题？

Answer 1

您必须记住 TCP 不是数据包协议——它是流协议。您将不会收到与发送时形状完全相同的数据包。如果您快速发送 40 字节和 80 字节，另一端可能会获得 120 字节的单次读取。或者，它可能会获取 20 个字节，然后是 60 个字节，然后是 40 个字节。没有任何保证。您必须能够在一次读取中处理多条消息，并且必须有一种方法来检测消息何时完成。