通过 WebFlux 中的过滤器向传出请求添加标头

Jae*_*Lee 6 java spring spring-webflux

我在客户端和服务器上使用 Java Spring WebFlux,我想通过向它添加自定义标头来自定义从客户端到服务器的请求。我已经将 WebFilter 用于其他目的,但它似乎只适用于传入的请求和响应(例如来自 FE 的请求和对它的响应)。

Ily*_*ich 8

有多种方法可以指定自定义标头。

如果标头是静态的,您可以在WebClient实例创建期间使用defaultHeaderdefaultHeaders方法指定它们:

WebClient.builder().defaultHeader("headerName", "headerValue")
WebClient.builder().defaultHeaders(headers -> headers.add("h1", "hv1").add("h2", "hv2"))
Run Code Online (Sandbox Code Playgroud)

如果标头是动态的,但标头值生成对于所有请求都是通用的,您可以ExchangeFilterFunction.ofRequestProcessorWebClient实例创建期间使用配置:

WebClient
    .builder()
    .filter(ExchangeFilterFunction.ofRequestProcessor(
        request -> Mono.just(ClientRequest.from(request)
                                          .header("X-HEADER-NAME", "value")
                                          .build())
    )
    .build();
Run Code Online (Sandbox Code Playgroud)

如果标头是动态的并且每次使用时都是特定的WebClient,您可以为每次调用配置标头:

webClient.get()
    .header("headerName", getHeaderValue(params))
    .retrieve();
Run Code Online (Sandbox Code Playgroud)