24

我正在寻找一种方法来定期通过连接到 TCP 端口的所有客户端发送一些数据。我在看twisted python，我知道reactor.callLater。但是如何使用它定期向所有连接的客户端发送一些数据？数据发送逻辑在协议类中，由reactor根据需要进行实例化。我不知道如何将它从反应堆绑定到所有协议实例......

4

2 回答 2

38

您可能希望在工厂中为连接执行此操作。每次建立和丢失连接时不会自动通知工厂，因此您可以从协议通知它。

这是一个完整的示例，说明如何将 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()
于 2008-11-25T07:12:05.703 回答
3

我想最简单的方法是使用客户端中的 connectionMade 和 connectionLost 管理协议中的客户端列表，然后使用 LoopingCall 要求每个客户端发送数据。

这感觉有点侵入性，但我认为如果协议没有对传输/接收进行一些控制，你不会想要这样做。当然，我必须查看您的代码才能真正了解它如何适合。有github链接吗？:)

于 2008-11-24T23:19:48.170 回答