꼬인 프로토콜로 함수를 주기적으로 실행하기

Question

TCP 포트에 연결된 모든 클라이언트를 통해 주기적으로 데이터를 보내는 방법을 찾고 있습니다. 나는 꼬인 파이썬을보고 있는데 reactor.callLater를 알고있다. 하지만 어떻게하면 모든 연결된 클라이언트에게 데이터를 주기적으로 보낼 수 있습니까? 데이터 전송 로직은 프로토콜 클래스에 있으며 필요에 따라 반응기에 의해 인스턴스화됩니다. 원자로에서 모든 프로토콜 인스턴스로 묶는 방법을 모르겠다. ...

Answer 1

아마 당신은 공장에서 연결을 원할 것입니다. 팩토리는 연결이 끊어 지거나 끊어 질 때마다 자동으로 통보되지 않으므로 프로토콜에서 통보 할 수 있습니다.

twisted.internet.task.LoopingCall을 사용자 지정 기본 팩토리 및 프로토콜과 함께 사용하여 10 초마다 모든 연결에 '10 초가 경과 한 '것을 알리는 방법의 전체 예제입니다.

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

가장 쉬운 방법은 클라이언트의 connectionMade 및 connectionLost를 사용하여 프로토콜에서 클라이언트 목록을 관리하는 것입니다. LoopingCall을 사용하여 각 클라이언트에게 데이터를 보내도록 요청하십시오.

약간 침해가 느껴지지만 전송/수신에 대한 일부 제어가없는 프로토콜을 사용하고 싶지는 않습니다. 물론, 코드가 실제로 어떻게 잘 들어 맞는지 실제로 알 수 있어야합니다. github 링크가 있습니까? :)