import threading
|
from time import sleep
|
import eventlet
|
import socketio
|
|
|
def create_serve():
|
sio = socketio.Server()
|
app = socketio.WSGIApp(sio, static_files={
|
'/': {'content_type': 'text/html', 'filename': 'index.html'}
|
})
|
|
@sio.event
|
def connect(sid, environ):
|
print('connect ', sid)
|
sio.emit('serve', {'response': 'connert success'})
|
# delay_cmd = Delay_cmd(sio)
|
# t3 = threading.Thread(target=delay_cmd.send(delay_cmd))
|
# t3.setDaemon(True)
|
# t3.start()
|
|
@sio.on('msg')
|
def on_message(sid, data):
|
print('serve received a message! on_message',data)
|
# sio.emit('command_msg', {'command': 'stop', "params":"nothing"})
|
|
@sio.on('client')
|
def another_event(sid, data):
|
print('serve received a message!', data)
|
|
# @sio.event
|
# def my_event(sid, data):
|
# print('message ', data)
|
# sio.emit('serve', {'response': 'connert success'})
|
|
@sio.event
|
def disconnect(sid):
|
print('disconnect ', sid)
|
|
if __name__ == '__main__':
|
eventlet.wsgi.server(eventlet.listen(('', 5000)), app)
|
|
|
class Delay_cmd():
|
def __init__(self, sio,):
|
self.sio = sio
|
|
def send(self):
|
while True:
|
sleep(10)
|
self.sio.emit('command_msg', {'command': 'stop', "params":"nothing"})
|
sleep(10)
|
self.sio.emit('command_msg', {'command': 'start', "params":"nothing"})
|
|
create_serve()
|
