flask上使用websocket的方法示例_python_

from flask import Flask, render_template from flask_socketio import SocketIO, emit app = Flask(__name__) app.config['SECRET_KEY'] = 'secret!' socketio = SocketIO(app) @app.route('/') def index():     return render_template('index.html') @socketio.on('my event', namespace='/test') def test_message(message):     emit('my response', {'data': message['data']}) @socketio.on('my broadcast event', namespace='/test') def test_message(message):     emit('my response', {'data': message['data']}, broadcast=True) @socketio.on('connect', namespace='/test') def test_connect():     emit('my response', {'data': 'Connected'}) @socketio.on('disconnect', namespace='/test') def test_disconnect():     print('Client disconnected') if __name__ == '__main__':     socketio.run(app)

$(document).ready(function(){     var socket = io.connect('http://' + document.domain + ':' + location.port + '/test');     socket.on('my response', function(msg) {         $('#log').append('
Received: ' + msg.data + '
');     });     $('form#emit').submit(function(event) {         socket.emit('my event', {data: $('#emit_data').val()});         return false;     });     $('form#broadcast').submit(function(event) {         socket.emit('my broadcast event', {data: $('#broadcast_data').val()});         return false;     }); });

from flask import Flask from flask_sockets import Sockets import datetime import time import random app = Flask(__name__) sockets = Sockets(app) @sockets.route('/echo') def echo_socket(ws):     while not ws.closed:         now = datetime.datetime.now().isoformat() + 'Z'         ws.send(now)  #发送数据         time.sleep(1) @app.route('/') def hello():     return 'Hello World!' if __name__ == "__main__":     from gevent import pywsgi     from geventwebsocket.handler import WebSocketHandler     server = pywsgi.WSGIServer(('', 5000), app, handler_class=WebSocketHandler)     print('server start')     server.serve_forever()