flask_socketio 使用 eventlet 的并发性

flask_socketio concurrency using eventlet

我正在尝试使用 flask_socketioeventlet 处理多个并发请求。但是,它没有按预期工作:当函数 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 分配给您的第二个任务,而第一个任务是 运行。