Простой клиент Twisted Echo

Question

Я пытаюсь написать простой клиент Echo в Twisted, который отправляет ввод с клавиатуры на сервер и прерывается тем, что пользователь сам вводит 'q'. Короче говоря, я просто пытаюсь изменить простой эхо-клиент (и варианты), найденные на этой странице. Ничего сексуального, только основы.

Я борюсь с очень простым циклом событий. Похоже, я не могу запустить / остановить реактор внутри контура, так как остановленный реактор не может быть перезапущен. Если я не остановлю реактор, я никогда не перейду к следующей строке, которая получает ввод с клавиатуры.

Любая помощь в получении моего эхо-клиента будет высоко ценится.

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

Как правило, есть очень редкие случаи, когда вы хотели бы перезапустить или остановить реактор, если вы не завершаете свою программу полностью вместе. Если вы столкнетесь с фрагментом кода, который вызовет блокировку, например, доступ к базе данных, длительные вычисления или, в вашем случае, raw_input, вы должны либо: найти витую альтернативу (twisted.enterprise.adabi в случае базы данных), либо сделать ее совместимой с витой. Самый простой способ "разблокировать" ваш код - переместить блокирующие биты в поток, используя deferToThread из twisted.internet.threads. Рассмотрим этот пример:

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 будет происходить во внешнем потоке, обратный вызов откладывается на каждой новой строке.