我试图使用flask_socketio和eventlet处理多个并发请求。但是,它不像预期的那样工作:当函数test1()运行时,它会阻止输出日志中函数test2()的执行。
如何实现服务器同时处理两个请求?
服务器(Python):
import eventlet
eventlet.monkey_patch()
from flask import Flask, render_template
from flask_socketio import SocketIO, send, emit
app = Flask(__name__)
socketio = SocketIO(app, async_mode='eventlet')
@socketio.on('test1')
def test1():
print('test1 started')
do_complicated_calculation() # takes some time
print('test1 done')
@socketio.on('test2')
def test2():
print('test2')
if __name__ == '__main__':
socketio.run(app)Client (JavaScript):
import io from 'socket.io-client';
socket = io('http://localhost:5000');
socket.emit('test1');
socket.emit('test2');预期输出:
test1 started
test2
test1 done实际输出:
test1 started
test1 done
test2发布于 2019-02-05 18:21:46
正如在GitHub上讨论的那样,您需要尽可能频繁地在长计算中插入socketio.sleep(0)调用,最好是在循环中插入,以便定期进行。这将允许事件调度程序在第一个任务运行时将CPU分配给您的第二个任务。
https://stackoverflow.com/questions/54530526
复制相似问题