spring cloud gateway全局过滤器实现向request header中放数据

exchange.getRequest().getHeaders().set();

@Component

public class AuthSignatureFilter implements GlobalFilter, Ordered {

     static Logger logger = LoggerFactory.getLogger(AuthSignatureFilter. class );

     /**

      * 全局过滤器 核心方法

      * @param exchange

      * @param chain

      * @return

      */

     @Override

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

         logger.info( "request = {}" ,JSONArray.toJSONString( exchange.getRequest()) );

         String token = exchange.getRequest().getQueryParams().getFirst( "authToken" );

         //向headers中放文件，记得build

         ServerHttpRequest host = exchange.getRequest().mutate().header( "a" , "888" ).build();

         //将现在的request 变成 change对象

         ServerWebExchange build = exchange.mutate().request(host).build();

         return chain.filter(build);

     }

     @Override

     public int getOrder() {

         return - 200 ;

     }

}

Consumer<HttpHeaders> httpHeaders = httpHeader -> {

            httpHeader.set( "aaaa" , "bbb" );

            httpHeader.set( "xxx" , "cc" );

            httpHeader.set( "bbxx" , "bbbx" );

            httpHeader.set( "aaaa" , "bbb" );

        };

        ServerHttpRequest serverHttpRequest = exchange.getRequest().mutate().headers(httpHeaders).build();

        exchange.mutate().request(serverHttpRequest).build();