我找不到一个非常简单的例子来说明如何在python中进行websocket连接,并提供一些监听传入消息的on_消息回调。
所以websocket create_connection 方法创建连接,但我不知道在哪里可以传递回调函数,每次对方向我发送消息时都会调用该函数。
create_connection
我正在创建一个简单的python websocket代理/中继,因此每次客户端连接到我的服务器时,我都想创建一个到另一台服务器的连接,然后监听传入的消息,以便将它们传递回客户端。
所以我就这么做了。我希望这是最好的方式。
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, ())