Reactor Netty HttpClient 请求解析过程详解

0x00 概述

Reactor Netty HttpClient 是 Reactor Netty 框架提供的异步 HTTP 客户端库，基于 Reactor 框架，采用响应式编程模型，支持非阻塞方式执行 HTTP 请求和处理响应。

基本使用示例

HttpClient httpClient = HttpClient.create().wiretap(true);
httpClient.get()
    .uri(target)
    .responseContent()
    .aggregate()
    .asString()
    .doOnSuccess(s -> {
        System.out.println("s1=" + s);
    })
    .block();

方法链说明：

1. httpClient.get().uri(target) - 创建GET请求并指定URL
2. .responseContent() - 获取响应内容Flux
3. .aggregate() - 整合分块的响应内容
4. .asString() - 将ByteBuf解码为字符串
5. doOnSuccess() - 注册成功回调
6. .block() - 阻塞等待响应完成

0x01 请求解析过程分析

1. UriEndpoint创建

核心类：MonoHttpConnect 表示异步HTTP请求

1. 实例化HttpClientConnect
2. 调用uriEndpointFactory.createUriEndpoint创建UriEndpoint
   • 封装URI信息（协议、主机名、端口号、路径等）
   • 使用正则匹配解析URI

2. 组件创建与配置

1. 调用resolverInternal获取地址解析器组

   • 将主机名解析为IP地址
   • 实际调用父类ClientTransportConfig的方法

2. 创建关键组件：

   • ConnectionProvider - 管理连接池
     • 硬编码name为"http"
   • PooledConnectionProvider - 连接池实现

3. 连接获取

调用_config.httpConnectionProvider().acquire从连接池获取可用连接

PooledConnectionProvider.acquire方法：

• 提供连接池管理功能
• 获取或创建新连接
• 连接池name来自Builder硬编码值，而非请求的schema

4. 请求处理特点

1. 不严格校验schema：

   • 可以接受任意符合正则的schema
   • 即使schema非http/https也能正常请求
   • 支持包含下划线的schema（如anyt____hing）

2. 示例验证：

   • 正常请求：http://127.0.0.1:8080/health
   • 任意schema请求：anything://127.0.0.1:8080/health 同样有效

0x02 WebClient相关分析

基本使用

WebClient webClient = WebClient.builder().build();
String response = webClient.get()
    .uri(url)
    .retrieve()
    .bodyToMono(String.class)
    .block();

实现依赖

spring-boot-starter-webflux基于reactor-netty-http实现

URI处理过程

1. UriComponentsBuilder.fromUriString处理目标URL

   • 使用正则匹配
   • 未匹配时抛出IllegalArgumentException
   • 对scheme和host进行基本合法性检查
     • 但不强制校验必须是http/https

2. 同样支持任意schema的请求

   • 示例：anything://127.0.0.1:8080/health 可正常解析和返回

安全注意事项

1. 潜在风险：

   • 可构造任意协议的"畸形"请求
   • 可能绕过某些SSRF防护措施

2. 开发建议：

   • 避免将未经验证的数据传递给HttpClient
   • 实现额外的schema校验层
   • 注意SSRF防护措施的有效性

总结

Reactor Netty HttpClient的请求解析过程具有以下特点：

1. 基于正则的URI解析，不严格限制schema
2. 连接池管理独立于请求schema
3. 与WebClient共享相同底层实现
4. 灵活的设计可能带来安全风险，需注意防护