SpringCloud Alibaba微服务番外篇二 - Feign传递Access\_Token

概述

还记得我们之前创建订单的流程吗?

通过网关调用order-service的create方法,然后order-service再通过feign调用account-service 的reduce和 product-service的deduct方法进行业务逻辑处理。

SpringCloud Alibaba微服务番外篇二 - Feign传递Access\_Token_第1张图片

当我们项目整合好oauth2后再来调用之前的方法发现调用异常,查看后端日志发现如下的错误信息:

org.springframework.security.authentication.InsufficientAuthenticationException: Full authentication is required to access this resource

Request processing failed; nested exception is feign.FeignException$Unauthorized: status 401 reading AccountFeign#reduce(String,BigDecimal)
复制代码

错误信息告诉我们是接口未授权导致访问异常,实际上我们已经将access_token放在了header上,如下:

SpringCloud Alibaba微服务番外篇二 - Feign传递Access\_Token_第2张图片

最后通过对自定义异常类进行跟踪发现是access_token经过order-service访问account-service时丢失了,获取的accessToken为null。
SpringCloud Alibaba微服务番外篇二 - Feign传递Access\_Token_第3张图片

本节主要是来解决使用feign调用时access_token丢失的问题。

代码示例

Feign 支持请求拦截器,在发送请求前,可以对发送的模板进行操作,例如设置请求头等属性,自定请求拦截器只需要实现RequestInterceptor接口,该接口的方法有 RequestTemplate 类型的参数,我们可以根据实际情况对请求的信息进行调整。

public interface RequestInterceptor {
    void apply(RequestTemplate var1);
}
复制代码

我们要实现的功能很简单,就是取出原来的请求头,再将其传递给下游服务,在order-service中建立FeignRequestInterceptor并给其添加@Configuration注解,代码如下:

/**
 * Description:
 * 微服务之间feign调用请求头丢失的问题
 * @author javadaily
 * @date 2020/02/24 9:28
 */
@Configuration
@Slf4j
public class FeignRequestInterceptor implements RequestInterceptor {
    @Override
    public void apply(RequestTemplate template) {
        HttpServletRequest httpServletRequest =   getHttpServletRequest();
        if(httpServletRequest!=null){
            Map headers = getHeaders(httpServletRequest);
            // 传递所有请求头,防止部分丢失
            //此处也可以只传递认证的header
            //requestTemplate.header("Authorization", request.getHeader("Authorization"));
            for (Map.Entry entry : headers.entrySet()) {
                template.header(entry.getKey(), entry.getValue());
            }
            log.debug("FeignRequestInterceptor:{}", template.toString());
        }
    }


    private HttpServletRequest getHttpServletRequest() {
        try {
            return ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
        } catch (Exception e) {
            return null;
        }
    }

    /**
     * 获取原请求头
     */
    private Map getHeaders(HttpServletRequest request) {
        Map map = new LinkedHashMap<>();
        Enumeration enumeration = request.getHeaderNames();
        if(enumeration!=null){
            while (enumeration.hasMoreElements()) {
                String key = enumeration.nextElement();
                String value = request.getHeader(key);
                map.put(key, value);
            }
        }
        return map;
    }
}
复制代码

完成配置后重启服务器,再次调用create方法,正常返回响应结果。

SpringCloud Alibaba微服务番外篇二 - Feign传递Access\_Token_第4张图片

系列文章

SpringCloud Alibaba微服务实战

SpringCloud Alibaba微服务番外篇二 - Feign传递Access\_Token_第5张图片

你可能感兴趣的