我使用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 格式传回。
似乎在您的代码中,调用了 WebsockeApp 类中的 on_message ,而不是您代码中的 on_message 。要在代码中运行 on_message,只需在代码中创建一个自己的类,然后将对象创建更改为
From:
on_message = on_message
To:
ws = websocket.WebSocketApp("ws://localhost:4010", subprotocols=["echo-protocol"], on_message = YourClassName.on_message, on_error = on_error, on_close = on_close)
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)