Python网络套接字连接并侦听传入消息

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