面试中谈起并发，ThreadLocal 必定要聊。ThreadLocal 的线程隔离非常好用。
几个经典且实用的场景，防止在面试官前一时语塞
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，定义用户信息具体操作接口：
为了类实现接口后直接使用（不定义为基础类，是因为类单继承）
publicpublic 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(); } }
