Eine Funktion regelmäßig im verdrehten Protokoll ausführen

Question

Ich bin auf der Suche nach einer Möglichkeit, einige Daten regelmäßig über alle Clients an einen TCP-Port zu senden. Ich schaue auf twisted python und ich kenne reactor.callLater. Aber wie verwende ich es, um regelmäßig Daten an alle angeschlossenen Clients zu senden? Die Datensende-Logik befindet sich in der Protokollklasse und wird vom Reaktor nach Bedarf instanziiert. Ich weiß nicht, wie man es vom Reaktor zu allen Protokollinstanzen bindet ...

Answer 1

Sie würden dies wahrscheinlich in der Factory für die Verbindungen tun. Die Factory wird nicht automatisch jedes Mal benachrichtigt, wenn eine Verbindung hergestellt oder verloren wird, sodass Sie sie über das Protokoll benachrichtigen können.

Hier ist ein vollständiges Beispiel für die Verwendung von twisted.internet.task.LoopingCall in Verbindung mit einer angepassten Standard-Factory und einem Protokoll, um zu melden, dass alle 10 Sekunden alle 10 Sekunden alle 10 Sekunden vergangen sind.

from twisted.internet import reactor, protocol, task 

class MyProtocol(protocol.Protocol): 
    def connectionMade(self): 
     self.factory.clientConnectionMade(self) 
    def connectionLost(self, reason): 
     self.factory.clientConnectionLost(self) 

class MyFactory(protocol.Factory): 
    protocol = MyProtocol 
    def __init__(self): 
     self.clients = [] 
     self.lc = task.LoopingCall(self.announce) 
     self.lc.start(10) 

    def announce(self): 
     for client in self.clients: 
      client.transport.write("10 seconds has passed\n") 

    def clientConnectionMade(self, client): 
     self.clients.append(client) 

    def clientConnectionLost(self, client): 
     self.clients.remove(client) 

myfactory = MyFactory() 
reactor.listenTCP(9000, myfactory) 
reactor.run() 

Answer 2

Ich könnte mir vorstellen, dass der einfachste Weg das zu tun ist, eine Liste von Clients im Protokoll mit connectionMade und connectionLost im Client und zu verwalten Verwenden Sie dann einen LoopingCall, um jeden Client zum Senden von Daten aufzufordern.

Das fühlt sich ein wenig invasiv an, aber ich denke nicht, dass Sie es tun möchten, ohne dass das Protokoll eine gewisse Kontrolle über die Übertragung/den Empfang hat. Natürlich müsste ich deinen Code sehen, um wirklich zu wissen, wie er gut passt. Hast du einen GitHub Link? :)