使用Python Twisted Websocket客户端建立与服务器的并发Websocket连接

Question

我试图使用Python Twisted Authobhan websocket客户端打开客户端（每台机器有60K端口限制）的并发websocket连接。但是我无法使用下面的代码打开不超过20K的连接：

from autobahn.twisted.websocket import WebSocketClientProtocol, WebSocketClientFactory

class WebSocketClient(WebSocketClientProtocol):

    def _handshake_request(self):
        pass

    def onOpen(self):
        self._handshake_request()

    def onConnect(self, response):
        pass
    def onMessage(self,data):
        pass


class WebSocketFactory(WebSocketClientFactory):

    """WebSocketClient Factory"""

    protocol = WebSocketClient

if __name__ == '__main__':

    factory = WebSocketFactory()

    ##### Note here. ######
    for _ in range(num_connections):
        reactor.connectTCP(ws_url, ws_port, factory)
    #####

    reactor.run()

我在一个循环中使用了“reactor.connecttcp”，使用Twisted打开并发websocket连接是否正确？

让我知道。

Answer 1

您需要执行较少的并发连接尝试。您可能能够维持20K或更多的连接，但无法同时建立所有连接。

每次限制在几十个或一百个。为此，您可能需要使用twisted.internet.task.coperation。