使用工具 :
Python 3.8
程式碼:
import websocket
try:
import thread
except ImportError:
import _thread as thread
import time
import threading
import json
"""
這是一個卡 WebSocket 的 Example
"""
def on_message(ws, message):
# parse x:
message = json.loads(message)
print("message", message, "\n")
print("\n");
def on_error(ws, error):
# print(error)
print("error", error, "\n")
def on_close(ws):
print("### closed ###")
def on_open(ws):
print("ws coennet...")
# def run(*args):
# print("ws coennet...")
# # for i in range(3):
# # time.sleep(1)
# # ws.send("Hello %d" % i)
# # time.sleep(1)
# # ws.close()
# print("thread terminating...")
# thread.start_new_thread(run, ())
def run_s(i):
websocket.enableTrace(True)
wsc = "接口"
ws = websocket.WebSocketApp(wsc,
on_message=on_message,
on_error=on_error,
on_close=on_close)
ws.on_open = on_open
ws.run_forever()
if __name__ == "__main__":
# 建立 5 個子執行緒
num = 1
threads = []
for i in range(num):
threads.append(threading.Thread(target=run_s, args=(i,)))
threads[i].start()
# 等待所有子執行緒結束
for i in range(num):
threads[i].join()
print("Done.")
