解决SpringCloud Feign异步调用传参问题

更新时间：2022年05月26日 10:45:11 作者：半岛铁板

这篇文章主要介绍了SpringCloud Feign异步调用传参问题,本文通过实例代码给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下

背景

各个子系统之间通过feign调用，每个服务提供方需要验证每个请求header里的token。

public void invokeFeign() throws Exception {
    feignService1.method();
    feignService2.method();
    feignService3.method();
....
}

定义拦截每次发送feign调用拦截器RequestInterceptor的子类，每次发送feign请求前将token带入请求头

@Configuration
public class FeignTokenInterceptor implements RequestInterceptor {
    @Override
    public void apply(RequestTemplate template) {
        public void apply(RequestTemplate template) {
            //上下文环境保持器,拿到刚进来这个请求包含的数据，而不会因为远程数据请求头被清除
            ServletRequestAttributes attributes = (ServletRequestAttributes)                  RequestContextHolder.getRequestAttributes();
            HttpServletRequest request = attributes.getRequest();//老的请求
            if (request != null) {
                //同步老的请求头中的数据，这里是获取cookie
                String cookie = request.getHeader("token");
                template.header("token", cookie);
            }
        }
  .....
    }

这样便能实现系统间通过同步方式feign调用的认证问题。但是如果需要在invokeFeign方法中feignService3的方法调用比较耗时，并且invokeFeign业务并不关心feignService3.method()方法的执行结果，此时该怎么办。

方案1：

修改feignService3.method()方法，将其内部实现修改为异步，这种方案依赖服务的提供方，如果feignService3服务是其他业务部门维护，并且无法修改实现为异步，此时只能采取方案2.

方案2：

通过线程池调用feignServie3.method()

public void invokeFeign() throws Exception {
    feignService1.method();
    feignService2.method();
    executor.submit(()->{
        feignService3.method();
    });
....
}

怀着期待的心情开启了尝试，你会发现调用feignService3方法并没有成功，查看日志你将会发现是由于feign发送request请求的header中未携带token导致。于是百度了下feign异步调用传参，网上大部分的解决方案，如下

public void invokeFeign() throws Exception {
        feignService1.method();
        feignService2.method();
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
                .getRequestAttributes();
        executor.submit(()->{
            RequestContextHolder.setRequestAttributes(RequestContextHolder.getRequestAttributes(), true);
            feignService3.method();
        });
    }
}

添加了上面的代码后，实测无效，此时确实有些束手无策。但是真的没无效吗？我仔细比对通过上述手段解决问题的博客，他们的业务代码和我的代码不同之处。确实有不同，比如https://www.jb51.net/article/249407.htm这篇。其代码如下

@Override
public OrderConfirmVo confirmOrder() throws ExecutionException, InterruptedException {
    OrderConfirmVo confirmVo = new OrderConfirmVo();
    MemberResVo memberResVo = LoginUserInterceptor.loginUser.get();
    //从主线程中获得所有request数据
    RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
    CompletableFuture&lt;Void&gt; getAddressFuture = CompletableFuture.runAsync(() -&gt; {
        //1、远程查询所有地址列表
        RequestContextHolder.setRequestAttributes(requestAttributes);
        List&lt;MemberAddressVo&gt; address = memberFeignService.getAddress(memberResVo.getId());
        confirmVo.setAddress(address);
    }, executor);

    //2、远程查询购物车所选的购物项,获得所有购物项数据
    CompletableFuture&lt;Void&gt; cartFuture = CompletableFuture.runAsync(() -&gt; {
        //放入子线程中request数据
        RequestContextHolder.setRequestAttributes(requestAttributes);
        List&lt;OrderItemVo&gt; items = cartFeginService.getCurrentUserCartItems();
        confirmVo.setItem(items);
    }, executor).thenRunAsync(()-&gt;{
        RequestContextHolder.setRequestAttributes(requestAttributes);
        List&lt;OrderItemVo&gt; items = confirmVo.getItem();
        List&lt;Long&gt; collect = items.stream().map(item -&gt; item.getSkuId()).collect(Collectors.toList());
        //远程调用查询是否有库存
        R hasStock = wmsFeignService.getSkusHasStock(collect);
        //形成一个List集合，获取所有物品是否有货的情况
        List&lt;SkuStockVo&gt; data = hasStock.getData(new TypeReference&lt;List&lt;SkuStockVo&gt;&gt;() {
        });
        if (data!=null){
            //收集起来，Map&lt;Long,Boolean&gt; stocks;
            Map&lt;Long, Boolean&gt; map = data.stream().collect(Collectors.toMap(SkuStockVo::getSkuId, SkuStockVo::getHasStock));
            confirmVo.setStocks(map);
        }
    },executor);
    //feign远程调用在调用之前会调用很多拦截器，因此远程调用会丢失很多请求头

    //3、查询用户积分
    Integer integration = memberResVo.getIntegration();
    confirmVo.setIntegration(integration);
    //其他数据自动计算

    CompletableFuture.allOf(getAddressFuture,cartFuture).get();
    return confirmVo;
}

