大家好，我是烤鴨：

? 網關升級，想使用 springcloud gateway nacos 動態過濾器配置(原來是硬編碼的方式)，升級之后出了一些問題(cpu升高，ygc頻繁)，記錄一下。

關于 springcloud gateway 集成 nacos 可以看這篇。

https://blog.csdn.net/Angry_Mills/article/details/108821602

springcloud gateway 源碼解析、請求響應流程 可以看這篇。

https://blog.csdn.net/Angry_Mills/article/details/109035426

pom

父pom

<dependencyManagement><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>${spring-cloud.version}</version><type>pom</type><scope>import</scope></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-alibaba-dependencies</artifactId><version>${springcloud-alibaba.version}</version><type>pom</type><scope>import</scope></dependency></dependencies></dependencyManagement>

gateway pom

<!--springcloud 組件start --> <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId> </dependency> <!-- nacos組件 --> <dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-config</artifactId> </dependency>

配置文件

springcloud gateway 支持配置文件 filters，RequestBodyAddCache為自定義過濾器，這里注意filters 的編寫順序和實際過濾的順序一樣。

spring:application:name: gatewaycloud:gateway:routes:- id: tick-routefilters:- RequestBodyAddCache- StripPrefix=1predicates:- name: Pathargs[pattern]: /tick/**uri: lb://demo-tick- id: tick-routefilters:- StripPrefix=1predicates:- name: Pathargs[pattern]: /dick/**uri: lb://demo-dicknacos:discovery:server-addr: localhost:8848password: nacosusername: nacos

默認自帶的有哪些過濾器：

常用的像：StripPrefix、RewritePath

還可以傳入參數，會封裝到 config對象里，創建過濾器時使用。

StripPrefix -> StripPrefixGatewayFilterFactory

RewritePath -> RewritePathGatewayFilterFactory

發現一點規律么，只要我們也按照這個方式寫一個工廠就可以，像這樣

RewritePathGatewayFilterFactory

過濾器類

這個過濾器的目的是 獲取請求路徑和請求方式

RequestBodyAddCacheGlobalFilter

package com.maggie.gateway.filter;import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.cloud.gateway.filter.GatewayFilter; import org.springframework.cloud.gateway.filter.GatewayFilterChain; import org.springframework.core.Ordered; import org.springframework.http.HttpMethod; import org.springframework.http.codec.HttpMessageReader; import org.springframework.http.server.reactive.ServerHttpRequest; import org.springframework.web.reactive.function.server.HandlerStrategies; import org.springframework.web.reactive.function.server.ServerRequest; import org.springframework.web.server.ServerWebExchange; import reactor.core.publisher.Mono;import java.util.List;public class RequestBodyAddCacheGlobalFilter implements GatewayFilter, Ordered {private Logger logger = LoggerFactory.getLogger(RequestBodyAddCacheGlobalFilter.class);private final List<HttpMessageReader<?>> messageReaders = HandlerStrategies.withDefaults().messageReaders();@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {ServerHttpRequest serverHttpRequest = exchange.getRequest();ServerRequest serverRequest = ServerRequest.create(exchange, messageReaders);String path = serverHttpRequest.getPath().value();HttpMethod method = serverHttpRequest.getMethod();// 打印請求路徑和請求方式logger.info("filter path : {},method : {}", path, method);return chain.filter(exchange);}@Overridepublic int getOrder() {return 0;}}

RequestBodyAddCacheGatewayFilterFactory

package com.maggie.gateway.filter;import org.springframework.cloud.gateway.filter.GatewayFilter; import org.springframework.cloud.gateway.filter.factory.AbstractGatewayFilterFactory; import org.springframework.stereotype.Component;@Component public class RequestBodyAddCacheGatewayFilterFactory extends AbstractGatewayFilterFactory {@Overridepublic GatewayFilter apply(Object config) {return new RequestBodyAddCacheGlobalFilter();} }

問題(cpu 升高)

但是這種方式升級之后，線上網關的cpu消耗差不多是之前的兩倍。

后來在測試環境壓測發現了問題源頭，artas 查看線程阻塞。

就是 RequestBodyAddCacheGlobalFilter 里的成員變量 messageReaders 阻塞了。

查了下源碼，HandlerStrategies.withDefaults() 的時候 ServerCodecConfigurer codecConfigurer 會初始化Jackson2JsonEncoder ->ClassUtils.forName(“com.fasterxml.jackson.datatype.jdk8.Jdk8Module”) -> Classloader.loadClass() 有鎖

為啥之前沒有問題呢？

原來的 RequestBodyAddCacheGlobalFilter 是@Autowired(單例的)，按照上面的改后變成每次觸發apply方法都會創建一個RequestBodyAddCacheGlobalFilter 對象。

每次創建對象其實也沒有問題，源碼里的工廠類都是new GatewayFilter()。（上面 StripPrefixGatewayFilterFactory 和 RewritePathGatewayFilterFactory 源碼的圖）

還有一個疑問就是 RequestBodyAddCacheGatewayFilterFactory.apply() 方法理論上只會項目啟動調用一次，不會創建多個對象。

其實不管是 eurka 或者 nacos 或者 apollo 會觸發 AbstractApplicationContext.refresh

而nacos（Watch-task 線程） NacosWatch.nacosServicesWatch( this.publisher.publishEvent )

eurka (DiscoveryClient-CacheRefresh 線程) CloudEurekaClient.onCacheRefreshed( this.publisher.publishEvent )

下圖可以看出頻繁訪問并不會觸發apply方法，apply方法是在固定的周期觸發。(觸發次數取決于攔截器配置的次數，比如幾個route配置了這個filter，就會初始化幾次，線上配置這個filter的route比較多，每次都會初始化十幾次，所以cpu變化也比較明顯)

解決方式

跟原來一樣，RequestBodyAddCacheGlobalFilter 采用單例，注入進來就行。不會創建多余的對象。cpu和ygc恢復了。

@Component public class RequestBodyAddCacheGatewayFilterFactory extends AbstractGatewayFilterFactory {@AutowiredRequestBodyAddCacheGlobalFilter requestBodyAddCacheGlobalFilter;@Overridepublic GatewayFilter apply(Object config) {return requestBodyAddCacheGlobalFilter;} }

總結

以上是生活随笔為你收集整理的springcloud gateway 使用nacos 动态过滤器 记一次线上网关升级cpu升高的问题的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。