竜巻：ウェブソケットの接続を識別/追跡しますか？

Question

私は基本的な竜巻のWebSocketのテストを持っている：

import tornado.httpserver 
import tornado.websocket 
import tornado.ioloop 
import tornado.web 

class WSHandler(tornado.websocket.WebSocketHandler): 
    def open(self): 
     print 'new connection' 
     self.write_message("Hello World") 

    def on_message(self, message): 
     print 'message received %s' % message 

    def on_close(self): 
     print 'connection closed' 


application = tornado.web.Application([ 
    (r'/ws', WSHandler), 
]) 


if __name__ == "__main__": 
    http_server = tornado.httpserver.HTTPServer(application) 
    http_server.listen(8888) 
    tornado.ioloop.IOLoop.instance().start() 

私は（すでにやっているようだ）複数の接続を処理するだけでなく、他の接続を参照できるようにすることができるようにしたいです。私は個々の接続を識別して追跡する方法は見当たりません。接続のオープン、メッセージの受信、および接続の終了時にイベントを処理できるようにするだけです。

[編集]
キーがSec-websocket-keyであり、その値がWSHandlerオブジェクト...思考であると思っていますか？ Sec-websocket-keyがどのようにして信頼できるかが一意であるかどうかはわかりません。

Answer 1

最も簡単な方法は、ちょうどWSHandlerインスタンスのリストや辞書を維持することです：

class WSHandler(tornado.websocket.WebSocketHandler): 
    clients = [] 

    def open(self): 
     self.clients.append(self) 
     print 'new connection' 
     self.write_message("Hello World") 

    def on_message(self, message): 
     print 'message received %s' % message 

    def on_close(self): 
     self.clients.remove(self) 
     print 'closed connection' 

あなたが接続を識別したい場合は、例えばおそらくその情報をソケット経由で送信する必要があります。

Answer 2

コールMaclean asnwerは、すべての接続の一覧が必要なときには簡単な解決策です。あなたがWSHandlerインスタンスの外で監視することができ、より複雑なものを、必要な場合 しかし、 - 勇敢なことのようにそれを行う：ユーザーがアクセストークンを持っている場合、これはあなたのWebSocketエンドポイントに

class WSHandler(tornado.websocket.WebSocketHandler): 

    def open(self): 
     self.id = uuid.uuid4() 
     external_storage[self.id] = {'id':self.id} 
     print 'new connection' 
     self.write_message("Hello World") 

    def on_message(self, message): 
     #Some message parsing here 
     if message.type == 'set_group': 
      external_storage[self.id]['group'] = message.group 
     print 'message received %s' % message 

    def on_close(self): 
     external_storage.remove(self.id) 
     print 'closed connection' 

Answer 3

を追加することができ、 SSLの上で作業してください。

ユーザーがトークンを提供していないか、指定されたトークンが期限切れになっているためにアクセストークンを使用できない場合、ユーザーは認証されず、できるだけ早くソケットを強制終了します。

ただし、これを行うには、アクセストークンを識別子を持つユーザーに関連付ける必要があります。その識別子は、開かれる前にソケットに結びつけることができます。識別子は、このユーザに結びつけられたソケットの集合である辞書キーとして機能することができる。

Answer 4

私はこの話題の起源をチェックしてこの問題を解決しました。したがって、メソッドdef check_origin(self, origin)をオーバーライドすると役に立ちます。たとえば、：

clients = {} 

class WSHandler(tornado.websocket.WebSocketHandler): 


    def check_origin(self, origin): 

     clients[origin] = self 
     print(clients) 
     return True