python websocketapp on_message() 方法不起作用

Question

我使用python从nodejs服务器接收流数据，使用以下python代码。websocket 应该获取实时流数据。我假设 python 的 WebSocketApp 获取流数据的唯一方法是通过 on_message() 。

然而，尽管可以成功建立连接，但 on_message() 从未被调用。 on_open() 仍然被调用，并且 ping 消息已例行发送到服务器以维持心跳。

我在互联网上进行了搜索，但找不到关于发生了什么导致 on_message() 失败的线索？

我测试了本地和远程的连接，连接良好。

import websocket
from websocket import create_connection


import json
try:
    import thread
except ImportError:
    import _thread as thread
import time

def on_message(ws, message):
    print('on msg called')
    print(message)

def on_error(ws, error):
    print(error)

def on_close(ws):
    time.sleep(1)
    ws.close()
    print("### closed ###")


def on_open(ws):
    def run(*args):
        time.sleep(1)
        print('sending from run()...')
        ws.send("{\"login\":\"login\",\"password\":\"pw\"}")
        time.sleep(1)

        try:
            print('receiving message...')
            #result =  json.loads(ws.receive())
            #result = ws.recv_frame()
            #result = json.loads(ws.recv())
            #print(result)
        except Exception as e:
            print('failed to receive messages...')
            print(e)
            time.sleep(1)
            ws.close()        

    thread.start_new_thread(run, ())


if __name__ == "__main__":
    try:
        websocket.enableTrace(True)         # show the header part 
        ws = websocket.WebSocketApp("ws://localhost:4010",
                                  subprotocols=["echo-protocol"],
                                  on_message = on_message,
                                  on_error = on_error,
                                  on_close = on_close)
        ws.on_open = on_open
        ws.run_forever(ping_interval=0,ping_timeout=0)
    except KeyboardInterrupt:
        ws.close()

相信成功检索后，信息将以json格式传回。

Answer 1

似乎在您的代码中，调用了 WebsockeApp 类中的 on_message，而不是您代码中的 on_message。要在代码中运行 on_message，只需在代码中创建一个自己的类，然后将对象创建更改为

来自:

on_message = on_message

致:

ws = websocket.WebSocketApp("ws://localhost:4010", subprotocols=["echo-protocol"], on_message = YourClassName.on_message, on_error = on_error, on_close = on_close)