分布式组件-feign-常见问题

矫情吗；* 2021-09-18 06:22 399阅读 0赞

# 丢失请求头 #

feign远程调用如果不对之进行增强，则会丢失请求头。  
Feign远程调用前，会通过遍历容器中的Feign包下的拦截器RequestInterceptor判断是否为当前的RequestTemplate进行增强。  
远程调用核心代码

![18721752-936064920dbdf6b9.png][]

image.png

![18721752-be186acef608a905.png][]

image.png

遍历private final List<RequestInterceptor> requestInterceptors;

![18721752-3349d49ebb3ee729.png][]

image.png

如果Spring容器中没有装配的RequestInterceptor的bean实例，则默认使用一个不增强的RequestTemplate，其header中没有需要的请求头。

![18721752-e4cf00dbb49000f1.png][]

image.png

## 解决方案 ##

装配一个RequestInterceptor 的bean实例，对RequestTemplate进行增强。

@Configuration
    public class GuliFeignConfig {
        @Bean
        public RequestInterceptor requestInterceptor() {
            return new RequestInterceptor() {
                @Override
                public void apply(RequestTemplate template) {
                    //1. 使用RequestContextHolder拿到老请求的请求数据
                    ServletRequestAttributes requestAttributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
                    if (requestAttributes != null) {
                        HttpServletRequest request = requestAttributes.getRequest();
                        if (request != null) {
                            //2. 将老请求得到cookie信息放到feign请求上
                            String cookie = request.getHeader("Cookie");
                            template.header("Cookie", cookie);
                        }
                    }
                }
            };
        }
    }

![18721752-adcf264ad5327db8.png][]

image.png

# 异步线程丢失上下文 #

异步调用的时候，第十一行会报空指针

因为异步调用会创建新线程，无法获取主线程的数据。  
解决办法  
利用RequestContextHolder通过ThreadLocal共享数据的特性，先在主线程中获取主线程的RequestAttributes，后在子线程中RequestContextHolder.setRequestAttributes(requestAttributes);

![18721752-4b9d20ef014e0dd3.png][]

image.png

@Override
        public ResponseResult<OrderConfirm> confirmOrder() {
          
            RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
          
            CompletableFuture<Object> objectFuture = CompletableFuture.supplyAsync(() -> {
                RequestContextHolder.setRequestAttributes(requestAttributes);
                //xxxx
                return Object;
            }, executor);
          }
      
    }

[18721752-936064920dbdf6b9.png]: /images/20210918/842765771f8444bdb925a1da32d950ae.png
[18721752-be186acef608a905.png]: /images/20210918/2f2086c076c64fd8b86e84231061d54e.png
[18721752-3349d49ebb3ee729.png]: /images/20210918/66d130158f6b41ad8592eec757fe5f1c.png
[18721752-e4cf00dbb49000f1.png]: /images/20210918/8297722abcff4dc3adfb061386783fb4.png
[18721752-adcf264ad5327db8.png]: /images/20210918/b2dff03445214421a7db31fc2cc11d7c.png
[18721752-4b9d20ef014e0dd3.png]: /images/20210918/87b48747f15741eeae53733c577d0abf.png