Zuul迁移至Spring Cloud Gateway踩坑记录
创始人
2024-02-29 18:50:02
0

缘起

Zuul1.x已经不维护了,并且使用的BIO,当流量较大时性能下降的厉害,并且线程池中的线程用尽时如果某个请求返回了非200并且你没有配置处理过滤器的话,这个线程就假死了。公司的代码扫描工具也提示Zuul1.0里面有很多的jar已经过时了。Zuul2.x虽然修改BIO为NIO,但社区不活跃,没有和Spring兼容,性能也没有预期的好。Spring Cloud社区实现了自己的Gateway就是Spring Cloud Gateway,这里记录一下从Zuul1.x迁移到Spring Cloud Gateway 3.x的坑点。

踩坑

坑点1. java.lang.NoClassDefFoundError: org/springframework/core/metrics/ApplicationStartup

  • 日志输出:
Exception in thread "main" java.lang.NoClassDefFoundError: org/springframework/core/metrics/ApplicationStartupat org.springframework.boot.SpringApplication.(SpringApplication.java:232)at org.springframework.boot.SpringApplication.(SpringApplication.java:245)at org.springframework.boot.SpringApplication.run(SpringApplication.java:1317)at org.springframework.boot.SpringApplication.run(SpringApplication.java:1306)at com.example.gateway.GatewayApplication.main(GatewayApplication.java:12)
  • 原因:netty本身版本不统一,netty和reactor版本不统一导致,因为我使用的是公司统一的父pom,并不是直接依赖的spring-boot-parent。 我测试过,使用spring-boot-parent 可以正常启动,无此错误
  • 解决方案:引入bom(请替换成你自己的版本号):
org.springframeworkspring-framework-bom${spring-framework.version}pomimport

io.nettynetty-bom${netty.version}pomimport

坑点2 java.lang.ClassNotFoundException: javax.servlet.Filter

  • 日志输出:
Caused by: java.lang.NoClassDefFoundError: javax/servlet/Filterat java.lang.ClassLoader.defineClass1(Native Method)at java.lang.ClassLoader.defineClass(ClassLoader.java:763)at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)at java.net.URLClassLoader.access$100(URLClassLoader.java:73)at java.net.URLClassLoader$1.run(URLClassLoader.java:368)at java.net.URLClassLoader$1.run(URLClassLoader.java:362)at java.security.AccessController.doPrivileged(Native Method)at java.net.URLClassLoader.findClass(URLClassLoader.java:361)at java.lang.ClassLoader.loadClass(ClassLoader.java:424)at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)at java.lang.ClassLoader.loadClass(ClassLoader.java:357)at java.lang.ClassLoader.defineClass1(Native Method)at java.lang.ClassLoader.defineClass(ClassLoader.java:763)at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)at java.net.URLClassLoader.access$100(URLClassLoader.java:73)at java.net.URLClassLoader$1.run(URLClassLoader.java:368)at java.net.URLClassLoader$1.run(URLClassLoader.java:362)at java.security.AccessController.doPrivileged(Native Method)at java.net.URLClassLoader.findClass(URLClassLoader.java:361)at java.lang.ClassLoader.loadClass(ClassLoader.java:424)at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)at java.lang.ClassLoader.loadClass(ClassLoader.java:357)at java.lang.ClassLoader.defineClass1(Native Method)at java.lang.ClassLoader.defineClass(ClassLoader.java:763)at java.security.SecureClassLoader.defineClass(SecureClassLoader.java:142)at java.net.URLClassLoader.defineClass(URLClassLoader.java:467)at java.net.URLClassLoader.access$100(URLClassLoader.java:73)at java.net.URLClassLoader$1.run(URLClassLoader.java:368)at java.net.URLClassLoader$1.run(URLClassLoader.java:362)at java.security.AccessController.doPrivileged(Native Method)at java.net.URLClassLoader.findClass(URLClassLoader.java:361)at java.lang.ClassLoader.loadClass(ClassLoader.java:424)at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)at java.lang.ClassLoader.loadClass(ClassLoader.java:357)at java.lang.Class.getDeclaredMethods0(Native Method)at java.lang.Class.privateGetDeclaredMethods(Class.java:2701)at java.lang.Class.getDeclaredMethods(Class.java:1975)at org.springframework.util.ReflectionUtils.getDeclaredMethods(ReflectionUtils.java:467)... 21 common frames omitted
Caused by: java.lang.ClassNotFoundException: javax.servlet.Filterat java.net.URLClassLoader.findClass(URLClassLoader.java:381)at java.lang.ClassLoader.loadClass(ClassLoader.java:424)at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335)at java.lang.ClassLoader.loadClass(ClassLoader.java:357)... 61 common frames omitted
  • 原因:这个应该是Spring Cloud Gateway使用的是Spring Webflux而非Spring Web,导致javax包没有引入
  • 解决方案:引入以下jar包
javax.servletjavax.servlet-api${your-version}

坑点3 server.servlet.contextPath不生效问题

  • 原因:Spring Cloud Gateway使用的是Spring Webflux,不是Spring Web,所以Spring Web的配置它无法解析
  • 解决方案
    • 方案1. 添加配置:
    spring:webflux:base-dir: /xxx
    
    • 方案2. 配置routor转发
    spring:cloud:gateway:routes:- id: selfuri: http://localhost:8080predicates:- Path=/xxx/**filters:# StripPrefix=1:去除原始请求路径中的前1级路径,去除2级的话StripPrefix=2- StripPrefix=1
    
    • 方案3. 配置默认filter:
     spring:cloud:gateway:default-filters:- StripPrefix=1
    

坑点4. spring.cloud.gateway.routes[0].uri带path无效

  • 问题描述,配置如下(当前服务配置了spring.webflux.base-dir=/xxx):
