feign添加header,feignclient调用外部接口
目录
FeignClient共享页眉及踩坑问题思路定义拦截器将拦截器注入到弹簧说说坑吧假装设置页眉头部抛出如下错误信息我找到了下面的代码问题就解决了
FeignClient共享Header及踩坑
问题
我们在调用假装的情况下，经常需要用到客户端所持有的页眉比如说授权令牌，我们需要将这些页眉传递下去
思路
使用拦截器，在客户端拦截假装的请求，并把所需要的页眉传递下去
代码：
定义拦截器
@配置公共类假装接受者实现请求拦截器{ @ Override public void apply(request template request template){ MapString，String headers=get headers(get http servlet request())；for(字符串头名：头。keyset()){请求模板。header(header name，get headers(get http servlet request()).get(头名))；} } private http servlet request get http servlet request(){ try { return((ServletRequestAttributes)requestcontextholder。getrequestattributes()).get request()；} catch(Exception e){ e . printstacktrace()；返回null} }私有MapString，String get headers(http servlet请求请求){ MapString，String map=new linked hashmap()；枚举字符串枚举=请求。getheadernames()；while(枚举。hasmorelements()){ String key=enumeration。next element()；if(needthishheader(key)){ String value=request。获取标题(键)；map.put(key，value)；} }返回图；} private boolean needthishheader(字符串头名称){//todo :这里写你的逻辑，哪些页眉需要传递，千万不能把所有的页眉传下去返回true}}
将拦截器注入到Spring
@配置公共类FeignSupportConfig { /** * feign请求拦截器* * @ return */@ Bean公共请求拦截器请求拦截器(){ return new FeignInterceptor()；}}
说说坑吧
一定不能把所有的页眉都往下传，这样很可能会导致在调用假装的时候，请求类型混乱，应该需要哪些页眉就穿哪些页眉
Feign设置Header头部
今天尝试用假装去调用其他部门提供的一个超文本传送协议接口，该接口要求在请求中设置一个用户名头部，用于身份鉴权。
@FeignClient(name=k
afka-client", url = "http://kafka.xxx.com")public interface KafkaClient { @GetMapping(value = "/api/clusterManager/listTopics"） @Headers( {"cache-control: no-cache", "username: wangyong@xxx.com"}) TopicsResponse listTopics(@RequestParam("clusterName") String clusterName, @RequestParam("clusterArea") String clusterArea);}代码写好好，尝试去进行访问
抛出如下错误信息
{ "timestamp": 1551768926170, "status": 500, "error": "Internal Server Error", "exception": "com.netflix.zuul.exception.ZuulException", "message": "pre:AuthAccessFilter"}异常堆栈信息如下：
at feign.FeignException.errorStatus(FeignException.java:62) at feign.codec.ErrorDecoder$Default.decode(ErrorDecoder.java:91) at feign.SynchronousMethodHandler.executeAndDecode(SynchronousMethodHandler.java:134) at feign.SynchronousMethodHandler.invoke(SynchronousMethodHandler.java:76) at feign.ReflectiveFeign$FeignInvocationHandler.invoke(ReflectiveFeign.java:103) at com.sun.proxy.$Proxy147.listTopics(Unknown Source) at com.yidian.data.exptmgr.controller.KafkaController.getKafkaTopics(KafkaController.java:35) // 省略更多异常堆栈信息
于是我尝试通过debug来找到问题的根源，通过debug我发现feign会先将请求参数构建成Request对象，request信息如下：/p>
request
从图中可看到，该Request实例的headers属性为空，而Request又是根据RequestTemplate模板对象生成的，RequestTemplate实例信息如下：
RequestTemplate
到这里可以看出，问题是出在RequestTemplate的构建构成中，于是我就去跟踪RequestTemplate构建的代码，发现RequestTemplate是根据MethodMetadata构建而成，而MethodMetadata就是对方法配置的抽象。
RequestTemplate template = resolve(argv, mutable, varBuilder); if (metadata.queryMapIndex() != null) { // add query map parameters after initial resolve so that they take // precedence over any predefined values template = addQueryMapQueryParameters(argv, template); } if (metadata.headerMapIndex() != null) { template = addHeaderMapHeaders(argv, template); }从上述代码可以看到，header的设置是由metadata的headerMapIndex 属性决定的，那么，设置headerMapIndex的位置，必然就和Header的解析相关，于是通过查看方法引用
我找到了下面的代码
private void parseHeaders(MethodMetadata md, Method method, RequestMapping annotation) { // TODO: only supports one header value per key if (annotation.headers() != null && annotation.headers().length > 0) { for (String header : annotation.headers()) { int index = header.indexOf(=); if (!header.contains("!=") && index >= 0) { md.template().header(resolve(header.substring(0, index)), resolve(header.substring(index + 1).trim())); } } } }从代码中我们可以清晰的看到，解析过程中是从@RequestMapping或其派生注解的header属性中解析Header的，并且Header的key和value需要用=进行分割。
于是我修改成下面的形式，
问题就解决了
@GetMapping(value = "/api/clusterManager/listTopics", headers = {"cache-control=no-cache", "username=wangyong@xxx.com"}) TopicsResponse listTopics(@RequestParam("clusterName") String clusterName, @RequestParam("clusterArea") String clusterArea);以上为个人经验，希望能给大家一个参考，也希望大家多多支持盛行IT。
郑重声明：本文由网友发布，不代表盛行IT的观点，版权归原作者所有，仅为传播更多信息之目的，如有侵权请联系，我们将第一时间修改或删除，多谢。