所以我是 Spring Cloud Gateway 的新手，剛剛開(kāi)始使用它。我正在瀏覽文檔并偶然發(fā)現(xiàn)如何創(chuàng)建自定義過(guò)濾器。https://cloud.spring.io/spring-cloud-gateway/reference/html/#developer-guide這是我創(chuàng)建自定義過(guò)濾器的代碼 - @Component public class CustomPreFilterFactory extends AbstractGatewayFilterFactory<CustomPreFilterFactory.Config> { public static class Config { //Put the configuration properties for your filter here } @Override public GatewayFilter apply(Config config) { return (exchange,chain) ->{ ServerHttpRequest.Builder builder = exchange.getRequest().mutate(); System.out.println("Request came in custom pre filter"); return chain.filter(exchange.mutate().request(builder.build()).build()); }; } }現(xiàn)在，我使用網(wǎng)關(guān)提供的java路由api來(lái)配置我的路由，所以這是我的路由代碼 - @Bean public RouteLocator myRoutes(RouteLocatorBuilder routeLocatorBuilder) { return routeLocatorBuilder.routes() .route( p -> p.path("/hello").uri("http://localhost:8081")) .build();}現(xiàn)在，我想知道如何以編程方式將我剛剛創(chuàng)建的自定義過(guò)濾器工廠添加到上面定義的路由中。我查看了以下示例，其中他們注冊(cè)了自定義過(guò)濾器工廠 - 1. https://www.javainuse.com/spring/cloud-filter 2. https://medium.com/@niral22/spring-cloud-gateway-tutorial-5311ddd59816它們都使用屬性而不是使用路由 api 創(chuàng)建路由。任何幫助深表感謝。
3 回答
翻閱古今
TA貢獻(xiàn)1780條經(jīng)驗(yàn) 獲得超5個(gè)贊
這個(gè)解決方案對(duì)我有用，我使用注入的 CustomGatewayFilterFactory 創(chuàng)建了一個(gè) OrderedGatewayFilter ，如下所示，并將該過(guò)濾器添加到路由中：
@Bean
public RouteLocator myRoutes(RouteLocatorBuilder routeLocatorBuilder, CustomGatewayFilterFactory customGatewayFilterFactory)
{
OrderedGatewayFilter orderedGatewayFilter =
new OrderedGatewayFilter(customGatewayFilterFactory.apply(config), 45);
return routeLocatorBuilder.routes()
.route( p -> p.path("/hello").uri("http://localhost:8081").filter(orderedGatewayFilter))
.build();
}
飲歌長(zhǎng)嘯
TA貢獻(xiàn)1951條經(jīng)驗(yàn) 獲得超3個(gè)贊
下面是一個(gè)路由示例，該路由定義了一個(gè)謂詞來(lái)匹配所有帶有 /api/v1/first/** 的請(qǐng)求 URL，并應(yīng)用預(yù)過(guò)濾器來(lái)重寫(xiě)路徑。還有另一個(gè)過(guò)濾器用于修改請(qǐng)求標(biāo)頭，然后將請(qǐng)求路由到負(fù)載平衡的 FIRST-SERVICE。
builder.routes()
.route(r -> r.path("/api/v1/first/**")
.filters(f -> f.rewritePath("/api/v1/first/(?.*)", "/${remains}")
.addRequestHeader("X-first-Header", "first-service-header")
)
.uri("lb://FIRST-SERVICE/") //downstream endpoint lb - load balanced
.id("queue-service"))
.build();
下面是等效的 .yaml 配置。
spring:
cloud:
gateway:
routes:
- id: first-service
uri: lb://FIRST-SERVICE
predicates:
- Path=/api/v1/first/**
filters:
- RewritePath=/api/v1/first/(?.*), /$\{remains}
- AddRequestHeader=X-first-Header, first-service-header
您可以在此鏈接中找到更多此類(lèi)過(guò)濾器。
希望這就是您正在尋找的。
海綿寶寶撒
TA貢獻(xiàn)1809條經(jīng)驗(yàn) 獲得超8個(gè)贊
您需要注入自定義過(guò)濾器并將其包含在路由中。像這樣的東西..
@Bean
public RouteLocator myRoutes(RouteLocatorBuilder routeLocatorBuilder, CustomPreFilterFactory cpf)
{
return routeLocatorBuilder.routes()
.route( p -> p.path("/hello").filters(f -> f.filter(myCustomFilter.apply(new Config()))).uri("http://localhost:8081"))
.build();
}
添加回答
舉報(bào)
0/150
提交
取消