Python Twisted如何通过连接的套接字连接发送数据？

Question

我有一个服务器以下内容：在

class MyServerProtocol(WebSocketServerProtocol):

    def onConnect(self, request):
        print("Client connecting: {0}".format(request.peer))

    def onOpen(self):
        print("WebSocket connection open.")

    def onMessage(self, payload, isBinary):
        self.sendMessage(payload, isBinary)

    def onClose(self, wasClean, code, reason):
        print("WebSocket connection closed: {0}".format(reason))

上面的代码接收消息并用相同的消息回复。然而，我的用例是不同的。在

我正在处理一些数据，将其存储到数据库中，然后最终希望将数据发送到连接的客户端，或者将一种类型的数据发送给特定的连接客户端，另一种类型发送给另一种类型。在

我该怎么做？如何在类之外调用sendMessage函数？

Answer 1

您需要子类WebSocketServerFactory来跟踪您的连接。在

看看这个example，它将所有打开的连接存储在一个列表中，并向所有这些连接广播。你可以很容易地调整它来向某些客户发送特定的消息。在

Answer 2

你确定你不想只使用WAMP而不是原始的WebSockets？在

这对于您的用例来说可能要容易得多，因为“向感兴趣的客户机广播信息”正是发布/订阅模式的目的。在