Flask服务器使用uwsgi发送事件（SSE）

Question

以下内容翻译自: https://pypi.python.org/pypi/Flask-SSE

app.py:

示例代码：

from flask import Flask
from flask_sse import sse

app = Flask(__name__)
app.config["REDIS_URL"] = "redis://localhost"
app.register_blueprint(sse, url_prefix='/stream')

@app.route('/send')
def send_message():
    sse.publish({"message": "Hello!"}, type='greeting')
    return "Message sent!"

使用：

var source = new EventSource("{{ url_for('sse.stream') }}");
source.addEventListener('greeting', function(event) {
    var data = JSON.parse(event.data);
    console.log(data);
}, false);
source.addEventListener('error', function(event) {
    console.log("Failed to connect to event stream.");
}, false);

如果我使用 gunicorn：

gunicorn app:app --worker-class gevent --bind 0.0.0.0:8000

在我的模板中可以成功接收消息，但如果我使用 uwsgi：

uwsgi --gevent 100 --socket 0.0.0.0:8000 --protocol=http -w wsgi

使用 app.ini 文件：

[uwsgi]
module = wsgi

master = true
processes = 5

socket = app.sock
chmod-socket = 660
vacuum = true

die-on-term = true

模板JavaScript没有收到任何消息，我也没有收到任何错误。

我在Ubuntu 16.10上使用redis服务器。

- Vladan

Answer 1

我认为你需要创建另一个端点来流式传输你发布的内容： 看一下这个仓库https://github.com/jakubroztocil/chat

- Amr Zaki