Потерянное клиентское соединение Python потеряно - PullRequest
Новая
       22

Потерянное клиентское соединение Python потеряно

4 голосов
/ 25 декабря 2010

У меня есть этот витой клиент, который соединяется с витым сервером, имеющим индекс. Я запустил этот клиент из командной строки. Работало нормально. Теперь я изменил его для запуска в цикле (см. main()), чтобы я мог продолжать запросы. Но клиент запускается только один раз. В следующий раз он просто говорит connection lost \n Connection lost - goodbye!.

Что я делаю не так? В цикле я переподключаюсь к серверу, это что неправильно? 

from twisted.internet import reactor
from twisted.internet import protocol

from settings import AS_SERVER_HOST, AS_SERVER_PORT

# a client protocol
class Spell_client(protocol.Protocol):
    """Once connected, send a message, then print the result."""

    def connectionMade(self):
        self.transport.write(self.factory.query)

    def dataReceived(self, data):
        "As soon as any data is received, write it back."
        if data == '!':
            self.factory.results = ''
        else:
            self.factory.results = data
        self.transport.loseConnection()

    def connectionLost(self, reason):
        print "\tconnection lost"

class Spell_Factory(protocol.ClientFactory):
    protocol = Spell_client

    def __init__(self, query):
        self.query   = query
        self.results = ''

    def clientConnectionFailed(self, connector, reason):
        print "\tConnection failed - goodbye!"
        reactor.stop()

    def clientConnectionLost(self, connector, reason):
        print "\tConnection lost - goodbye!"
        reactor.stop()

# this connects the protocol to a server runing on port 8090
def main(): 
    print 'Connecting to %s:%d' % (AS_SERVER_HOST, AS_SERVER_PORT)
    while True:
        print
        query = raw_input("Query:")
        if query == '': return
        f = Spell_Factory(query) 
        reactor.connectTCP(AS_SERVER_HOST, AS_SERVER_PORT, f)
        reactor.run()
        print f.results
    return

if __name__ == '__main__':
    main()

1 Ответ

3 голосов
/ 25 декабря 2010

Вы не совсем понимаете, как работает витой реактор.

reactor.run() запускает цикл событий реактора - это блокирующий вызов, который повторяет цикл "навсегда".

См. http://twistedmatrix.com/documents/10.2.0/core/howto/reactor-basics.html для различных тем, связанных с реактором.

...