GOU*_*HTA 9 java spring spring-boot spring-cloud-netflix api-gateway
我有一个自定义网关过滤器MYGatewayFilter.java文件现在我想使用这个网关过滤器与我在application.yml中编写的路由
spring:
cloud:
gateway:
routes:
- id: login2_route
uri: http://127.0.0.1:8083/login
predicates:
- Path: /login/
filters:
Run Code Online (Sandbox Code Playgroud)
如何为上述路线定义过滤器
自定义筛选MyGatewayFilter.java
public class MyGatewayFilter implements GatewayFilter {
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
ServerHttpRequest request;
if(request.getHeaders().get("x-mydata")!=null){
request= exchange.getRequest().mutate().header("my-new-header",request.getHeaders().get("x-mydata").get(0)).build();
}
return chain.filter(exchange.mutate().request(request).build());
}
}
Run Code Online (Sandbox Code Playgroud)
dev*_*evo 14
您应该实现GatewayFilterFactory,而不是实现GatewayFilter
并使其成为一个组件:
@Component
public class MyGatewayFilter implements GatewayFilterFactory {
Run Code Online (Sandbox Code Playgroud)
然后,您可以通过路径中的bean名称来引用它.
filters:
- MyGatewayFilter
Run Code Online (Sandbox Code Playgroud)
目前关于此的文档并不是很好.我只能通过查看github上spring-cloud-gateway的源代码来解决这个问题
你需要实施GatewayFilterFactory
@Component
public class DemoGatewayFilter implements GatewayFilterFactory<DemoGatewayFilter.Config> {
@Override
public GatewayFilter apply(Config config) {
return (exchange, chain) -> {
System.out.println("gateway filter name "+config.getName());
return chain.filter(exchange);
};
}
@Override
public Config newConfig() {
return new Config("DemoGatewayFilter");
}
public static class Config {
public Config(String name){
this.name = name;
}
private String name;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
}
Run Code Online (Sandbox Code Playgroud)
并在 application.yml 文件中
spring:
application:
cloud:
gateway:
routes:
- id: MayApplication
uri: http://myapplication:8080
predicates:
- Path=/apipath/to/filter/**
filters:
- DemoGatewayFilter
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
5652 次 |
| 最近记录: |