ToB企服应用市场:ToB评测及商务社交产业平台

标题: 微服务获取用户信息和OpenFeign传递用户 [打印本页]
作者: 农妇山泉一亩田    时间: 2024-10-10 22:23
标题: 微服务获取用户信息和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企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4