代码之家  ›  专栏  ›  技术社区  ›  Nathan B

Python websocket连接并侦听传入消息

  •  0
  • Nathan B  · 技术社区  · 6 年前

    我找不到一个非常简单的例子来说明如何在python中进行websocket连接,并提供一些监听传入消息的on_消息回调。

    所以websocket create_connection 方法创建连接,但我不知道在哪里可以传递回调函数,每次对方向我发送消息时都会调用该函数。

    我正在创建一个简单的python websocket代理/中继,因此每次客户端连接到我的服务器时,我都想创建一个到另一台服务器的连接,然后监听传入的消息,以便将它们传递回客户端。

    1 回复  |  直到 6 年前
        1
  •  0
  •   Nathan B    6 年前

    所以我就这么做了。我希望这是最好的方式。

    ws = create_connection(url)
    def run(*args):
            while True:
                try:
                    message = ws.recv() # This is blocking
                # do what I need to do here
                except WebSocketClosedError:
                    break
    
        thread.start_new_thread(run, ())