main
wsy182 2025-08-08 10:17:31 +08:00
parent 1211d2fca9
commit f7eb913be3
1 changed files with 15 additions and 17 deletions

View File

@ -1,29 +1,27 @@
import ssl
import websocket import websocket
# WebSocket 地址 URL = "wss://192.168.1.3/ws/" # 注意走 443不要再连 8080 了
url = "ws://192.168.1.41:9516/ws/" # 或 wss://192.168.1.41:9516/ws/ # 如果你的 WS 路径是 /ws/,就写成上面这样;若是别的路径自己改
def on_message(ws, message):
print("收到消息:", message)
def on_error(ws, error):
print("发生错误:", error)
def on_close(ws, close_status_code, close_msg):
print("连接关闭")
def on_message(ws, msg): print("收到:", msg)
def on_error(ws, err): print("错误:", err)
def on_close(ws, code, reason): print("关闭:", code, reason)
def on_open(ws): def on_open(ws):
print("连接成功") print("连接成功")
# 连接成功后发一条测试消息
ws.send("hello server") ws.send("hello server")
if __name__ == "__main__": if __name__ == "__main__":
websocket.enableTrace(True) # 打开调试日志,看握手过程 websocket.enableTrace(True)
ws_app = websocket.WebSocketApp( ws = websocket.WebSocketApp(
url, URL,
on_open=on_open,
on_message=on_message, on_message=on_message,
on_error=on_error, on_error=on_error,
on_close=on_close, on_close=on_close,
on_open=on_open header=["Origin: https://192.168.1.3"] # 如后端不校验 Origin 可删
) )
ws_app.run_forever() ws.run_forever(sslopt={
"cert_reqs": ssl.CERT_NONE,
"check_hostname": False,
})