服务器之家

服务器之家 > 正文

spring cloud zuul增加header传输的操作

时间:2021-09-14 11:49     来源/作者:zhuwei_clark

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

标签:

相关文章

热门资讯

yue是什么意思 网络流行语yue了是什么梗
yue是什么意思 网络流行语yue了是什么梗 2020-10-11
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全
2020微信伤感网名听哭了 让对方看到心疼的伤感网名大全 2019-12-26
背刺什么意思 网络词语背刺是什么梗
背刺什么意思 网络词语背刺是什么梗 2020-05-22
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总
苹果12mini价格表官网报价 iPhone12mini全版本价格汇总 2020-11-13
2021年耽改剧名单 2021要播出的59部耽改剧列表
2021年耽改剧名单 2021要播出的59部耽改剧列表 2021-03-05
返回顶部