キーボード入力をサーバーに送信し、ユーザーが独自に「q」を入力することで終了する、Twisted で単純な Echo クライアントを作成しようとしています。要するに、このページにある単純なエコー クライアント (およびその亜種) を変更しようとしているだけです。まったくセクシーではなく、基本だけです。
非常に基本的なイベントループに苦労しています。停止したリアクターは再起動できないため、ループ内でリアクターを開始/停止できないようです。リアクターを停止しなければ、キーボード入力を取得する次の行にたどり着くことはありません。
私のエコークライアントを機能させるための助けをいただければ幸いです。
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()