Spring Cloud组件feign异步调用获取HttpRequest为null
获取HttpRequest场景在Spring Cloud分布式系统中,微服务之间的feign调用需要授权,请求参数的传递,此时就需要实现feign.RequestInterceptor,将token或者session,params参数等传递到目标微服务.怎么获取HttpRequest对象public class ZuulCustomFeignClientConfig implements R...
获取HttpRequest场景
在Spring Cloud分布式系统中,微服务之间的feign调用需要授权,请求参数的传递,此时就需要实现feign.RequestInterceptor,将token或者session,params参数等传递到目标微服务.
怎么获取HttpRequest对象
public class ZuulCustomFeignClientConfig implements RequestInterceptor {
@Override
public void apply(RequestTemplate requestTemplate) {
ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
HttpServletRequest request = attributes.getRequest();
String access_token = request.getParameter("access_token");
Map<String, Collection<String>> queries = requestTemplate.queries();
Map<String, Collection<String>> newMaP = Maps.newLinkedHashMap();
newMaP.putAll(queries);
Collection<String> param = Lists.newArrayList();
param.add(access_token);
newMaP.put("access_token", param);
此时获取的request在开启异步调用的时候就就会出现问null的情况,出现问题的原因是啥呢?
获取HttpRequest 为null的原因
开启另外一个线程异步调用feign,因为httpRequest是绑定在ThreadLocal中的,只能在当前线程中共享,子线程是不能获取到父线程的属性.
怎么解决feign线程共享
方案一
在父线程冲获取到RequestContextHolder设置
public static void setRequestAttributes(@Nullable RequestAttributes attributes) { setRequestAttributes(attributes, false); }
阅读源码我们可以发现,其实使用的是
public static void setRequestAttributes(@Nullable RequestAttributes attributes, boolean inheritable) {
if (attributes == null) {
resetRequestAttributes();
} else if (inheritable) {
inheritableRequestAttributesHolder.set(attributes);
requestAttributesHolder.remove();
} else {
requestAttributesHolder.set(attributes);
inheritableRequestAttributesHolder.remove();
}
}
inheritableRequestAttributesHolder就是NamedInheritableThreadLocal,可以实现线程之间的共享
总结
feign异步调用问题多多,在使用时,需要多加注意,同时开启hystrix时,当feign第一次请求失败(spring使用的是懒加载的形式)怎么处理.
更多推荐
所有评论(0)