Flask 自带的服务器是如何处理请求的？Python 中其工作原理是什么？

from flask import Flask
app = Flask(name)
@app.route(’/’）
def index():
return ‘Hello Flask’
if name == ‘main’:
app.run()

假设现在有这么一个最简单的 Flask 代码，Flask 会根据 Request 产生相对应的 Response。

那么，Flask 自带的 WSGI 服务器是以何种方式处理请求的呢？比如说是单进程多线程，多进程多线程还是单进程单线程？

itying888 1楼

默认单线程单进程。
<a target="_blank" href="http://app.run" rel="nofollow noopener">app.run</a>(threaded=True) 多进程
<a target="_blank" href="http://app.run" rel="nofollow noopener">app.run</a>(processes=4) 多线程

phonegap100 2楼

Flask自带的开发服务器（Werkzeug）处理请求的核心流程是这样的：

首先，当你在代码里执行app.run()时，Werkzeug会启动一个单线程的WSGI服务器。这个服务器在一个循环里监听你指定的端口（默认5000）。

当有HTTP请求进来时，服务器主循环会接收到原始的socket连接。Werkzeug的make_server会创建一个WSGIRequestHandler实例来处理这个连接。这个handler会把原始的HTTP请求数据解析成符合WSGI规范的环境字典（environ）。

关键的一步是调用Flask应用对象本身——因为Flask应用实现了WSGI接口的__call__方法。Werkzeug服务器会执行app(environ, start_response)，这触发了Flask的整个请求处理流程。

在Flask内部，它会根据environ中的PATH和METHOD，通过URL映射找到对应的视图函数。然后创建请求上下文，推入到_request_ctx_stack中，这样你才能在视图函数里访问request和session这些对象。

找到视图函数后，Flask执行它，拿到返回值。如果是字符串，就包装成响应对象；如果已经是响应对象，就直接使用。最后，通过start_response回调函数把状态码和响应头发回给Werkzeug服务器，服务器再把响应体发送给客户端。

整个过程是同步阻塞的——一个请求处理完才会处理下一个。这就是为什么开发服务器不适合生产环境，它只能同时处理一个请求。

简单说，就是Werkzeug负责网络IO和WSGI协议，Flask负责路由和业务逻辑。

建议：想深入了解可以看看Werkzeug和Flask的源码，特别是BaseWSGIServer和Flask.__call__方法。

sinazl 3楼作者

如果是这样的话，我进行测试过。代码如下：

python .route('/') def index(): time.sleep(10) return 'Hello Flask' 

假如是默认是单进程单线程，我开启了 10 个网页，是不是第 10 个网页应该在 100s 后才能接收到 Response，但是实际测试的时候，并不是？

shell $ gunicorn -w 4 xxx:app 

使用 Gunicorn 运行的话，相当于开启了四个进程，那也就是说，四个进程也是单线程模式？

我找了很多资料，也没有找到答案，请前辈赐教。

yuanlaile 4楼

不是 100s 后才接收到的话，那你是多久后接收到的？ 99s ？
2. gunicorn 起了 4 个 worker，每个 worker 单独运行 app，与你的 app.run 没有关系，这相当于四个进程，每个 app 单线程单进程。

gunicorn 使用按照 wsgi 协议启动 app，app.run 使用的是 werkzeug 的 run_simple 启动 app，你看一下 run_simple 的启动参数或者 flask 源码就知道了。

bupafengyu 5楼

问题一:
由于 Flask 代码中默认启用了多线程，如下:

python # 大致在 936 行 options.setdefault('use_reloader', self.debug) options.setdefault('use_debugger', self.debug) options.setdefault('threaded', True) # here cli.show_server_banner(self.env, self.debug, <a target="_blank" href="http://self.name" rel="nofollow noopener">self.name</a>, False) from werkzeug.serving import run_simple try: run_simple(host, port, self, **options) # 此处启动 server finally: # reset the first request information if the development server # reset normally. This makes it possible to restart the server # without reloader and that stuff from an interactive shell. self._got_first_request = False 

然后再往下走，此处忽略，然后最终到达：

python def make_server(host=None, port=None, app=None, threaded=False, processes=1, request_handler=None, passthrough_errors=False, ssl_context=None, fd=None): """Create a new server instance that is either threaded, or forks or just processes one request after another. """ if threaded and processes > 1: raise ValueError("cannot have a multithreaded and " "multi process server.") elif threaded: return ThreadedWSGIServer(host, port, app, request_handler, passthrough_errors, ssl_context, fd=fd) elif processes > 1: return ForkingWSGIServer(host, port, app, processes, request_handler, passthrough_errors, ssl_context, fd=fd) else: return BaseWSGIServer(host, port, app, request_handler, passthrough_errors, ssl_context, fd=fd) 
所以默认使用的是多线程方式，所以解决了问题 1

问题二:

-w 表示启动多少个 worker,简单来讲就是启动几个 flask app 副本，一种简单实现方式:

python # 伪代码 def start(app, worker=4, *args, **kwargs): workers = [Process(target=app, args=()) for _ in range(worker)) for _worker in workers: _worker.start() # 如果你看 sanic，其实也是这个实现方式 

所以关于 gunicorn,我的理解就是启动-w 个 flask 程序，如你描述那就是 4 个 flask 进程，至于是不是单进程多线程方式，那是另外一个问题了…