HCM upstream/downstream 事件驱动协作下的 HTTP 反向代理流程#

HTTP 反向代理的总流程#

整体看，Socket 事件驱动的 HTTP 反向代理总流程如下：图：Socket 事件驱动的 HTTP 反向代理总流程

图中看出，有4种事件驱动了整个流程。后面几节会逐个分析。

为免一下子进入各个步骤细节而让人迷途，建议回顾一下之前举例的所有步骤的总流程： Istio 下 Envoy 配置举例

大概说明一下流程：

downstream socket 可读回调
Http::ConnectionManagerImpl 读取 socket，增量放入 Http1::ConnectionImpl
Http1::ConnectionImpl 调用 nghttp2 增量解释 HTTP 请求
如果 nghttp2 认为已经完整读取了 HTTP Request 请求，则调用 Http::ServerConnection::onMessageCompleteBase()
Http::ServerConnection::onMessageCompleteBase() 首先 停止 downstream ReadReady 监听
Http::ServerConnection::onMessageCompleteBase() 调用 Http::FilterManager ，发起 http filter chain 的 decodeHeaders 迭代流程
一般，http filter chain 的最后一个 http filter 是 Router::Filter ，Router::Filter::decodeHeaders() 被调用
Router::Filter::decodeHeaders() 的逻辑就见下图了。

大概说明一下流程：

Router::Filter ，Router::Filter::decodeHeaders() 被调用
根据配置的 Router 规则，匹配到 Cluster
如 Cluster 连接池对象不存在，则新建
新建 Envoy::Router::UpstreamRequest 对象。
调用 Envoy::Router::UpstreamRequest::encodeHeaders(bool end_stream) ， encode HTTP header
经过一系列的负载均衡算法，匹配到 upstream 的 host(endpoint)
发现到选定的 upstream host 的连接不足，则：
1. 打开一新的 socket fd(未连接)
2. 注册 upstream socket FD 的 WriteReady / Connected 事件。准备在事件回调时写 upstream request
3. 用 socket fd 发起到 upstream host 的异步连接请求
关联 downstream 与 upstream fd