Twisted：減慢數據接收

Question

假設我通過TCP連接以快速接收數據。我必須對它做一些處理。由於我不想阻塞反應器線程，我將處理卸載到後臺線程。

數據到達比我能處理它快。如果我將數據放入隊列中，則隊列無限增長。

有沒有辦法告訴twisted來暫停接收數據？

TCP協議可以強制發件人放慢速度。如果我要處理反應器線程（這不是一個選項，因爲還有其他更好的TCP連接），會發生什麼情況。

Answer 1

如果要實現的Protocol一個子類，你transport屬性可能是一個IPushProducer，這意味着你只需要調用self.transport.pauseProducing()然後self.transport.resumeProducing()只要你想它再次開始給你的數據。如果您只想限制費率，可以在短暫延遲後使用reactor.callLater()撥打resumeProducing()。