ThreadLocal 的作用?
ThreadLocal是解决线程安全问题一个很好的思路,它通过为每个线程提供一个独立的变量副本解决了变量并发访问的冲突问题。在很多情况下,ThreadLocal比直接使用synchronized同步机制解决线程安全问题更简单,更方便,且结果程序拥有更高的并发性。
ThreadLocal的应用场景?
在Java的多线程编程中,为保证多个线程对共享变量的安全访问,通常会使用synchronized来保证同一时刻只有一个线程对共享变量进行操作。这种情况下可以将类变量放到ThreadLocal类型的对象中,使变量在每个线程中都有独立拷贝,不会出现一个线程读取变量时而被另一个线程修改的现象。最常见的ThreadLocal使用场景为用来解决数据库连接、Session管理等。在下面会例举几个场景
这样我们就可以在任意一个地方通过ThreadLocal取到用户数据了。
需求分析:
* 这是一个购物车场景,在用户未登录情况下可以添加购物车,登录后也可以添加购物车。
* 浏览器有一个cookie:user-key,标识用户身份,一个月后过期
* 如果第一次使用jd的购物车功能,都会给一个临时的用户身份
* 浏览器以后保存,每次访问都会带上这个cookie
*
* 登录 session 有
* 没登录,按照cookie中的user-key来做
* 第一次:如果没有临时用户,帮忙创建一个临时用户 --> 使用拦截器
* @return
引入依赖:
<!-- 引入redis-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>
<!-- 整合Spring Session完成session共享问题 微服务自治,就不放在common里了-->
<dependency>
<groupId>org.springframework.session</groupId>
<artifactId>spring-session-data-redis</artifactId>
</dependency>
修改安排plication.yml配置信息
#配置Redis缓存
spring:
redis:
host: 81.68.112.20
port: 6379
#整合Spring Session 指定session是存到redis里
session:
store-type: redis
首先创建一个拦截器
**
* @author 孟享广
* @date 2021-02-03 3:01 下午
* @description 在执行目标方法之前,判断用户的登录状态,并封装传递给controller的目标请求
*/
public class CartInterceptor implements HandlerInterceptor {
//ThreadLocal 同一线程上信息共享
public static ThreadLocal<UserInfoTo> threadLocal = new ThreadLocal<>();
/**
* 在目标方法执行之前
*/
@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
UserInfoTo userInfoTo = new UserInfoTo();
HttpSession session = request.getSession();
MemberResVo memberResVo = (MemberResVo) session.getAttribute(AuthServiceConstant.LOGIN_USER);
if (memberResVo != null) {
//说明用户登录了
userInfoTo.setUserId(memberResVo.getId());
}
//只要有user-key 就赶紧取出value
Cookie[] cookies = request.getCookies();
if (cookies != null && cookies.length > 0) {
//有cookie 可能是临时用户,但是此方法针对登录用户
for (Cookie cookie : cookies) {
String name = cookie.getName();
if (name.equals(CartServiceConstant.TEMP_USER_COOKIE_NAME)) {
userInfoTo.setUserKey(cookie.getValue());
//执行到这,说明是临时用户
userInfoTo.setTempUser(true);
}
}
}
//如果没有登录 就准备临时set一个cookie,首先设置To的userKey
if (StringUtils.isEmpty(userInfoTo.getUserKey())) {
String uuid = UUID.randomUUID().toString();
userInfoTo.setUserKey(uuid);
}
//目标方法执行前,放入 threadLocal
threadLocal.set(userInfoTo);
//只要来到目标方法都放行 无条件放行
return true;
}
/**
* 业务执行之后,让浏览器保存cookie
* 分配临时用户,让浏览器保存
*/
@Override
public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
UserInfoTo userInfoTo = threadLocal.get();
//如果没有临时用户,一定要保存一个临时用户
if (!userInfoTo.isTempUser()) {
//不是临时用户
Cookie cookie = new Cookie(CartServiceConstant.TEMP_USER_COOKIE_NAME, userInfoTo.getUserKey());
//设置cookie作用域
cookie.setDomain("gulimall.com");
//cookie的过期时间
cookie.setMaxAge(CartServiceConstant.TEMP_USER_COOKIE_TIMEOUT);
response.addCookie(cookie);
}
}
}
在Controller里面通过ThreadLocal取到用户数据。
/**
* 浏览器有一个cookie:user-key:标识用户身份 一个月过期
* 假如是第一次登录,都会给一个临时身份
* 浏览器保存以后,每次访问都会带上这个cookie
*/
@GetMapping("/cart.html")
public String cartListPage(Map<String, Cart> map) throws ExecutionException, InterruptedException {
//1 快速得到用户信息,ThreadLocal获取用户信息
UserInfoTo userInfoTo = CartInterceptor.threadLocal.get();
System.out.println(userInfoTo);
return "cartList";
}