扭曲的回调循环阻止接收更多数据

Question

当回调循环在 Twisted 中运行时，我的印象是反应器仍然能够从服务器发送/接收数据，因为它能够在回调“之间”运行。但是，当我运行下面的脚本时，它完全忽略了 self.transport.write() 行。该服务器只是 Twisted 在其网站上的基本回显服务器。

from twisted.internet import reactor, protocol
from twisted.internet.defer import Deferred


class EchoClient(protocol.Protocol):

    deferred = Deferred()

    def connectionMade(self):
        self.deferred.addCallback(self.doThing)
        self.deferred.callback(0)

    def doThing(self, _):
        print 'xxx'
        self.transport.write('Hello, world!')
        self.deferred.addCallback(self.doThing)

    def dataReceived(self, data):
        "As soon as any data is received, write it back."
        print "Server said:", data
        self.transport.loseConnection()


class EchoFactory(protocol.ClientFactory):

    protocol = EchoClient


def main():
    f = EchoFactory()
    reactor.connectTCP('192.168.0.7', 8000, f) # Correctly connected to my server
    reactor.run()

if __name__ == '__main__':
    main()

我预计会打印一个，甚至几个“xxx”，然后服务器会发送“Hello, world!”的回显回到我身边，然后更多的'xxx'。相反，我得到的是“xxx”的无限滚动，甚至没有尝试发送“你好，世界！”到服务器。我错过了什么/误解了什么？

Answer 1

问题是您的示例永远不会让主循环运行。

建立连接后，您向self.deferred 添加回调 - 我不确定self.deferred 应该代表什么操作，但显然没有什么用处。

然后您立即（同步）回拨self.deferred。这会立即执行doThing，它调用self.transport.write。这会在主循环下次运行时将一些字节添加到要发送的传出缓冲区。然后，在该回调中，您立即（同步）向self.deferred 添加另一个回调，该回调将在当前回调完成后立即运行。所以我们进入doThing，它调用self.transport.write。我们还没有写任何东西，更不用说读任何东西来传递给dataReceived，因为我们还没有回到主循环。但是我们向该Deferred 添加了另一个回调。再次调用doThing。

这将永远持续下去，当您缓冲不断增加的传出流量时，会在传输上分配无限量的内存，但绝不允许程序从 connectionMade 返回，使其返回主循环，并且等待可写性和可读性事件。

我不知道如何修复此程序，因为不清楚您要尝试做什么，但无论如何，这不是方法:)。