Führen Sie etwas, wenn der erste Client in twisted verbindet?

Question

So habe ich einen Hauptserver in verdrehten geschrieben. Ich möchte einen Backup-Server auf einem anderen Port ausführen, wenn der erste Client eine Verbindung herstellt. Dieses Verhalten sollte nicht wiederholt werden, wenn der zweite Client eine Verbindung herstellt. Der Sicherungsserver sollte auch geschlossen werden, wenn der letzte Client die Verbindung trennt.
Wie kann ich dieses Verhalten implementieren? Momentan führe ich eine Batch-Datei aus, bevor der Reaktor startet. Aber das Problem ist, dass dies eine unendliche Schleife erzeugen würde. Aber ich gebe ein Argument, das es stoppen kann. Dies bedeutet jedoch, dass, wenn der Hauptserver ausfällt und der Backup-Server Clients annimmt, Backup-Server übrig sind.

Answer 1

Sie müssen die connectionMade und connectionLost Ereignisse des Twisted-Protokoll anschließen. In diesen können Sie Ihre Geschäftslogik implementieren.

Schauen Sie folgende Ereignisse auf:

from twisted.internet.protocol import Factory 
from twisted.protocols.basic import LineReceiver 
from twisted.internet import reactor 


class Protocol(LineReceiver): 

    def __init__(self, factory): 
     self.factory = factory 

    def connectionMade(self): 
     self.factory.clients.add(self) 
     print('Client added. count:', len(self.factory.clients)) 

    def connectionLost(self, reason): 
     self.factory.clients.remove(self) 
     print('Client removed. count:', len(self.factory.clients)) 

    def lineReceived(self, line): 
     self.transport.write(line) 


class MyFactory(Factory): 

    def __init__(self): 
     self.clients = set() 

    def buildProtocol(self, addr): 
     return Protocol(self) 


reactor.listenTCP(1520, MyFactory()) 
reactor.run() 

Sie diesen Server mit Telnet testen:

telnet 127.0.0.1 1520