扭曲的传输.write

Question

有没有办法强制 self.transport.write(response) 立即写入其连接，以便下一次调用 self.transport.write(response) 不会缓冲到同一个调用中。

我们有一个客户，其遗留软件无法修改，它读取第一个请求，然后再次开始读取，我遇到的问题是扭曲地将两个写入连接在一起，这打破了客户我尝试过延迟的任何想法，但我不知道我认为在这种情况下不会有帮助

示例：

self.transport.write("|123|") # amount of messages to follow 
a loop to generate next message
self.transport.write("|message 1 text here|")

预期：

|123|
|message 1 text here|

结果：

|123||message 1 text here|

Answer 1

也许您可以将协议注册为传输的拉生产者

self.transport.registerProducer(self, False)

，然后在协议中创建一个具有作业缓冲的写入方法
数据，直到传输调用协议的resumeProducing方法来获取
数据一一列出。

def write(self, data):
    self._buffers.append(data)

def resumeProducing(self):
    data = self._buffers.pop()
    self.transport.write(data)

Answer 2

您能告诉我您使用的是哪种交通工具吗？对于大多数实现来说，
这是典型的方法：

 def write(self, data):
        if data:
            if self.writeInProgress:
                self.outQueue.append(data)
            else:
                ....

根据详细信息，可以更改写入函数的行为以根据需要进行操作。

Answer 3

我在使用低级 Python 2.6 时遇到了一些相关的问题。与我交谈的主机期待一个 ACK​​ 字符，然后是一个单独的数据缓冲区，它们全部同时出现。在上面
其中，这是一个 TLS 连接。但是，如果您直接引用套接字，则可以调用
sendall() as:

self.transport.write(Global.ACK)

to:

self.transport.getHandle().sendall(Global.ACK)

... 这应该有效。这在 X86 上使用 Twisted 的 Python 2.7 上似乎不是问题，只是
SHEEVAPlug ARM 处理器上的 Python 2.6。