我们看的出来，他的业务代码即使是开启多线程，也是等最后线程里的任务都执行完成后，业务方法才结束返回，而我的业务方法并不会等feignService3调用完成结束，抱着尝试的心态，我调整了下代码添加了CountDownLatch，让业务方法等待feign调用结束后在返回。

public void invokeFeign() throws Exception {
        feignService1.method();
        feignService2.method();
        CountDownLatch latch = new CountDownLatch(1);
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
                .getRequestAttributes();
        executor.submit(()->{
            RequestContextHolder.setRequestAttributes(RequestContextHolder.getRequestAttributes(), true);
            feignService3.method();
            latch.countDown();
        });
        latch.await();
    }
}

不如所料，调用成功了。到这里看似是解决了问题，但是与我想象的异步差别太大了，最终业务线程还是需要等待feignService3.method()调用业务方法才能返回，而且异步场景如发送短信、消息推送，记录日志可能调用耗时，业务方法可不想等待他们执行结束，此时该怎么解决？只能翻源码ServletRequestAttributes.java

首先看到了注释，这给了我灵感

Servlet-based implementation of the {@link RequestAttributes} interface. <p>Accesses objects from servlet request and HTTP session scope,
with no distinction between "session" and "global session".

从servlet请求和HTTP会话范围访问对象，"session"和"global session"作用域没有区别。对呀会不会是因为header中的参数是request作用域的原因呢，因为请求结束，所以即使在子线程设置请求头，也取不到原因。回到请求拦截器RequestInterceptor查看获取token地方

ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
    //老的请求
    HttpServletRequest request = attributes.getRequest();
if (request != null) {
        //同步老的请求头中的数据，这里是获取cookie
        String cookie = request.getHeader("token");
        template.header("token", cookie);
        }

果然如此，从attributes中获取request，然后从request中获取token。但是没有考虑到request请求结束，request作用域的问题，此时肯定取不到header里的token了。

那么该怎么解决呢？思路不能变，肯定还是围绕着ServletRequestAttributes展开，发现他有两个方法getAttributes和setAttribute，而且这俩方法都支持两个作用域request、session。

@Override
public Object getAttribute(String name, int scope) {
    if (scope == SCOPE_REQUEST) {
        if (!isRequestActive()) {
            throw new IllegalStateException(
                    "Cannot ask for request attribute - request is not active anymore!");
        }
        return this.request.getAttribute(name);
    }
    else {
        HttpSession session = getSession(false);
        if (session != null) {
            try {
                Object value = session.getAttribute(name);
                if (value != null) {
                    this.sessionAttributesToUpdate.put(name, value);
                }
                return value;
            }
            catch (IllegalStateException ex) {
                // Session invalidated - shouldn't usually happen.
            }
        }
        return null;
    }
}

