Twisted-我需要定期连接/断开客户端连接

Question

我有一个扭曲的tcp客户端，我想定期让它连接，接收n秒的数据流，然后断开连接。断开连接后，经过n秒后，该过程才会重新开始。

下面是我迄今为止尝试过的代码的一个非常简短的摘录。当我运行代码时，会发出reactor.stop（），在睡眠结束后，当在startClientConnection（）中调用reactor.run（）时，我会收到一个扭曲的.internet错误"ReactorAlreadyRunning"

我是一个使用twisted的新手，我不确定自己做错了什么。任何帮助都将不胜感激。

class TCPClientFactory(ReconnectingClientFactory)
   def startedConnecting(self, connector):
       pass
   def buildProtocol(self, addr):
       self.resetDelay()
       return MsgProcessor()
   def clientConnectionLost(self, connector, reason):
       ReconnectingClientFactory.clientConnectionLost(self, connector, reason)
   def clientConnectionFailed(self, connector, reason):
       ReconnectingClientFactory.clientConnectionFailed(self, connector, reason)        

class mainClass(object):
    def __init__(self):
        ...
    def startClientConnection(self):
        reactor.connectTCP(host, port, TCPClientFactory())
        reactor.callLater(60, self.periodic_connect_manager)
        reactor.run()
    def periodic_connect_manager(self):
        reactor.stop()
        time.sleep(60)
        self.startClientConnection()

Answer 1

reactor.run()应该只运行一次。

from twisted.internet import task, reactor
def connect():
    do_connect()
    reactor.callLater(60, disconnect) # disconnect in a minute
task.LoopingCall(connect).start(120) # call connect() every 2 minutes
reactor.run()