我们在gateway服务中，创建一个拦截器；在拦截器中，向后续服务传递自定义header头信息。
拦截器定义如下：
@Configuration
public class TestGlobalFilter implements GlobalFilter, Ordered {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
// .....
// 封装需要向后续封装的header对象
LinkedHashMap<String, String> headerMap = new LinkedHashMap<>();
headerMap.put("header1", "1");
headerMap.put("header2", "2");
headerMap.put("header3", "3");
chainFilterAndSetHeaders(chain, exchange, headerMap);
// .....
//调用chain.filter继续向下游执行
return chain.filter(exchange);
}
/**
* 顺序,数值越小,优先级越高
*
* @return
*/
@Override
public int getOrder() {
return 1;
}
/**
* 设置向后传递的header
*
* @param chain
* @param exchange
* @param headerMap
*/
private Mono<Void> chainFilterAndSetHeaders(GatewayFilterChain chain, ServerWebExchange exchange, LinkedHashMap<String, String> headerMap) {
// 添加header
Consumer<HttpHeaders> httpHeaders = httpHeader -> {
for (Map.Entry<String, String> entry : headerMap.entrySet()) {
// 遍历Map设置header，向后传递
httpHeader.set(entry.getKey(), entry.getValue());
}
};
ServerHttpRequest newRequest = exchange.getRequest().mutate().headers(httpHeaders).build();
ServerWebExchange build = exchange.mutate().request(newRequest).build();
//将现在的request 变成 exchange对象
return chain.filter(build);
}
}
应用：
在下游服务的拦截器中，可以通过request.getHeader()获取从gateway中获取加入的header。
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之家整理，本文链接：https://www.bmabk.com/index.php/post/18051.html
