シンプルなツイストエコークライアント

Question

私はツイストで簡単なエコークライアントを書こうとしています。これはキーボード入力をサーバに送信し、ユーザーが '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、外部のスレッドで起こるとあなたは、原子炉を停止する必要がないだろう。