在Flask-SocketIO多重处理中将套接字作为参数传递

Question

我正在尝试让Flask SocketIO服务器使用多处理。服务器无需多处理即可正常工作。我需要在通过访问路由调用的函数中发出SocketIO消息。之前，我是通过将socketio作为参数传递给函数，然后使用socketio来实现的。emit（），工作正常。不幸的是，当我用pool将函数添加到pool时。apply（），我得到TypeError:无法序列化'greenlet'。greenlet对象。如果我没有通过套接字，它会工作，但显然我没有得到我需要的套接字功能。导致此错误的原因是什么？如何更正？我没有使用gunicorn或eventlet或gevent或其他任何东西。

我的简化代码：

def requester(user, socket):

    socket.emit('hello')
    # do some stuff with requests and databases
    socket.emit('goodbye')

def main():

    app = Flask(__name__,
                static_url_path='',
                static_folder='dist',
                template_folder='dist')

    socketio = SocketIO(app)

    pool = multiprocessing.Pool(16)

    @app.route('/addname', methods=['POST'])
    def add_name:
        pool.apply(requester, args=(request.json['user'], socketio))
        return request.json['user'], 201

    socketio.run(app, host='0.0.0.0', port=8000)

if __name__ == '__main__':
    main()

Answer 1

我没有使用gunicorn或eventlet或gevent或其他任何东西。

很明显，您使用的是基于greenlet的框架。异步框架的选择是自动的，因此通过在virtualenv greenlets上安装eventlet或gevent，可以使用异步框架。如果不想使用这些，请确保未安装eventlet或gevent。

我正在尝试让Flask SocketIO服务器使用多处理。

这是行不通的，因为插座。IO是一个有状态的服务器，您不能仅通过运行多个工作进程来扩展。

有关从辅助进程向客户端发送的推荐方法，请参阅关于从外部进程发送的留档。