Skip to content

Commit 5b11cb3

Browse files
committed
Added socketio server
1 parent 435a16e commit 5b11cb3

File tree

2 files changed

+30
-1
lines changed

2 files changed

+30
-1
lines changed

package.json

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,11 @@
1616
"ws-eventlet": "PORT=5004 SERVER=eventlet babel-node src/clients/ws_client.js",
1717
"websocket-eventlet": "PORT=5004 SERVER=eventlet babel-node src/clients/websocket_client.js",
1818
"eventlet": "python src/servers/eventlet_server.py --port 5004",
19+
"ws-websockets": "PORT=5005 SERVER=websockets babel-node src/clients/ws_client.js",
1920
"websocket-websockets": "PORT=5005 SERVER=websockets babel-node src/clients/websocket_client.js",
20-
"websockets": "python src/servers/websockets_server.py --port 5005"
21+
"websockets": "python src/servers/websockets_server.py --port 5005",
22+
"socketio-socketio": "PORT=5006 SERVER=socketio babel-node src/clients/socketio_client.js",
23+
"socketio": "python src/servers/socketio_server.py --port 5006"
2124
},
2225
"repository": {
2326
"type": "git",

src/servers/socketio_server.py

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
import eventlet
2+
import socketio
3+
import json
4+
import argparse
5+
6+
sio = socketio.Server()
7+
app = socketio.WSGIApp(sio)
8+
9+
class HelloNamespace(socketio.Namespace):
10+
def on_message(self, sid, data):
11+
self.send({'hello': data['name']})
12+
13+
# @sio.on('message', namespace='/hello')
14+
# def hello(sid, data):
15+
# sio.send({'hello': data['name']}, namespace='/hello')
16+
17+
sio.register_namespace(HelloNamespace('/hello'))
18+
19+
if __name__ == '__main__':
20+
parser = argparse.ArgumentParser()
21+
parser.add_argument('-l', '--host', default='0.0.0.0')
22+
parser.add_argument('-p', '--port', default=5000, type=int)
23+
24+
args = parser.parse_args()
25+
print('Server starting at: ' + 'ws://{}:{}'.format(args.host, args.port))
26+
eventlet.wsgi.server(eventlet.listen((args.host, args.port)), app)

0 commit comments

Comments
 (0)