Python websocket 连接并监听传入的消息

Question

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

所以 websocket 有create_connection 方法来创建连接，但是我看不到我可以在哪里传递一个回调函数，每次对方向我发送消息时都会调用该函数。

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

Answer 1

所以我设法做到了这一点。我希望这是这样做的最佳方式。

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