Webflux WebClient能否配置两套过滤器链及条件请求头？

1. 能否使用两套不同的过滤器链？ #

完全可以。WebClient的过滤器链是绑定在WebClient实例上的，你可以通过WebClient.Builder创建多个独立的WebClient实例，每个实例配置专属的ExchangeFilterFunction集合，以此实现多套完全独立的过滤器链。

举个简单示例：

// 第一套过滤器链：日志+基础认证
WebClient webClientWithAuth = WebClient.builder()
    .filter(ExchangeFilterFunction.ofRequestProcessor(request -> {
        // 日志处理逻辑
        System.out.println("Request URI: " + request.url());
        return Mono.just(request);
    }))
    .filter(ExchangeFilterFunction.ofRequestProcessor(request -> {
        // 添加基础认证头
        ClientRequest authenticatedRequest = ClientRequest.from(request)
            .header(HttpHeaders.AUTHORIZATION, "Basic dXNlcjpwYXNzd29yZA==")
            .build();
        return Mono.just(authenticatedRequest);
    }))
    .build();

// 第二套过滤器链：仅请求重试
WebClient webClientWithRetry = WebClient.builder()
    .filter(RetryExchangeFilterFunction.builder()
        .retryOnServerError()
        .maxRetries(2)
        .build())
    .build();

两个WebClient实例各自使用独立的过滤器链，互不干扰。

2. 按条件添加请求头的实现 #

针对你的POST请求场景，只需在构建请求时，根据上游request的头信息做条件判断即可。假设你要检查的特定头是X-Upstream-Special，存在时添加额外头X-Custom-Header-1和X-Custom-Header-2，否则走默认流程。

修改你的代码如下：

// 先获取上游请求的头信息
HttpHeaders upstreamHeaders = request.headers();

// 构建WebClient请求
webClient.post()
    .uri(request.destination())
    // 默认头
    .header("X-Default-Header-1", "default-value-1")
    .header("X-Default-Header-2", "default-value-2")
    // 条件添加额外头+复制上游头
    .headers(headers -> {
        headers.addAll(upstreamHeaders);
        if (upstreamHeaders.containsKey("X-Upstream-Special")) {
            headers.add("X-Custom-Header-1", "special-value-1");
            headers.add("X-Custom-Header-2", "special-value-2");
        }
    })
    .body(BodyInserters.fromValue(request.data()))
    .retrieve()
    .bodyToMono(YourResponseType.class);

如果需要更清晰的逻辑拆分，也可以单独处理条件判断：

ClientRequest.Builder requestBuilder = ClientRequest.create(HttpMethod.POST, URI.create(request.destination()))
    // 默认头
    .header("X-Default-Header-1", "default-value-1")
    .header("X-Default-Header-2", "default-value-2")
    // 复制上游头
    .headers(headers -> headers.addAll(request.headers()))
    .body(BodyInserters.fromValue(request.data()));

// 条件添加额外头
if (request.headers().containsKey("X-Upstream-Special")) {
    requestBuilder.header("X-Custom-Header-1", "special-value-1")
                  .header("X-Custom-Header-2", "special-value-2");
}

// 发送请求
webClient.execute(requestBuilder.build())
    .retrieve()
    .bodyToMono(YourResponseType.class);

内容的提问来源于stack exchange，提问作者Sarthak Sinha