Changeset View
Changeset View
Standalone View
Standalone View
src/websocket_test.py
- This file was added.
Property | Old Value | New Value |
---|---|---|
File Mode | null | 100755 |
#!/usr/bin/python3 -tt | |||||
import json | |||||
import time | |||||
import websocket | |||||
try: | |||||
import thread | |||||
except ImportError: | |||||
import _thread as thread | |||||
def on_message(ws, message): | |||||
print("message: %s" % (message)) | |||||
def on_pong(ws, message): | |||||
print("pong: %s" % (message)) | |||||
def on_error(ws, error): | |||||
print(error) | |||||
def on_close(ws): | |||||
print("### closed ###") | |||||
def on_open(ws): | |||||
def run(*args): | |||||
for i in range(3): | |||||
time.sleep(1) | |||||
ws.send(json.dumps(['ping', i])) | |||||
time.sleep(1) | |||||
ws.close() | |||||
print("thread terminating...") | |||||
thread.start_new_thread(run, ()) | |||||
if __name__ == "__main__": | |||||
websocket.enableTrace(True) | |||||
ws = websocket.WebSocketApp( | |||||
"ws://127.0.0.1:8000", | |||||
on_message=on_message, | |||||
on_pong=on_pong, | |||||
on_error=on_error, | |||||
on_close=on_close | |||||
) | |||||
ws.on_open = on_open | |||||
ws.run_forever() |