9

我有多个客户端试图连接到服务器发送的事件流/stream。这适用于单个客户端，但尝试连接更多客户端会导致新客户端无限期地阻塞等待数据。如果我发送更多数据，它只会发送给第一个客户端，而不会发送给其他客户端。

这是一个小片段，说明了我的问题：

import flask
import time

app = flask.Flask(__name__)

def event_stream():
    for i in xrange(9999):
        yield "data: %d\n\n" % i
        time.sleep(1)

@app.route("/stream", methods=[ "GET" ])
def stream():
    return flask.Response(
        event_stream(),
        mimetype="text/event-stream"
    )

然后我用gunicorn --worker-class=gevent -w 4 -t 99999 app:app. 它适用于单个客户端，但任何其他客户端在发布时都会被阻止GET /stream。

阻塞的原因是什么，我应该如何解决它？

我又调试了一些，得到了一些奇怪的结果。如果我执行此过程，则会发生这种情况：

  • 启动客户端1（只有客户端1接收数据）
  • 启动客户端 2（只有客户端 1 接收数据）
  • 启动客户端 3（只有客户端 1 接收数据）
  • 启动客户端 4（只有客户端 1 接收数据）
  • 重启客户端1（4个客户端突然同时开始接收数据）
4

2 回答 2

3

事实证明，这与我正在测试的 Chromium 网络浏览器有关。由于某种原因，它会在第一个请求完成之前阻止发出请求。使用curl, 或隐身浏览器会话允许多个会话同时运行。这意味着我的问题在现实中并不真正存在，只是因为 Chromium 处理对同一资源的同时请求的方式。

我不太清楚为什么 Chromium 会这样，这看起来很奇怪。无论哪种方式，这都不是真正的问题，只是我的浏览器感知到的问题。

于 2013-06-24T08:21:45.747 回答
2

我在 Firefox 中得到了类似的结果（正如我在评论中指出的那样）然后我切换到在主块中使用 WSGIServer 而不是 gunicorn 并且一切正常，超时消失了（因为 WSGIServer 不会使其工作人员超时，但 gunicorn 会）所以我认为这值得添加作为答案。

添加这个：

if __name__ == '__main__':
http_server = WSGIServer(('127.0.0.1', 8001), app)
http_server.serve_forever()

然后就做

python app.py

[如果我使用 Chris 的命令行并将超时设置为 99999，我将不会在 30 秒后超时，但会晚得多]

于 2013-07-19T02:55:31.970 回答