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)) 

上記のコードは、メッセージを受信して​​、戻って同じメッセージで応答します。しかし、私のユースケースは異なります。

私はいくつかのデータを処理してDBに格納し、最後にデータを接続されたクライアントに送信するか、特定のタイプのデータを特定の接続クライアントに送信し、もう一方のタイプを別のタイプに送信します。

どうすればいいですか？ sendMessageをクラス外でどのように呼び出すことができますか？

Answer 1

接続を追跡するには、WebSocketServerFactoryをサブクラス化する必要があります。

このexampleを見ると、すべての開いている接続がリストに格納され、すべての接続がブロードキャストされます。特定のクライアントに特定のメッセージを送信するように簡単に調整できます。

Answer 2

raw WebSocketの代わりにWAMPを使用したくないですか？

「興味のあるクライアントへのブロードキャスト情報」は、パブリッシュ/サブスクライブパターンのためのものです。