36 lines
800 B
Python
36 lines
800 B
Python
import websocket
|
|
|
|
try:
|
|
import thread
|
|
except ImportError:
|
|
import _thread as thread
|
|
import time
|
|
|
|
def on_message (ws, message):
|
|
print (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 ("Hello %d" % i, 2)
|
|
time.sleep (1)
|
|
ws.close ()
|
|
print ("thread terminating...")
|
|
thread.start_new_thread (run, ())
|
|
|
|
|
|
if __name__ == "__main__":
|
|
ws = websocket.WebSocketApp ("ws://127.0.0.1:80/",
|
|
on_message = on_message,
|
|
on_error = on_error,
|
|
on_close = on_close)
|
|
ws.on_open = on_open
|
|
ws.run_forever ()
|