Miguel Grinberg
4 years ago
45 changed files with 468 additions and 29 deletions
@ -0,0 +1,28 @@ |
|||
import asyncio |
|||
import socketio |
|||
|
|||
sio = socketio.AsyncClient() |
|||
|
|||
|
|||
@sio.event |
|||
async def connect(): |
|||
print('connected to server') |
|||
|
|||
|
|||
@sio.event |
|||
async def disconnect(): |
|||
print('disconnected from server') |
|||
|
|||
|
|||
@sio.event |
|||
def hello(a, b, c): |
|||
print(a, b, c) |
|||
|
|||
|
|||
async def start_server(): |
|||
await sio.connect('http://localhost:5000') |
|||
await sio.wait() |
|||
|
|||
|
|||
if __name__ == '__main__': |
|||
asyncio.run(start_server()) |
|||
@ -0,0 +1,23 @@ |
|||
import socketio |
|||
|
|||
sio = socketio.Client() |
|||
|
|||
|
|||
@sio.event |
|||
def connect(): |
|||
print('connected to server') |
|||
|
|||
|
|||
@sio.event |
|||
def disconnect(): |
|||
print('disconnected from server') |
|||
|
|||
|
|||
@sio.event |
|||
def hello(a, b, c): |
|||
print(a, b, c) |
|||
|
|||
|
|||
if __name__ == '__main__': |
|||
sio.connect('http://localhost:5000') |
|||
sio.wait() |
|||
@ -0,0 +1,11 @@ |
|||
<!doctype html> |
|||
<html lang="en"> |
|||
<head> |
|||
<meta charset="UTF-8"> |
|||
<title>Socket.IO Fiddle</title> |
|||
</head> |
|||
<body> |
|||
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/3.0.3/socket.io.min.js"></script> |
|||
<script src="/static/fiddle.js"></script> |
|||
</body> |
|||
</html> |
|||
@ -0,0 +1,31 @@ |
|||
from aiohttp import web |
|||
|
|||
import socketio |
|||
|
|||
sio = socketio.AsyncServer(async_mode='aiohttp') |
|||
app = web.Application() |
|||
sio.attach(app) |
|||
|
|||
|
|||
async def index(request): |
|||
with open('fiddle.html') as f: |
|||
return web.Response(text=f.read(), content_type='text/html') |
|||
|
|||
|
|||
@sio.event |
|||
async def connect(sid, environ): |
|||
print('connected', sid) |
|||
await sio.emit('hello', (1, 2, {'hello': 'you'}), to=sid) |
|||
|
|||
|
|||
@sio.event |
|||
def disconnect(sid): |
|||
print('disconnected', sid) |
|||
|
|||
|
|||
app.router.add_static('/static', 'static') |
|||
app.router.add_get('/', index) |
|||
|
|||
|
|||
if __name__ == '__main__': |
|||
web.run_app(app) |
|||
@ -0,0 +1,19 @@ |
|||
'use strict'; |
|||
|
|||
(function() { |
|||
|
|||
const socket = io(); |
|||
|
|||
socket.on('connect', () => { |
|||
console.log(`connect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('disconnect', () => { |
|||
console.log(`disconnect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('hello', (a, b, c) => { |
|||
console.log(a, b, c); |
|||
}); |
|||
|
|||
})(); |
|||
@ -0,0 +1,11 @@ |
|||
<!doctype html> |
|||
<html lang="en"> |
|||
<head> |
|||
<meta charset="UTF-8"> |
|||
<title>Socket.IO Fiddle</title> |
|||
</head> |
|||
<body> |
|||
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/3.0.3/socket.io.min.js"></script> |
|||
<script src="/static/fiddle.js"></script> |
|||
</body> |
|||
</html> |
|||
@ -0,0 +1,25 @@ |
|||
#!/usr/bin/env python |
|||
import uvicorn |
|||
|
|||
import socketio |
|||
|
|||
sio = socketio.AsyncServer(async_mode='asgi') |
|||
app = socketio.ASGIApp(sio, static_files={ |
|||
'/': 'fiddle.html', |
|||
'/static': 'static', |
|||
}) |
|||
|
|||
|
|||
@sio.event |
|||
async def connect(sid, environ): |
|||
print('connected', sid) |
|||
await sio.emit('hello', (1, 2, {'hello': 'you'}), to=sid) |
|||
|
|||
|
|||
@sio.event |
|||
def disconnect(sid): |
|||
print('disconnected', sid) |
|||
|
|||
|
|||
if __name__ == '__main__': |
|||
uvicorn.run(app, host='127.0.0.1', port=5000) |
|||
@ -0,0 +1,19 @@ |
|||
'use strict'; |
|||
|
|||
(function() { |
|||
|
|||
const socket = io(); |
|||
|
|||
socket.on('connect', () => { |
|||
console.log(`connect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('disconnect', () => { |
|||
console.log(`disconnect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('hello', (a, b, c) => { |
|||
console.log(a, b, c); |
|||
}); |
|||
|
|||
})(); |
|||
@ -0,0 +1,11 @@ |
|||
<!doctype html> |
|||
<html lang="en"> |
|||
<head> |
|||
<meta charset="UTF-8"> |
|||
<title>Socket.IO Fiddle</title> |
|||
</head> |
|||
<body> |
|||
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/3.0.3/socket.io.min.js"></script> |
|||
<script src="/static/fiddle.js"></script> |
|||
</body> |
|||
</html> |
|||
@ -0,0 +1,32 @@ |
|||
from sanic import Sanic |
|||
from sanic.response import html |
|||
|
|||
import socketio |
|||
|
|||
sio = socketio.AsyncServer(async_mode='sanic') |
|||
app = Sanic() |
|||
sio.attach(app) |
|||
|
|||
|
|||
@app.route('/') |
|||
def index(request): |
|||
with open('fiddle.html') as f: |
|||
return html(f.read()) |
|||
|
|||
|
|||
@sio.event |
|||
async def connect(sid, environ): |
|||
print('connected', sid) |
|||
await sio.emit('hello', (1, 2, {'hello': 'you'}), to=sid) |
|||
|
|||
|
|||
@sio.event |
|||
def disconnect(sid): |
|||
print('disconnected', sid) |
|||
|
|||
|
|||
app.static('/static', './static') |
|||
|
|||
|
|||
if __name__ == '__main__': |
|||
app.run() |
|||
@ -0,0 +1,19 @@ |
|||
'use strict'; |
|||
|
|||
(function() { |
|||
|
|||
const socket = io(); |
|||
|
|||
socket.on('connect', () => { |
|||
console.log(`connect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('disconnect', () => { |
|||
console.log(`disconnect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('hello', (a, b, c) => { |
|||
console.log(a, b, c); |
|||
}); |
|||
|
|||
})(); |
|||
@ -0,0 +1,47 @@ |
|||
import os |
|||
|
|||
import tornado.ioloop |
|||
from tornado.options import define, options, parse_command_line |
|||
import tornado.web |
|||
|
|||
import socketio |
|||
|
|||
define("port", default=5000, help="run on the given port", type=int) |
|||
define("debug", default=False, help="run in debug mode") |
|||
|
|||
sio = socketio.AsyncServer(async_mode='tornado') |
|||
|
|||
|
|||
class MainHandler(tornado.web.RequestHandler): |
|||
def get(self): |
|||
self.render("fiddle.html") |
|||
|
|||
|
|||
@sio.event |
|||
async def connect(sid, environ): |
|||
print('connected', sid) |
|||
await sio.emit('hello', (1, 2, {'hello': 'you'}), to=sid) |
|||
|
|||
|
|||
@sio.event |
|||
def disconnect(sid): |
|||
print('disconnected', sid) |
|||
|
|||
|
|||
def main(): |
|||
parse_command_line() |
|||
app = tornado.web.Application( |
|||
[ |
|||
(r"/", MainHandler), |
|||
(r"/socket.io/", socketio.get_tornado_handler(sio)), |
|||
], |
|||
template_path=os.path.join(os.path.dirname(__file__), "templates"), |
|||
static_path=os.path.join(os.path.dirname(__file__), "static"), |
|||
debug=options.debug, |
|||
) |
|||
app.listen(options.port) |
|||
tornado.ioloop.IOLoop.current().start() |
|||
|
|||
|
|||
if __name__ == "__main__": |
|||
main() |
|||
@ -0,0 +1,19 @@ |
|||
'use strict'; |
|||
|
|||
(function() { |
|||
|
|||
const socket = io(); |
|||
|
|||
socket.on('connect', () => { |
|||
console.log(`connect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('disconnect', () => { |
|||
console.log(`disconnect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('hello', (a, b, c) => { |
|||
console.log(a, b, c); |
|||
}); |
|||
|
|||
})(); |
|||
@ -0,0 +1,11 @@ |
|||
<!doctype html> |
|||
<html lang="en"> |
|||
<head> |
|||
<meta charset="UTF-8"> |
|||
<title>Socket.IO Fiddle</title> |
|||
</head> |
|||
<body> |
|||
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/3.0.3/socket.io.min.js"></script> |
|||
<script src="/static/fiddle.js"></script> |
|||
</body> |
|||
</html> |
|||
@ -0,0 +1,57 @@ |
|||
# set async_mode to 'threading', 'eventlet', 'gevent' or 'gevent_uwsgi' to |
|||
# force a mode else, the best mode is selected automatically from what's |
|||
# installed |
|||
async_mode = None |
|||
|
|||
from flask import Flask, render_template |
|||
import socketio |
|||
|
|||
sio = socketio.Server(async_mode=async_mode) |
|||
app = Flask(__name__) |
|||
app.wsgi_app = socketio.WSGIApp(sio, app.wsgi_app) |
|||
|
|||
|
|||
@app.route('/') |
|||
def index(): |
|||
return render_template('fiddle.html') |
|||
|
|||
|
|||
@sio.event |
|||
def connect(sid, environ): |
|||
print('connected', sid) |
|||
sio.emit('hello', (1, 2, {'hello': 'you'}), to=sid) |
|||
|
|||
|
|||
@sio.event |
|||
def disconnect(sid): |
|||
print('disconnected', sid) |
|||
|
|||
|
|||
if __name__ == '__main__': |
|||
if sio.async_mode == 'threading': |
|||
# deploy with Werkzeug |
|||
app.run(threaded=True) |
|||
elif sio.async_mode == 'eventlet': |
|||
# deploy with eventlet |
|||
import eventlet |
|||
import eventlet.wsgi |
|||
eventlet.wsgi.server(eventlet.listen(('', 5000)), app) |
|||
elif sio.async_mode == 'gevent': |
|||
# deploy with gevent |
|||
from gevent import pywsgi |
|||
try: |
|||
from geventwebsocket.handler import WebSocketHandler |
|||
websocket = True |
|||
except ImportError: |
|||
websocket = False |
|||
if websocket: |
|||
pywsgi.WSGIServer(('', 5000), app, |
|||
handler_class=WebSocketHandler).serve_forever() |
|||
else: |
|||
pywsgi.WSGIServer(('', 5000), app).serve_forever() |
|||
elif sio.async_mode == 'gevent_uwsgi': |
|||
print('Start the application through the uwsgi server. Example:') |
|||
print('uwsgi --http :5000 --gevent 1000 --http-websockets --master ' |
|||
'--wsgi-file latency.py --callable app') |
|||
else: |
|||
print('Unknown async_mode: ' + sio.async_mode) |
|||
@ -0,0 +1,19 @@ |
|||
'use strict'; |
|||
|
|||
(function() { |
|||
|
|||
const socket = io(); |
|||
|
|||
socket.on('connect', () => { |
|||
console.log(`connect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('disconnect', () => { |
|||
console.log(`disconnect ${socket.id}`); |
|||
}); |
|||
|
|||
socket.on('hello', (a, b, c) => { |
|||
console.log(a, b, c); |
|||
}); |
|||
|
|||
})(); |
|||
@ -0,0 +1,11 @@ |
|||
<!doctype html> |
|||
<html lang="en"> |
|||
<head> |
|||
<meta charset="UTF-8"> |
|||
<title>Socket.IO Fiddle</title> |
|||
</head> |
|||
<body> |
|||
<script src="https://cdnjs.cloudflare.com/ajax/libs/socket.io/3.0.3/socket.io.min.js"></script> |
|||
<script src="{{ url_for('static', filename='fiddle.js') }}"></script> |
|||
</body> |
|||
</html> |
|||
Loading…
Reference in new issue