flask_socketio 用法：

socket.io不能同时建多个：

启动必须：socketio.run(app, debug=False,host = '0.0.0.0', port = 5000)

init_app不管用，不知道干嘛的：会报gevent的猴子错误

#!/usr/bin/env python
from threading import Lock
from flask import Flask, render_template, session, request
from flask_socketio import SocketIO, emit, join_room, leave_room, \close_room, rooms, disconnect# Set this variable to "threading", "eventlet" or "gevent" to test the
# different async modes, or leave it set to None for the application to choose
# the best option based on installed packages.
async_mode = Noneapp = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app, async_mode=async_mode)
thread = None
thread_lock = Lock()def background_thread():"""Example of how to send server generated events to clients."""count = 0while True:socketio.sleep(1)count += 1socketio.emit('my_response',{'data': 'Server generated event', 'count': count},namespace='/test')@app.route('/')
def index():return render_template('index.html', async_mode=socketio.async_mode)@socketio.on('my_event', namespace='/test')
def test_message(message):session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response',{'data': message['data'], 'count': session['receive_count']})print("################################")
@socketio.on('my_broadcast_event', namespace='/test')
def test_broadcast_message(message):session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response',{'data': message['data'], 'count': session['receive_count']},broadcast=True)@socketio.on('join', namespace='/test')
def join(message):join_room(message['room'])session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response',{'data': 'In rooms: ' + ', '.join(rooms()),'count': session['receive_count']})@socketio.on('leave', namespace='/test')
def leave(message):leave_room(message['room'])session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response',{'data': 'In rooms: ' + ', '.join(rooms()),'count': session['receive_count']})@socketio.on('close_room', namespace='/test')
def close(message):session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response', {'data': 'Room ' + message['room'] + ' is closing.','count': session['receive_count']},room=message['room'])close_room(message['room'])@socketio.on('my_room_event', namespace='/test')
def send_room_message(message):session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response',{'data': message['data'], 'count': session['receive_count']},room=message['room'])@socketio.on('disconnect_request', namespace='/test')
def disconnect_request():session['receive_count'] = session.get('receive_count', 0) + 1emit('my_response',{'data': 'Disconnected!', 'count': session['receive_count']})disconnect()@socketio.on('my_ping', namespace='/test')
def ping_pong():emit('my_pong')@socketio.on('connect', namespace='/test')
def test_connect():print("connect")global threadwith thread_lock:if thread is None:thread = socketio.start_background_task(target=background_thread)emit('my_response', {'data': 'Connected', 'count': 0})@socketio.on('disconnect', namespace='/test')
def test_disconnect():print('Client disconnected', request.sid)if __name__ == '__main__':socketio.run(app, debug=False,host = '0.0.0.0', port = 5000)

// var socket = io.connect(location.origin + '/warn/',var socket = io.connect( 'http://127.0.0.1:9000/warn/',{'sync disconnect on unload': true// 'transports': ['websocket']});socket.on('connect', function() {alert("conn");socket.emit('alive', {data: 'ok'});
});
socket.on('join', function(response) {if (response.success) {displayWarningData(response);} else {socket.disconnect();}
});
socket.on('message', function(msg) {displayWarningData(msg);
});

flask_socketio 用法：相关推荐

c语言中external，static关键字用法
static用法: 在C中,static主要定义全局静态变量.定义局部静态变量.定义静态函数. 1.定义全局静态变量:在全局变量前面加上关键字static,该全局变量变成了全局静态变量.全局静态变量有 ...
Pandas_transform的用法
先来看一个实例问题. 如下销售数据中展现了三笔订单,每笔订单买了多种商品,求每种商品销售额占该笔订单总金额的比例.例如第一条数据的最终结果为:235.83 / (235.83+232.32+107.9 ...
Python中yield和yield from的用法
yield 后面接的是 future 对象调用方委托生成器 yield from 直接给出循环后的结果 yield from 委托者和子生成器直接通信 yield from 直接处理stopIte ...
pytorch学习中 torch.squeeze() 和torch.unsqueeze()的用法
squeeze的用法主要就是对数据的维度进行压缩或者解压. 先看torch.squeeze() 这个函数主要对数据的维度进行压缩,去掉维数为1的的维度,比如是一行或者一列这种,一个一行三列(1,3)的 ...
python yield 和 yield from用法总结
#例1. 简单输出斐波那契數列前 N 个数 #缺点:该函数可复用性较差,因为 fab 函数返回 None,其他函数无法获得该函数生成的数列 #要提高 fab 函数的可复用性,最好不要直接打印出数列,而 ...
tf.nn.embedding_lookup()的用法
函数: tf.nn.embedding_lookup( params, ids, partition_strategy='mod', name=None, validate_indices=True, ...
OpenMP用法大全
OpenMP基本概念 OpenMP是一种用于共享内存并行系统的多线程程序设计方案,支持的编程语言包括C.C++和Fortran.OpenMP提供了对并行算法的高层抽象描述,特别适合在多核CPU机器上的 ...
Dorado用法与示例
Dorado用法与示例 dorado用后总结一.dorado概念 dorado的产品全名是"dorado展现中间件".从产品形态上dorado由两部分组成,第一部分是一个具有AJ ...
TensorFlow用法
TensorFlow用法什么是TensorFlow TensorFlow是一个开源软件库,用于使用数据流图进行数值计算.图中的节点表示数学运算,而图的边缘表示流动的多维数据数组(张量).这种灵活的体 ...

flask_socketio 用法：

flask_socketio 用法：相关推荐

最新文章

热门文章