python - 如何在 Flask 中使用 "start_background_task"的 block 函数？

Question

我正在使用 Flask 设置一个新服务器。 它使用flask_socketio和zmq将图像从服务器推送到网络。 我想使用 zmq.recv() 作为 block 函数。 然而它会堵塞 flask 。所有来自网络的消息都将被阻止。 如何在flask中使用 block 函数，而不使用socketio.sleep()

我尝试将 zmq.NOBLOCK 设置为 zmq.recv()。然后添加socketio.sleep(0.001)。它有效，但非常难看。

这是我的代码。

ctx = zmq.Context()
sock = ctx.socket(zmq.ROUTER)
sock.bind("tcp://*:9988")


def recvThread():   
    while True:     
            img = sock.recv()   
                socketio.emit("frame", img)


if __name__ == '__main__':
    init_zmq()
    with thread_lock:
        if thread is None:
            socketio.start_background_task(target=recvThread)
    socketio.run(app, host='0.0.0.0', port=5000)

有什么标志可以用于这种情况吗？

Answer 1

我通过用 eventlet.green.zmq 替换 zmq 解决了这个问题。 Ref