spring:cloud:gateway:routes:- id: routeUseruri: http://192.168.1.1:8081/dev/yyypredicates:- Path=/xxx/user/**filters:# StripPrefix:去除原始请求路径中的前1级路径- StripPrefix=1

当使用post请求localhost:8080/xxx/user/getAllUser时,发现转发出去的是http://192.168.1.1:8081/getAllUser,而不是我期望的http://192.168.1.1:8081/dev/yyy/getAllUser
这种配置看着比较反常,其实在k8s容器中使用Ingress互相通讯时比较常见,里面的ip大多都是某个内部域名。

  • 原因:转发前会重新拼装新的url,这个拼装逻辑在org.springframework.cloud.gateway.filter.RouteToRequestUrlFilter#filter,其中代码如下:
 Route route = (Route)exchange.getAttribute(ServerWebExchangeUtils.GATEWAY_ROUTE_ATTR);if (route == null) {return chain.filter(exchange);} else {log.trace("RouteToRequestUrlFilter start");URI uri = exchange.getRequest().getURI();boolean encoded = ServerWebExchangeUtils.containsEncodedParts(uri);URI routeUri = route.getUri();if (hasAnotherScheme(routeUri)) {exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_SCHEME_PREFIX_ATTR, routeUri.getScheme());routeUri = URI.create(routeUri.getSchemeSpecificPart());}if ("lb".equalsIgnoreCase(routeUri.getScheme()) && routeUri.getHost() == null) {throw new IllegalStateException("Invalid host: " + routeUri.toString());} else {URI mergedUrl = UriComponentsBuilder.fromUri(uri).scheme(routeUri.getScheme()).host(routeUri.getHost()).port(routeUri.getPort()).build(encoded).toUri();exchange.getAttributes().put(ServerWebExchangeUtils.GATEWAY_REQUEST_URL_ATTR, mergedUrl);return chain.filter(exchange);}}

我们单挑这一句URI mergedUrl = UriComponentsBuilder.fromUri(uri).scheme(routeUri.getScheme()).host(routeUri.getHost()).port(routeUri.getPort()).build(encoded).toUri();来看,其实它只帮你拼装了你的scheme(协议,如http),host(域名或者ip),port(端口号),并没有你配置的path

  • 解决方案:
spring:cloud:gateway:routes:- id: routeUseruri: http://192.168.1.1:8081/dev/yyypredicates:- Path=/xxx/user/**filters:# StripPrefix:去除原始请求路径中的前1级路径- StripPrefix=1# 对于/xxx/user开头的url转发时拼装新的url的path前都添加一个/dev/yyy前缀# 也可以进行rewritePath,不过不如当前方案简洁- PrefixPath=/dev/yyy

坑点5 自定义全局过滤器获取的requestPath非原始的requestPath

  • 问题描述:我的项目有在gateway中做登录校验,但有一些需要不需要登录就可以访问的url会在校验前进行验证白名单,判断这些url我使用的是exchange.getRequest().getURI().getPath(),因为坑点4的配置,当我请求localhost:8080/xxx/user/login我拿到的path为/dev/yyyy/login,而我期望的是拿到/xxx/user/login
  • 原因:routeUser中的filter走完后,请求path就已经改完了,我的全局过滤器是在route之后的
  • 解决方案:
LinkedHashSet uriLinkedHashSet  = (LinkedHashSet)exchange.getAttributes().get(ServerWebExchangeUtils.GATEWAY_ORIGINAL_REQUEST_URL_ATTR);
String requestUrlPath = uriLinkedHashSet.iterator().next().getPath();

exchange.getAttributes()中的ServerWebExchangeUtils.GATEWAY_ORIGINAL_REQUEST_URL_ATTR存放了原始的path,直接取出即可。

相关内容

热门资讯

喜欢穿一身黑的男生性格(喜欢穿... 今天百科达人给各位分享喜欢穿一身黑的男生性格的知识,其中也会对喜欢穿一身黑衣服的男人人好相处吗进行解...
发春是什么意思(思春和发春是什... 本篇文章极速百科给大家谈谈发春是什么意思,以及思春和发春是什么意思对应的知识点,希望对各位有所帮助,...
网络用语zl是什么意思(zl是... 今天给各位分享网络用语zl是什么意思的知识,其中也会对zl是啥意思是什么网络用语进行解释,如果能碰巧...
为什么酷狗音乐自己唱的歌不能下... 本篇文章极速百科小编给大家谈谈为什么酷狗音乐自己唱的歌不能下载到本地?,以及为什么酷狗下载的歌曲不是...
家里可以做假山养金鱼吗(假山能... 今天百科达人给各位分享家里可以做假山养金鱼吗的知识,其中也会对假山能放鱼缸里吗进行解释,如果能碰巧解...
华为下载未安装的文件去哪找(华... 今天百科达人给各位分享华为下载未安装的文件去哪找的知识,其中也会对华为下载未安装的文件去哪找到进行解...
四分五裂是什么生肖什么动物(四... 本篇文章极速百科小编给大家谈谈四分五裂是什么生肖什么动物,以及四分五裂打一生肖是什么对应的知识点,希...
怎么往应用助手里添加应用(应用... 今天百科达人给各位分享怎么往应用助手里添加应用的知识,其中也会对应用助手怎么添加微信进行解释,如果能...
苏州离哪个飞机场近(苏州离哪个... 本篇文章极速百科小编给大家谈谈苏州离哪个飞机场近,以及苏州离哪个飞机场近点对应的知识点,希望对各位有...
客厅放八骏马摆件可以吗(家里摆... 今天给各位分享客厅放八骏马摆件可以吗的知识,其中也会对家里摆八骏马摆件好吗进行解释,如果能碰巧解决你...