在 python 中处理 websockets



我正在开发一个使用websockets的消息服务。我将使用python/django作为服务器端语言。有以下选项:

  1. 龙卷风
  2. Django-websockets-redis
  3. Crossbar.io
  4. 烧瓶插座IO

我对应该在活动连接数量很大的生产环境中使用什么感到困惑。

龙卷风中的Websockets相对简单。此示例展示了如何将 websocket 与极其基本的管理(openon_close方法)集成。

对于上游流量(浏览器 -> 服务器),您可以实现 WebSocketHandler 方法:

def on_message(self, message):
    # call message callback
def data_received(self, chunk):
    # do something with chunked data

对于下游流量,有WebSocketHandler.write_message

def broadcast_to_all_websockets(self, message):
    for ws in cl:
        if not ws.ws_connection.stream.socket:
            print "Web socket %s does not exist anymore!" % ws
            cl.remove(ws)
        else:
            ws.write_message(message)

强烈建议使用高速公路|蟒。 目前正在将它用于Python中的WebSocket项目,它非常易于使用,并且已经为您构建了许多类,例如WebSocketServer。 让我们也选择你的实现(在异步和扭曲之间进行选择。

相关内容

  • 没有找到相关文章

最新更新