python - 如何使用Twisted中收到的数据？

Question

我已经用Twisted实现了一个服务器程序。我使用basic.lineReceiver和dataReceived方法从多个客户机接收数据。另外，我使用protocol.ServerFactory来跟踪连接的客户端。服务器向每个连接的客户端发送一些命令。基于服务器从每个客户端得到的响应，它（服务器）应该执行一些任务。因此，我想到的最佳解决方案是为接收到的消息创建一个缓冲区作为python列表，每当服务器端的函数想知道来自客户端的响应时，它们都会访问缓冲区列表（该客户端）的最后一个元素。
事实证明，这种方法是不可靠的。第一个问题是，由于使用了TCP流，有时消息会合并（我可以为此使用分隔符）。其次，接收到的消息有时不在其适当的序列中。第三，网络通信似乎太慢，因为当服务器最初试图访问缓冲列表的最后一个元素时，列表是空的（这表明缓冲区上的最后一条消息可能不是对最后发送的命令的响应）。
您能告诉我在上述问题中使用dataReceived或其等价物的最佳包裹是什么吗？提前谢谢你。
编辑1：回答-虽然我接受@Jean Paul Calderone的回答，因为我确实从中学到了这一点，但我想补充一下，在我自己对Twisted文档的研究中，我了解到为了避免服务器通信的延迟，应该在dataReceived（）或lineReceived（）函数的末尾使用return，这解决了我的部分问题。其余的，都在回答中解释过了。

Answer 1

我已经用Twisted实现了一个服务器程序。我使用basic.lineReceiver和dataReceived方法从多个客户端接收数据。
这是一个错误——不幸的是，在Twisted的许多协议实现中，由于错误地使用继承作为构建越来越复杂的行为的机制而导致的一个常见错误。当您使用twisted.protocols.basic.LineReceiver时，dataReceived回调不适合您。LineReceiver.dataReceived是LineReceiver的实现细节。您的回拨是LineReceiver.lineReceived。LineReceiver.dataReceived看起来它可能适合您—它不是以下划线或任何内容开头—但它不是。dataReceived是如何从其传输接收信息的。它是LineReceiver的公共方法之一，即传输和协议之间的接口，用于解释通过该传输接收的数据。是的，我刚才说了“公共方法”。问题是它是为了别人的利益而公开的。这是令人困惑的，也许没有沟通好，因为它可以。毫无疑问，这就是为什么它是一个Frequently Asked Question。
事实证明，这种方法是不可靠的。第一个问题是，由于使用了TCP流，有时消息会合并（我可以为此使用分隔符）。
使用IProtocol就是发生这种情况的原因。dataReceived已经为您实现了基于分隔符的解析。这就是为什么它被称为“行”接收器-它接收由分隔符分隔的行。如果覆盖LineReceiver而不是lineReceived，则将调用接收到的每一行，而不管TCP如何拆分或粉碎它们。
其次，接收到的消息有时不在其适当的序列中。
TCP是一种可靠的、有序的、面向流的传输。”“有序”意味着字节的到达顺序与它们的发送顺序相同。换言之，当您dataReceived时，可以保证接收者在收到“y”之前收到“x”（他们可能在对write("x"); write("y")的同一个调用中收到“x”和“y”），但是如果他们收到了，数据肯定是“xy”而不是“yx”；或者他们可能在对recv()的两个调用中收到两个字节，如果他们收到了，第一个recv()肯定是“x”，第二个肯定是“y”，而不是相反的方向）。
如果字节的到达顺序与您发送的顺序不同，则可能有另一个错误使其看起来像正在发生，但实际上并非如此。您的平台的TCP堆栈很可能非常接近无错误，特别是它可能没有TCP数据重新排序错误。同样，这个扭曲的区域也经过了很好的测试，可能工作正常。这会在应用程序代码中留下一个错误，或是对观察结果的误解。也许您的代码并不总是将数据追加到列表中，或者数据没有按您期望的顺序发送。
另一种可能性是，您正在讨论数据通过多个单独的TCP连接到达的顺序。TCP仅通过单个连接进行排序。如果您有两个连接，那么很少（如果有的话）可以保证数据到达它们的顺序。
第三，网络通信似乎太慢，因为当服务器最初试图访问缓冲列表的最后一个元素时，列表是空的（这表明缓冲区上的最后一条消息可能不是对最后发送的命令的响应）。
什么定义“太慢”？网络和网络一样快。如果这对你来说不够快，找一块更胖的铜。听起来你真正的意思是，你的服务器有时希望数据在实际到达之前到达。这并不意味着网络太慢，但是，这意味着服务器没有正确的事件驱动。如果您正在检查缓冲区，但没有找到预期的信息，那是因为您在事件发生之前检查了缓冲区，该事件通知您该信息的到达。这就是为什么Twisted有所有这些回调方法-recv()，dataReceived，lineReceived等。当调用connectionLost时，这是一个事件通知，告诉您现在发生了一些事情，导致一行可用（为了方便，lineReceived接受一个参数-一个表示当前可用行的对象）。
如果有一些代码要在行到达时运行，请考虑将该代码放入lineReceived方法的实现中。这样，当它运行（响应接收到的行）时，您可以100%确定您有一个要操作的行。你也可以确信它会尽快运行（一旦线路到达），但不会很快。