如何刷新 Python 套接字？

Question

我用Python编写了一个服务器，旨在以“标题：消息”的形式将数据发送到客户端，

我希望能够单独发送每条消息，以便客户端只需执行最少的工作即可读取“标头”和“消息”

不幸的是，我不知道如何正确刷新Python套接字，因此当我快速连续执行多个发送时，消息会集中在套接字缓冲区中并作为一个大块发送。

示例：

服务器发送...

socket.send ("header1:message1")
socket.send ("header2:message2")
socket.send ("header3:message3")

客户端接收... “header1:message1header2:message2header3:message3”

我想收到三条单独的消息，

header1:message1
header2:message2
header3:message3

我需要一种在每次发送后刷新的方法

Answer 1

我猜你正在通过 TCP 连接进行交谈。

你的方法有缺陷。 TCP 流被定义为字节流。您始终必须使用某种分隔符，并且可能不依赖网络堆栈来分隔消息。

如果您确实需要基于数据报的服务，请切换到 UDP。在这种情况下，您需要自己处理重传。

澄清一下：

正如您所期望的那样，刷新发送缓冲区通常会创建新的包。如果您的客户端足够快地读取这些包，您每次读取可能会收到一条消息。

现在想象一下您通过卫星链路进行通信。由于高带宽和延迟，卫星之前的最后一个路由器会等待很短的时间，直到缓冲区中有足够的数据并立即发送所有数据包。您的客户端现在将立即接收所有数据包，并将所有数据立即放入接收缓冲区中。于是你们的分离又消失了。

Answer 2

您想要做的是将数据分成“批次”。

例如，每当您从文件中读取“行”时，您都是在“批量”操作。 “线”的定义是什么？它是一个以“\n”结尾的字节序列。另一个例子是：您从文件中读取了 64KiB“块”。什么定义了“块”？确实如此，因为每次读取 65536 字节。你想要一个可变长度的“块”吗？您只需在“块”前面加上其大小，然后读取“块”即可。 “aiff”文件（其实现也是 MS Windows 的 .wav 和 .avi 文件）和“mov”文件的组织方式类似。

这三种方法是组织字节流的最基本方法，无论使用何种介质：

1. 记录分隔符
2. 固定大小记录
3. 以其大小为前缀的记录。

它们可以混合和/或修改。例如，您可以拥有“变量记录分隔符”，如 XML 读取器：从第一个 '<' 读取字节直到第一个“>”，在第一个“<”后添加斜杠并将其称为记录结束，读取流直到记录结束。这只是一个粗略的描述。

选择一种方法，并在编写器和读取器中实现它。如果您还记录了您的选择，则您刚刚定义了第一个协议。

Answer 3

我在“刷新”UDP 套接字的缓冲区时遇到了同样的问题，这是我的解决方案：

def empty(sock):
    """Empty the UDP buffer."""
    sock.setblocking(0)
    while True:
        try:
            sock.recv(1024)
        except BlockingIOError:
            sock.setblocking(1)
            return

Answer 4

只需在每条消息后附加 \n ...
喜欢

socket.send ("header1:message1\n")
socket.send ("header2:message2\n")
socket.send ("header3:message3\n")