Как добавить собственный заголовок в Spring WebFilter?

Если вы используете облачный шлюз Spring, заголовок запроса может быть изменен с помощью реализации GlobalFilter или GatewayFilter.

    @Component 
    public class LogFilter implements GlobalFilter, Ordered {

    private Logger LOG = LoggerFactory.getLogger(LogFilter.class);

    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {

        return chain.filter(
                exchange.mutate().request(
                        exchange.getRequest().mutate()
                                .header("customer-header", "customer-header-value")
                                .build())
                        .build());
    }

    @Override
    public int getOrder() {
        return 0;
    } }

Если вы находитесь в ZuulFilter, addZuulRequestHeader может изменить заголовок запроса.

    RequestContext.getCurrentContext().addZuulRequestHeader("customer-header", "customer-header-value");

Надеюсь, это полезно.

Я думаю, что исключение выбрасывается из соображений безопасности. Было бы неприятно, если бы фильтр мог добавлять/изменять заголовки HTTP-запросов. Конечно, вы можете добиться этого, создав серию декораторов:

import org.springframework.http.HttpHeaders;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpRequestDecorator;
import org.springframework.util.MultiValueMap;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.ServerWebExchangeDecorator;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono;

    public class CustomFilter implements WebFilter {

    public Mono<Void> filter(ServerWebExchange serverWebExchange, WebFilterChain webFilterChain) {

            ServerWebExchangeDecorator decorator = new ServerWebExchangeDecoratorImpl(serverWebExchange);

            //do your stuff using decorator 

            return webFilterChain.filter(decorator);
        }
    }


    class ServerWebExchangeDecoratorImpl extends ServerWebExchangeDecorator {

        private ServerHttpRequestDecorator requestDecorator;

        public ServerWebExchangeDecoratorImpl(ServerWebExchange delegate) {
            super(delegate);
            this.requestDecorator = new ServerHttpRequestDecoratorImpl(delegate.getRequest());
        }

        @Override
        public ServerHttpRequest getRequest() {
            return requestDecorator;
        }

    }

    class ServerHttpRequestDecoratorImpl extends  ServerHttpRequestDecorator {

        // your own query params implementation
        private MultiValueMap queryParams;

        public ServerHttpRequestDecoratorImpl(ServerHttpRequest request) {
            super(request);
            this.queryParams = new HttpHeaders();
            this.queryParams.addAll(request.getQueryParams());
        }

        @Override
        public MultiValueMap<String, String> getQueryParams() {
            return queryParams;
        }

        //override other methods if you want to modify the behavior
    }

У меня та же проблема, потому что заголовки уже имеют один и тот же ключ; Мое решение - установить ключ в заголовке, сначала проверить, существует ли ключ;

@Configuration
public class AuthGatewayFilter implements GlobalFilter, Ordered {
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        Consumer<HttpHeaders> httpHeaders = httpHeader -> {
            // check exists
            if(StringUtils.isBlank(httpHeader.getFirst("xxx"))){
                httpHeader.add("xxx", "xxx");
            }
        };
        ServerHttpRequest serverHttpRequest = exchange.getRequest().mutate().headers(httpHeaders).build();
        exchange = exchange.mutate().request(serverHttpRequest).build();

        return chain.filter(exchange);
    }

}