flask_socketio 使用 eventlet 的并发性
flask_socketio concurrency using eventlet
我正在尝试使用 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)
客户(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
正如在 GitHub 上讨论的那样,您需要在长时间的计算中尽可能频繁地插入 socketio.sleep(0)
调用,最好是在循环中,以便它定期发生。这将允许 eventlet 调度程序将 CPU 分配给您的第二个任务,而第一个任务是 运行。
我正在尝试使用 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)
客户(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
正如在 GitHub 上讨论的那样,您需要在长时间的计算中尽可能频繁地插入 socketio.sleep(0)
调用,最好是在循环中,以便它定期发生。这将允许 eventlet 调度程序将 CPU 分配给您的第二个任务,而第一个任务是 运行。