springcloud 中 zuul 修改请求参数信息的方法
Zuul是Netflix出品的一个基于JVM路由和服务端的负载均衡器.
Zuul功能:
- 认证
- 压力测试
- 金丝雀测试
- 动态路由
- 负载削减
- 安全
- 静态响应处理
- 主动/主动交换管理
Zuul的规则引擎允许通过任何JVM语言来编写规则和过滤器,支持基于Java和Groovy的构建。
配置属性zuul.max.host.connections已经被两个新的配置属性替代,zuul.host.maxTotalConnections(总连接数)和zuul.host.maxPerRouteConnections,(每个路由连接数)默认值分别是200和20.
一.为什么要用到这个
在基于springcloud构建的微服务系统中,通常使用网关zuul来进行一些用户验证等过滤的操作,比如用户在header或者url参数中存放了token,网关层需要用该token查出用户的userId,并存放于request中,以便后续微服务可以直接使用而避免再去用token查询。
二.基础知识
在zuul中最大的用法的除了路由之外,就是过滤器了,自定义过滤器需实现接口ZuulFilter,在run()方法中,可以用
RequestContextctx=RequestContext.getCurrentContext(); HttpServletRequestrequest=ctx.getRequest();
获取到request,但是在request中只有getParameter()而没有setParameter()方法,所以直接修改url参数不可行,另外在reqeust中可以虽然可以使用setAttribute(),但是可能由于作用域的不同,在这里设置的attribute在后续的微服务中是获取不到的,因此必须考虑另外的方式。
三.具体做法
最后确定的可行的方法是,用
ctx.setRequest(newHttpServletRequestWrapper(request){})
的方式,重新构造上下文中的request,代码如下:
importjavax.servlet.http.HttpServletRequestWrapper; //在json参数中添加userId try{ InputStreamin=ctx.getRequest().getInputStream(); Stringbody=StreamUtils.copyToString(in,Charset.forName("UTF-8")); System.out.println("body:"+body); JSONObjectjson=JSONObject.fromObject(body); json.put("userId",userId); StringnewBody=json.toString(); System.out.println("newBody:"+newBody); finalbyte[]reqBodyBytes=newBody.getBytes(); ctx.setRequest(newHttpServletRequestWrapper(request){ @Override publicServletInputStreamgetInputStream()throwsIOException{ returnnewServletInputStreamWrapper(reqBodyBytes); } @Override publicintgetContentLength(){ returnreqBodyBytes.length; } @Override publiclonggetContentLengthLong(){ returnreqBodyBytes.length; } }); }catch(IOExceptione){ e.printStackTrace(); }
思路就是,获取请求的输入流,并重写,即重写json参数。
在后续的微服务的controller中,可以用形似
@RequestBodyMapbody ======= body.get("userId");
这样的方式,去获取在zuulFilter传入的userId
四.一些尝试
在重写 HttpServletRequestWrapper的时候,我尝试过重写getParameterNames()和getParameterMap()方法,希望重写url参数,但是并没有生效。
总结
以上所述是小编给大家介绍的springcloud中zuul修改请求参数信息的方法,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对毛票票网站的支持!