Question

Hello
I m new in twisted, but have some questions after read manual:
1. How to use different protocols with different reactor in one program? (for example, txNetTools have own reactor and internal IRC support in twisted have own reactor from twisted.internet)
2. How to start more one client in one time? (many client with ping to other remote host) http://bazaar.launchpad.net/~oubiwann/txnet/trunk/view/head:/sandbox/ping.py
3. How to put data from one protocol to other (in one program)? I m want use data from database in protocol. (for example, every 5 minutes get hosts from database and create ping clients)
My task is simple, create a more different protocol client to many count of servers.

Answer 1

好吧，至少对于第三个问题，你说的是使用不同类的协议还是同一类的多个协议实例？协议实例可以通过让创建它们的工厂存储它们的数据来在彼此之间进行通信，如下所示：

class p(Protocol):
    factory = None
    ...
class f(Factory):
    protocol = p
    data = None
    def buildProtocol(self, addr):
        returnValue = p()
        returnValue.factory = self
        return returnValue

从那里你可以将数据保存到self.factory.data中的协议实例，任何其他协议实例都可以访问它。我希望这能回答你的问题。

Answer 2

如何在一个程序中使用不同的协议和不同的反应器？

你没有。每个进程只有一个反应器，它可以处理你想要的任意多个连接。绝大多数库都不提供反应器，txNetTools提供的反应器是可选的。它唯一提供的是这种方法：

def listenICMP(self, port, protocol, interface="", maxPacketSize=8192):
    p = icmp.Port(port, protocol, interface, maxPacketSize, self)
    p.startListening()
    return p

如果您想使用另一个reactor，那么您可以自己实例化一个icmp.Port。

如何一次启动多个客户端？

和你开始的一样，只是重复了一遍。例如，这里有十个并发的ping（包含第一个问题的答案）：

for i in range(10):
    p = icmp.Port(0, Pinger(), reactor=reactor)
    p.startListening()
reactor.run()

查梅科很好地回答了最后一个问题。

友情链接