@Override
public void setAttribute(String name, Object value, int scope) {
    if (scope == SCOPE_REQUEST) {
        if (!isRequestActive()) {
            throw new IllegalStateException(
                    "Cannot set request attribute - request is not active anymore!");
        }
        this.request.setAttribute(name, value);
    }
    else {
        HttpSession session = obtainSession();
        this.sessionAttributesToUpdate.remove(name);
        session.setAttribute(name, value);
    }
}

既然我们的业务方法调用(HttpServletRequest)不会等待feignService3.method，我们可以通过ServletRequestAttributes.setAttributes指定作用域为session呀。此时invokeFeign代码如下

public void invokeFeign() throws Exception {
        feignService1.method();
        feignService2.method();
        ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder
                .getRequestAttributes();
        //在ServeletRequestAttributes中设置token，作用域为session                 
        attributes.setAttribute("token",attributes.getRequest().getHeader("token"),1);
        executor.submit(()->{
            RequestContextHolder.setRequestAttributes(RequestContextHolder.getRequestAttributes(), true);
            feignService3.method();
        });
    }
}

然后RequestInterceptor.apply方法也做响应调整，如下

ServletRequestAttributes attributes = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
    //老的请求
    HttpServletRequest request = attributes.getRequest();
    String token = (String) attributes.getAttribute("token",1);
template.header("token",token);
        if (request != null) {
        //同步老的请求头中的数据，这里是获取cookie
        String cookie = request.getHeader("token");
        template.header("token", cookie);
        }

问题得以圆满解决。

到此这篇关于SpringCloud Feign异步调用传参问题的文章就介绍到这了,更多相关SpringCloud Feign传参内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

Java文件读取写入后 md5值不变的实现方法
下面小编就为大家分享一篇Java文件读取写入后 md5值不变的实现方法，具有很好的参考价值，希望对大家有所帮助
2017-11-11
关于Spring Cloud实现日志管理模块
这篇文章主要介绍了关于Spring Cloud实现日志管理模块问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-11-11
Java面向对象之包装类的用途与实际使用
所谓包装类,就是能够直接将简单类型的变量表示为一个类,在执行变量类型的相互转换时,我们会大量使用这些包装类,本文我们来深入探索一下Java包装类的相关内容,需要的朋友可以参考下
2022-03-03
java获取中文拼音首字母的实例
下面小编就为大家带来一篇java获取中文拼音首字母的实例。小编觉得挺不错的，现在就分享给大家，也给大家做个参考。一起跟随小编过来看看吧
2017-09-09
Java源码解析之平衡二叉树
在上一章的文章中,我们讲到了二叉排序树,它很好的平衡了插入与查找的效率,但二叉排序树如果不平衡,那么查找效率就会大大降低,今天要讲的这个平衡二叉树就是一种解决这个问题的方法.需要的朋友可以参考下
2021-05-05
Java Comparator.comparing比较导致空指针异常的解决
这篇文章主要介绍了Java Comparator.comparing比较导致空指针异常的解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-07-07
如何基于Jenkins构建Docker镜像
这篇文章主要介绍了基于Jenkins构建Docker镜像,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
2019-11-11
Spring Batch读取txt文件并写入数据库的方法教程
这篇文章主要给大家介绍了Spring Batch读取txt文件并写入数据库的方法，SpringBatch 是一个轻量级、全面的批处理框架。这里我们用它来实现文件的读取并将读取的结果作处理，处理之后再写入数据库中的功能。需要的朋友可以参考借鉴，下面来一起看看吧。
2017-04-04
MyBatis中的占位符入参全面详解
这篇文章主要为大家介绍了MyBatis中的占位符全面详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2023-03-03
mybatis-plus之如何根据数据库主键定义字段类型
这篇文章主要介绍了mybatis-plus之如何根据数据库主键定义字段类型问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2023-07-07

解决SpringCloud Feign异步调用传参问题

背景

方案1：

方案2：

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具