spring cloud zuul增加header传输
在使用OAuth2.0传输权限认证，为了再调用其他的项目的时候获取token，必须在token下传到其他各个服务
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 |
@Component public class KeyUserFilter extends ZuulFilter { private static final Logger logger = LoggerFactory.getLogger(KeyUserFilter. class ); @Override public Object run() { // TODO Auto-generated method stub String keyCloakUser = CurrentUser.getInstance().getCurrentAuditor(); String keyCloakUserName = CurrentUser.getInstance().getCurrentAuditorName(); String nickname = CurrentUser.getInstance().getCurrentNickname(); RequestContext requestContext = RequestContext.getCurrentContext(); HttpServletRequest req = (HttpServletRequest)RequestContext.getCurrentContext().getRequest(); requestContext.addZuulRequestHeader( "authorization" , req.getHeader( "authorization" )); return null ; }
@Override public boolean shouldFilter() { // TODO Auto-generated method stub return true ; //表示是否需要执行该filter，true表示执行，false表示不执行 } @Override public int filterOrder() { // TODO Auto-generated method stub return 0 ; } @Override public String filterType() { // TODO Auto-generated method stub return "pre" ; //定义filter的类型，有pre、route、post、error四种 } } |
在其他服务中，使用HttpServletRequest 通过getHeader方法获取获取Token值即可，然后在传给其他调用
spring cloud zuul 修改转发传递的参数
在使用 springcloud zuul 进行转发请求到各个对应的服务中, 像 校验 请求权限之类的可以放 zuul的拦截器中,有些时候我们就需要增加或者减伤转发时带过去的对应的一些参数.
贴增加转发参数的代码
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 |
public static void setReqParams() { RequestContext ctx = RequestContext.getCurrentContext(); HttpServletRequest request = ctx.getRequest(); // 一定要get一下,下面这行代码才能取到值... [注1] request.getParameterMap(); Map<String, List<String>> requestQueryParams = ctx.getRequestQueryParams(); if (requestQueryParams== null ) { requestQueryParams= new HashMap<>(); } //将要新增的参数添加进去,被调用的微服务可以直接 去取,就想普通的一样,框架会直接注入进去 ArrayList<String> arrayList = new ArrayList<>(); arrayList.add( "1" ); requestQueryParams.put( "test" , arrayList); ctx.setRequestQueryParams(requestQueryParams); } |
就简单几行代码,重要的是最后一行
|
1 |
ctx.setRequestQueryParams(requestQueryParams); |
这个put([requestQueryParams], qp); 是在源码中 会在转发的时候去取这个key里面的参数值.
也就是说zuul在转发请求的时候,最终取的是这个.
然后 是 [注1], 这个地方, 一般来说,如果你的filter 的 filterOrder() 也就是过滤器顺序设定的比较晚,可以不需要这一行代码,(之所以这样是因为在源码中,后续的拦截器会执行这样一段程序:将所有传递的参数取出来,再setRequestQueryParams 中,执行顺序晚就 是框架中设定的filter执行过一次了)
但是如果你的执行顺序是0 也就是最先执行的话,这样代码必不可少,如果没有这行代码,将不会有值,也就无法达到修改传递参数的目的.(之前 没有查看源码和文档,还傻乎乎的把从request里面取出来的值 一个一个给set进去,导致参数重复.)
这里可以将 定义为流的方式的参数取出来,set进去,方便后面的微服务获取.减少相关取值代码
就是这种
|
1 2 |
ServletInputStream inputStream = request.getInputStream(); String copyToString = StreamUtils.copyToString(inputStream, Charset.forName([UTF- 8 ])); |
取出来是字符串(字符串的格式json或者xml都行) 然后set进去即可
还有一种将信息放到header 通过header传递
缺点：header传递中文需要特殊处理不然乱码
网关
|
1 2 |
RequestContext ctx = RequestContext.getCurrentContext(); ctx.addZuulRequestHeader( "original_requestURL" ,request.getRequestURL().toString()); |
子系统
|
1 |
request.getHeader( "original_requestURL" ) |
以上为个人经验，希望能给大家一个参考，也希望大家多多支持。
原文链接：https://blog.csdn.net/zhuwei_clark/article/details/90233373
查看更多关于spring cloud zuul增加header传输的操作的详细内容...