Envoy 源码剖析主文档

graph TB
    subgraph "应用层"
        A[HTTP/gRPC 应用]
    end
    
    subgraph "Envoy 代理层"
        B[Listener 监听器]
        C[Filter Chain 过滤器链]
        D[Router 路由器]
        E[Cluster Manager 集群管理器]
        F[Load Balancer 负载均衡器]
    end
    
    subgraph "网络层"
        G[Upstream Hosts 上游主机]
        H[Connection Pool 连接池]
    end
    
    A --> B
    B --> C
    C --> D
    D --> E
    E --> F
    F --> H
    H --> G

// source/exe/main.cc
int main(int argc, char** argv) {
#ifdef WIN32
  Envoy::ServiceBase service;
  if (!Envoy::ServiceBase::TryRunAsService(service)) {
    return Envoy::MainCommon::main(argc, argv);
  }
  return EXIT_SUCCESS;
#endif
  return Envoy::MainCommon::main(argc, argv);
}

sequenceDiagram
    participant M as main()
    participant MC as MainCommon
    participant MCB as MainCommonBase
    participant Server as Server Instance
    participant CM as ClusterManager
    participant LM as ListenerManager
    
    M->>MC: MainCommon::main()
    MC->>MCB: MainCommonBase::run()
    MCB->>Server: create Server Instance
    Server->>CM: initialize ClusterManager
    CM-->>Server: cluster initialization complete
    Server->>LM: initialize ListenerManager
    LM-->>Server: listener initialization complete
    Server-->>MCB: server ready
    MCB-->>MC: start event loop
    MC-->>M: running...

/**
 * 网络连接的基础抽象接口
 */
class Connection : public Event::DeferredDeletable,
                   public FilterManager {
public:
  virtual ~Connection() = default;
  
  /**
   * 添加连接回调处理器
   * @param cb 连接回调处理器
   */
  virtual void addConnectionCallbacks(ConnectionCallbacks& cb) PURE;
  
  /**
   * 关闭连接
   * @param type 连接关闭类型
   */  
  virtual void close(ConnectionCloseType type) PURE;
  
  /**
   * 获取连接的事件分发器
   * @return 事件分发器引用
   */
  virtual Event::Dispatcher& dispatcher() PURE;
  
  /**
   * 获取连接状态
   * @return 当前连接状态
   */
  virtual State state() const PURE;
  
  /**
   * 写入数据到连接
   * @param data 要写入的数据缓冲区
   * @param end_stream 是否结束流
   */
  virtual void write(Buffer::Instance& data, bool end_stream) PURE;
};

/**
 * HTTP流解码器，用于处理接收到的HTTP消息
 */
class StreamDecoder {
public:
  virtual ~StreamDecoder() = default;

  /**
   * 处理接收到的HTTP头部
   * @param headers HTTP请求或响应头部映射
   * @param end_stream 是否为流的结束
   */
  virtual void decodeHeaders(RequestOrResponseHeaderMapPtr&& headers,
                           bool end_stream) PURE;

  /**
   * 处理接收到的HTTP数据
   * @param data HTTP消息体数据
   * @param end_stream 是否为流的结束  
   */
  virtual void decodeData(Buffer::Instance& data, bool end_stream) PURE;

  /**
   * 处理接收到的HTTP尾部
   * @param trailers HTTP尾部头映射
   */
  virtual void decodeTrailers(RequestOrResponseTrailerMapPtr&& trailers) PURE;
};

/**
 * 集群管理器接口，负责管理所有上游服务集群
 */
class ClusterManager {
public:
  virtual ~ClusterManager() = default;

  /**
   * 添加或更新集群配置
   * @param cluster 集群配置  
   * @param version_info 版本信息
   * @return 是否成功添加或更新集群
   */
  virtual absl::StatusOr<bool> addOrUpdateCluster(
      const envoy::config::cluster::v3::Cluster& cluster,
      const std::string& version_info) PURE;

  /**
   * 获取指定名称的活跃集群
   * @param cluster 集群名称
   * @return 集群对象的可选引用
   */
  virtual OptRef<const Cluster> getActiveCluster(const std::string& cluster) const PURE;

  /**
   * 获取线程本地集群对象
   * @param cluster 集群名称  
   * @return 线程本地集群指针
   */
  virtual ThreadLocalCluster* getThreadLocalCluster(absl::string_view cluster) PURE;

  /**
   * 移除指定的集群
   * @param cluster 要移除的集群名称
   * @return 是否成功移除
   */
  virtual bool removeCluster(const std::string& cluster) PURE;
};

# 克隆代码库
git clone https://github.com/envoyproxy/envoy.git
cd envoy

# 使用Docker构建（推荐）
./ci/run_envoy_docker.sh './ci/do_ci.sh bazel.compile_time_options'

# 本地构建
bazel build -c opt //source/exe:envoy-static