我使用spring网关implementation "org.springframework.cloud:spring-cloud-starter-gateway"作为我的项目网关,在application.properties中定义过滤器,如下所示:
spring.cloud.gateway.default-filters=JwtAuthenticationFilterGatewayFilterFactory我的网关过滤器代码如下所示:
@Component
public class JwtAuthenticationFilterGatewayFilterFactory implements GatewayFilter {
@Value("${dolphin.gateway.jwt.verify:true}")
private boolean jwtVerfiy;
final static List<String> apiEndpoints = List.of("/register", "/login");
final static Predicate<ServerHttpRequest> isApiSecured = r -> apiEndpoints.stream()
.noneMatch(uri -> r.getURI().getPath().contains(uri));
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
return chain.filter(exchange);
}
}当我启动项目时,日志输出显示如下错误:
021-09-19 22:51:42.480 ERROR 1 --- [oundedElastic-7] r.c.s.Schedulers : Scheduler worker in group main failed with an uncaught exception
reactor.core.Exceptions$ErrorCallbackNotImplemented: java.lang.IllegalArgumentException: Unable to find GatewayFilterFactory with name JwtAuthenticationFilterGatewayFilterFactory
Caused by: java.lang.IllegalArgumentException: Unable to find GatewayFilterFactory with name JwtAuthenticationFilterGatewayFilterFactory
at org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator.loadGatewayFilters(RouteDefinitionRouteLocator.java:187) ~[spring-cloud-gateway-server-2.2.8.RELEASE.jar!/:2.2.8.RELEASE]
at org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator.getFilters(RouteDefinitionRouteLocator.java:228) ~[spring-cloud-gateway-server-2.2.8.RELEASE.jar!/:2.2.8.RELEASE]
at org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator.convertToRoute(RouteDefinitionRouteLocator.java:170) ~[spring-cloud-gateway-server-2.2.8.RELEASE.jar!/:2.2.8.RELEASE]
at org.springframework.cloud.gateway.route.RouteDefinitionRouteLocator$$Lambda$924/0x0000000069f16e40.apply(Unknown Source) ~[?:?]
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:100) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxFlatMap$FlatMapMain.tryEmitScalar(FluxFlatMap.java:481) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxFlatMap$FlatMapMain.onNext(FluxFlatMap.java:414) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.drain(FluxMergeSequential.java:425) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxMergeSequential$MergeSequentialMain.innerNext(FluxMergeSequential.java:297) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxMergeSequential$MergeSequentialInner.onNext(FluxMergeSequential.java:563) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxMap$MapSubscriber.onNext(FluxMap.java:114) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxFilter$FilterSubscriber.onNext(FluxFilter.java:107) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]
at reactor.core.publisher.FluxMap$MapConditionalSubscriber.onNext(FluxMap.java:213) ~[reactor-core-3.3.16.RELEASE.jar!/:3.3.16.RELEASE]我曾尝试使用JwtAuthenticationFilterGatewayFilterFactory和JwtAuthenticationFilter调整过滤器名称,两者都抛出了相同的错误。我哪里错了?我应该怎么做才能解决这个问题?
发布于 2021-09-21 09:57:41
如果实现GatewayFilter,则应按如下方式注册过滤器:
@Bean
public RouteLocator myRoutes(RouteLocatorBuilder builder) {
return builder.routes()
.route(p -> p
.path("/get")
.filters(f -> f.addRequestHeader("Hello", "World"))
.uri("http://httpbin.org:80"))
.build();
}您不能使用application.yaml或application.properties配置自定义网关筛选器。如果您想在application.yaml或application.properties中进行配置,则需要实现GatewayFilterFactory。
https://stackoverflow.com/questions/69244460
复制相似问题