gevent-socketio 从线程发送消息

Question

我想使用 gevent-socketio 从工作线程发送消息并更新所有连接的客户端的作业状态。

我试过了：

from flask import Flask, render_template
from flask.ext.socketio import SocketIO, send, emit
import threading
import time

app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)

@socketio.on('message')
def handle_message(message):
    send(message, broadcast=True)

@app.route('/')
def index():
    return render_template('index.html')

def ping_thread():
    while True:
        time.sleep(1)
        print 'Pinging'
        send('ping')

if __name__ == '__main__':
    t = threading.Thread(target=ping_thread)
    t.daemon = True
    t.start()
    socketio.run(app)

它给了我这个错误：

RuntimeError: working outside of request context

如何从没有 @socketio.on() 装饰器的函数发送消息？可以直接用gevent给socketio发消息吗？

Answer 1

来自this section of the documentation：

有时服务器需要成为消息的发起者。这对于向客户端发送源自服务器的事件的通知很有用。 socketio.send() 和 socketio.emit() 方法可用于向所有连接的客户端广播：

def some_function():
    socketio.emit('some event', {'data': 42})

这个emit 不是来自from flask.ext.socketio import SocketIO, send，而是从socketio = SocketIO(app) 调用你的socketio 变量。如果您完成了socketio_connection = SocketIO(app)，那么您将调用socketio_connection.emit() 来广播您的数据。