微服务获取用户信息和OpenFeign传递用户

问题一：
网关已经完成登录校验并获取登录用户身份信息。但是当网关将哀求转发到微服务时，微服务又该如何获取用户身份呢？
由于网关发送哀求到微服务依然采用的是Http哀求，因此我们可以将用户信息以哀求头的方式传递到下游微服务。然后微服务可以从哀求头中获取登录用户信息。思量到微服务内部大概许多地方都必要用到登录用户信息，因此我们可以利用SpringMVC的拦截器来实现登录用户信息获取，并存入ThreadLocal，方便后续利用。
据图流程图如下：
 

因此，接下来我们要做的事情有：
改造网关过滤器，在获取用户信息后生存到哀求头，转发到下游微服务

1. String userInfo = userId.toString();
2. exchange.mutate()
3.         .request(builder -> builder.header("user-info",userInfo)).build();

复制代码

编写微服务拦截器，拦截哀求获取用户信息，生存到ThreadLocal后放行
ThreadLocal相关的类：

1. package com.hmall.common.utils;
3. public class UserContext {
4.     private static final ThreadLocal<Long> tl = new ThreadLocal<>();
6.     /**
7.      * 保存当前登录用户信息到ThreadLocal
8.      * @param userId 用户id
9.      */
10.     public static void setUser(Long userId) {
11.         tl.set(userId);
12.     }
14.     /**
15.      * 获取当前登录用户信息
16.      * @return 用户id
17.      */
18.     public static Long getUser() {
19.         return tl.get();
20.     }
22.     /**
23.      * 移除当前登录用户信息
24.      */
25.     public static void removeUser(){
26.         tl.remove();
27.     }
28. }

复制代码

 拦截器：

1. package com.hmall.common.interceptor;
3. import cn.hutool.core.util.StrUtil;
4. import com.hmall.common.utils.UserContext;
5. import org.springframework.web.servlet.HandlerInterceptor;
7. import javax.servlet.http.HttpServletRequest;
8. import javax.servlet.http.HttpServletResponse;
10. public class UserInfoInterceptor implements HandlerInterceptor {
12.     @Override
13.     public boolean preHandle(final HttpServletRequest request, final HttpServletResponse response, final Object handler) throws Exception {
14.         String userId = request.getHeader("User-info");
15.         if(StrUtil.isNotEmpty(userId)){
16.             UserContext.setUser(Long.parseLong(userId));
17.         }
18.         return true;
19.     }
21.     @Override
22.     public void afterCompletion(final HttpServletRequest request, final HttpServletResponse response, final Object handler, final Exception ex) throws Exception {
23.         UserContext.removeUser();
24.     }
25. }

复制代码

配置类：

1. package com.hmall.common.config;
3. import com.hmall.common.interceptor.UserInfoInterceptor;
4. import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
5. import org.springframework.context.annotation.Configuration;
6. import org.springframework.web.servlet.DispatcherServlet;
7. import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
8. import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
10. @Configuration
11. @ConditionalOnClass(DispatcherServlet.class) //排除网关服务
12. public class MvcConfig implements WebMvcConfigurer {
13.     @Override
14.     public void addInterceptors(InterceptorRegistry registry) {
15.         registry.addInterceptor(new UserInfoInterceptor()).addPathPatterns("/**");
16.     }
17. }

复制代码

基于SpringBoot的主动装配原理，我们要将其添加到resources目次下的META-INF/spring.factories文件中：

 内容如下：

1. org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
2.   com.hmall.common.config.MyBatisConfig,\
3.   com.hmall.common.config.MvcConfig

复制代码

问题二：
前端发起的哀求都会颠末网关再到微服务，由于我们之前编写的过滤器和拦截器功能，微服务可以轻松获取登录用户信息。
但有些业务是比较复杂的，哀求到达微服务后还必要调用别的多个微服务。比如下单业务，流程如下：

 下单的过程中，必要调用商品服务扣减库存，调用购物车服务清理用户购物车。而清理购物车时必须知道当前登录的用户身份。但是，订单服务调用购物车时并没有传递用户信息，购物车服务无法知道当前用户是谁！
这里要借助Feign中提供的一个拦截器接口：feign.RequestInterceptor

1. @Bean
2. public RequestInterceptor userInfoRequestInterceptor(){
3.     return new RequestInterceptor() {
4.         @Override
5.         public void apply(RequestTemplate template) {
6.             // 获取登录用户
7.             Long userId = UserContext.getUser();
8.             if(userId == null) {
9.                 // 如果为空则直接跳过
10.                 return;
11.             }
12.             // 如果不为空则放入请求头中，传递给下游微服务
13.             template.header("user-info", userId.toString());
14.         }
15.     };
16. }

复制代码

此外还必要在调用服务的启动类上加上：

1. @EnableFeignClients(basePackages = "com.hmall.api.client",defaultConfiguration = DefaultFeignConfig.class)

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。