ThreadLocal 场景题

痛定思痛。 2023-10-02 09:46 9阅读 0赞

面试中谈起并发，ThreadLocal 必定要聊。ThreadLocal 的线程隔离非常好用。

> 几个经典且实用的场景，防止在面试官前一时语塞

#### 文章目录 ####

*   *  1. 用过ThreadLocal吗？
     *  2. 它有什么用？
     *  3. 什么场景下使用的?
     *   *   *  场景一、保存用户信息
             *   *  场景：
                 *  1，定义用户实体：
                 *  2，定义工具类操作ThreadLocal（存放，获取，删除用户信息）
                 *  3，拦截器：1，访问接口时将用户信息放入ThreadLocal，2，访问结束时候删除ThreadLocal中信息（线程放入线程池并不一定会销毁）
                 *  4，配置拦截器。
                 *  5，定义用户信息具体操作接口：
                 *  6，使用：（代码中第二种使用方法，不需要定义接口）
     *  4. 源码深入

### 1. 用过ThreadLocal吗？ ###

### 2. 它有什么用？ ###

### 3. 什么场景下使用的? ###

##### 场景一、保存用户信息 #####

当我们的系统项目足够大到一定程度时，一些基础功能模块被调用很多次也会随之增大。

例如用户模块，几乎每个系统的每个功能都是和用户绑定的，用户在访问某个功能时，总是需要判断用户的一些属性判断对应是否拥有对应权限。

如果每个功能都查询一遍用户及相关信息，那代码就过于臃肿且不利于维护。

###### 场景： ######

接手一个项目，用户信息是用Feign调用用户中心获取，方法之间相互调用使用用户信息很麻烦（1，通过接口传参，2，再次调用Feign）。所以使用ThreadLocal存放用户信息。（大多公司都会把自己的用户单独放到公司层面做一套服务，供各个业务线使用）

###### 1，定义用户实体： ######

@ApiModel("登录用户信息")
    @Data
    public class FeginUser implements Serializable {
        
    
        private static final long serialVersionUID = 1L;
    
        @ApiModelProperty(value = "用户ID")
        private String id;
        @ApiModelProperty(value = "用户名")
        private String name;
       
        @ApiModelProperty(value = "密码")
        @JsonIgnore
        private String upass;
    }

###### 2，定义工具类操作ThreadLocal（存放，获取，删除用户信息） ######

public class ThreadLocalUtil {
        
    
            /**
             * 保存用户对象的ThreadLocal  在拦截器操作 添加、删除相关用户数据
             */
            private static final ThreadLocal<FeginUser> userThreadLocal = new ThreadLocal<FeginUser>();
    
            /**
             * 添加当前登录用户方法  在拦截器方法执行前调用设置获取用户
             * @param user
             */
            public static void addCurrentUser(FeginUser user){
        
                userThreadLocal.set(user);
            }
    
            /**
             * 获取当前登录用户方法
             */
            public static FeginUser getCurrentUser(){
        
                return userThreadLocal.get();
            }
    
    
            /**
             * 删除当前登录用户方法  在拦截器方法执行后 移除当前用户对象
             */
            public static void remove(){
        
                userThreadLocal.remove();
            }
        }

###### 3，拦截器：1，访问接口时将用户信息放入ThreadLocal，2，访问结束时候删除ThreadLocal中信息（线程放入线程池并不一定会销毁） ######

@Component
    @Slf4j
    public class UserInfoInterceptor implements HandlerInterceptor  {
        
    
        @Autowired
        private UserInfoUtil userInfoUtil;
    
        /**
         * 请求执行前执行的，将用户信息放入ThreadLocal
         * @param request
         * @param response
         * @param handler
         * @return
         * @throws Exception
         */
        @Override
        public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        
            FeginUser user;
            try{
        
                 user = userInfoUtil.getUser();
            }catch (CustomException e){
        
                log.info("***************************用户未登录， ThreadLocal无信息***************************");
                return true;
            }
            if (null!=user) {
        
                log.info("***************************用户已登录，用户信息放入ThreadLocal***************************");
                ThreadLocalUtil.addCurrentUser(user);
                return true;
            }
            log.info("***************************用户未登录， ThreadLocal无信息***************************");
            return true;
        }
    
        /**
         * 接口访问结束后，从ThreadLocal中删除用户信息
         * @param request
         * @param response
         * @param handler
         * @param ex
         * @throws Exception
         */
        @Override
        public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        
            log.info("***************************接口调用结束， 从ThreadLocal删除用户信息***************************");
            ThreadLocalUtil.remove();
        }

###### 4，配置拦截器。 ######

@Configuration
    @ComponentScan
    public class MyAppConfigurer extends WebMvcConfigurationSupport {
        
    
        @Autowired
        private UserInfoInterceptor userInfoInterceptor;
    
        /**
         * 拦截器，将用户信息放入threadLocal
         *
         * @param registry
         */
        @Override
        protected void addInterceptors(InterceptorRegistry registry) {
        
            registry.addInterceptor(this.userInfoInterceptor).addPathPatterns("/**");
            super.addInterceptors(registry);
        }
    
    }

###### 5，定义用户信息具体操作接口： ######

为了类实现接口后直接使用（不定义为基础类，是因为类单继承）

public interface IBaseUserInfo {
        
        default Boolean isLogin() {
        
            return ThreadLocalUtil.getCurrentUser() != null;
        }
    
        default FeginUser getUser() {
        
            return ThreadLocalUtil.getCurrentUser();
        }
    
        default String getUserId() {
        
            if (ThreadLocalUtil.getCurrentUser() != null) {
        
                return ThreadLocalUtil.getCurrentUser().getId();
            }
            return null;
        }
    
    }

###### 6，使用：（代码中第二种使用方法，不需要定义接口） ######

@Service
    public class ApplylServiceImpl implements IBaseUserInfo {
        
        
    
        public void applyUserInfo() {
        
            /**
             * 1,实现接口后，直接使用
             */
            FeginUser user1 = getUser();
            /**
             * 2，不实现接口，调用ThreadLocalUtil
             */
            FeginUser user2 = ThreadLocalUtil.getCurrentUser();
        }
    
    }

### 4. 源码深入 ###