簡單的扭曲回聲客戶端

Question

我試圖編寫一個簡單的Echo客戶端在扭曲，發送鍵盤輸入到服務器，並由用戶輸入'q'自己終止。總之，我只是想修改在this page上找到的簡單回聲客戶端（和變體）。沒有什麼性感，只是基本。

我很苦惱與非常基本的事件循環。看起來我無法在迴路內啓動/停止反應堆，因爲停止的反應堆不能爲restarted。如果我不停止反應堆，那麼我將永遠不會進入下一行獲得鍵盤輸入。

任何幫助讓我的回聲客戶端工作將不勝感激。

from twisted.internet.protocol import ClientFactory 
from twisted.protocols.basic import LineReceiver 
from twisted.internet import reactor 

class EchoClient(LineReceiver): 
    end="Bye-bye!" 
    def connectionMade(self): 
     #only write and end transmission if the message isn't empty 
     if len(self.factory.message) > 0: 
      self.sendLine(self.factory.message) 
      self.sendLine(self.end) 
     else: 
     #Else just terminate the connection 
      self.transport.loseConnection() 

    def lineReceived(self, line): 
     print "receive:", line 
     if line==self.end: 
      self.transport.loseConnection() 

class EchoClientFactory(ClientFactory): 
    message = "" 

    def buildProtocol(self, address): 
     p = EchoClient() 
     p.factory = self 
     return p 

    def clientConnectionFailed(self, connector, reason): 
     reactor.stop() 

    def clientConnectionLost(self, connector, reason): 
     reactor.stop() 

def main(): 

    s = raw_input('Text to send (''q'' to terminate): ') 
    while s != 'q': 
     factory = EchoClientFactory() 
     factory.message = s 
     reactor.connectTCP('localhost', 8000, factory) 

     #This is bad because reactor cannot be restarted once it's been stopped 
     reactor.run() 

     s = raw_input('Text to send(''q'' to terminate): ') 

if __name__ == '__main__': 
    main() 

Answer 1

作爲一個經驗法則 - 有非常罕見的情況下，您將要重新啓動或停止反應器，除非你是終止程序alltogeather。如果你遇到一段會導致阻塞的代碼數據庫訪問，長時間計算，或者在你的情況下raw_input，你必須：找到一個扭曲的替代（數據庫的情況下twisted.enterprise.adabi）或扭曲兼容。 '解鎖'你的代碼最簡單的方法是通過使用twisted.internet.threads中的deferToThread將阻塞位移入線程。 考慮這個例子：

from twisted.internet.threads import deferToThread as __deferToThread 
from twisted.internet import reactor 

def mmprint(s): 
    print(s) 

class TwistedRAWInput(object): 
    def start(self,callable,terminator): 
     self.callable=callable 
     self.terminator=terminator 
     self.startReceiving() 
    def startReceiving(self,s=''): 
     if s!=self.terminator: 
      self.callable(s) 
      __deferToThread(raw_input,':').addCallback(self.startReceiving) 


tri = TwistedRAWInput() 
reactor.callWhenRunning(tri.start,mmprint,'q') 
reactor.run() 

你就永遠不會停止反應器，如將的raw_input的外螺紋發生，在每一個新行callbacking推遲。