时间戳

首页 > 解决方案 > flask_socketio 并发使用 eventlet

socket.io - flask_socketio 并发使用 eventlet

问题描述

我正在尝试使用flask_socketioand处理多个并发请求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

标签： socket.ioflask-socketioeventlet

解决方案

正如 GitHub 上所讨论的，您需要socketio.sleep(0)在长计算中尽可能频繁地插入调用，最好是在循环中，以便它定期发生。这将允许 eventlet 调度程序在第一个任务运行时将 CPU 分配给您的第二个任务。

推荐阅读