面试难题：分布式 Session 实现难点，这篇就够！

• 那如何来解决分布式Session问题呢？

• • 一、解决方案列举

  • 二、Java代码实现解决分布式Session

平常做的项目都是在一台应用系统，并且所有的操作都在一台Tomcat服务器上，并不会引发Session共享的问题，所以并不会对我们的系统产生影响，但是当我们部署多个微服务的时候，再搭配Nginx进行负载均衡时，如果不处理分布式Session问题，我们在系统中访问不同功能时就会频繁出现用户登录的操作

图解分析原因：

图片

前提：用户登录功能和图中的商品订单模块、秒杀抢购模块属于单独的微服务模块用户登录成功后想要访问图中其他两个模块的功能时，由于Nginx使用默认负载均衡策略（轮询），这时请求会按照时间顺序逐一分发到后端应用上，也就是说用户在Tomcat1上登录成功之后，用户的信息放在Tomcat1的Session里，过了一会，用户想要进行秒杀活动的功能操作，请求又被Nginx分发到了Tomcat2，而这时的Tomcat2上的Session里还没有用户信息，于是就是出现让用户重新登录的情况，在微服务分布式项目中，不同的功能模块必然会被分列成各自的微服务，假设访问一个功能都需要重新登录一次，用户的体验必然会大幅度下降！

那如何来解决分布式Session问题呢？一、解决方案列举 1. Session复制

优点：

• 无需修改代码，只需要修改Tomcat配置

缺点：

• 同步传输占用内网宽带

• 多台Tomcat同步性能指数级下降

• Session占用内存，无法有效水平扩展

优点：

• 不占用服务器内存

缺点：

• 存在安全风险

• 数据大小受cookie限制

• 占用外网宽带

优点：

• 无需修改代码

• 服务端可以水平扩展

缺点：

• 增加新机器，会重新Hash，导致重新登录

• 应用重新启动后，需要重新登录

优点：

• 安全

• 容易水平扩展

优点：

• 增加复杂度

• 需要修改代码

• 另外， 面试宝典：https://www.yoodb.com即将上线
  

添加依赖

org.springframework.boot
spring-boot-starter-data-redis

org.apache.commons
commons-pool2

org.springframework.session
spring-session-data-redis

添加Redis配置

业务逻辑实现

String username = loginVo.getUserName();
String password = loginVo.getPassword();

User user = userMapper.selectByUserName(username);
if (user == null){

throw new GlobalException(RespBeanEnum.LOGIN_ERROR);
}
//判断密码是否正确
if (!MDUtils.formPassToDBPass(password,user.getSalt()).equals(user.getPassword())){

throw new GlobalException(RespBeanEnum.LOGIN_ERROR);
}
//使用UUID生成字符串代替Cookie
String ticket = UUIDUtil.uuid();
request.getSession().setAttribute(ticket,user);
CookieUtil.setCookie(request,response,"userTicket",ticket);
return RespBean.success();
}


视图控制层

if (StringUtils.isEmpty(ticket)){

return "login";
}
User user = (User) session.getAttribute(ticket);
if (user == null){

return "login";
}
model.addAttribute("user",user);
return "goodsList";
}


登录测试

2. Redis解决分布式Session

导入依赖

org.springframework.boot
spring-boot-starter-data-redis

org.apache.commons
commons-pool2

业务逻辑层

String username = loginVo.getUserName();
String password = loginVo.getPassword();

User user = userMapper.selectByUserName(username);
if (user == null){

throw new GlobalException(RespBeanEnum.LOGIN_ERROR);
}
//判断密码是否正确
if (!MDUtils.formPassToDBPass(password,user.getSalt()).equals(user.getPassword())){

throw new GlobalException(RespBeanEnum.LOGIN_ERROR);
}
//成功Cookie
String ticket = UUIDUtil.uuid();
//将用户信息存入到redis中
redisTemplate.opsForValue().set("userTicket",ticket);
redisTemplate.opsForValue().set("user:"+ticket,user);
//request.getSession().setAttribute(ticket,user);
CookieUtil.setCookie(request,response,"userTicket",ticket);
return RespBean.success();
}

/**
* 根据cookie获取cookie
* @param ticket
* @return
*/
@Override
public User getUserByByCookie(String ticket,HttpServletRequest request,HttpServletResponse response) {

if (StringUtils.isEmpty(ticket)){

return null;
}
User user = (User) redisTemplate.opsForValue().get("user:" + ticket);
if (user == null){

CookieUtil.setCookie(request,response,"userTicket",ticket);
}
return user;
}


视图控制层

String ticket = (String) redisTemplate.opsForValue().get("userTicket");
if (StringUtils.isEmpty(ticket)){

return "login";
}
//User user = (User) session.getAttribute(ticket);
User user = userService.getUserByByCookie(ticket, request, response);
if (user == null){

return "login";
}
model.addAttribute("user",user);
return "goodsList";
}


测试成功

图片

查看Redis管理工具

图片

作者：派 大 星. https://blog.csdn.net/Gaowumao/article/details/124309548

公众号“Java精选”所发表内容注明来源的，版权归原出处所有（无法查证版权的或者未注明出处的均来自网络，系转载，转载的目的在于传递更多信息，版权属于原作者。如有侵权，请联系，笔者会第一时间删除处理！

最近有很多人问，有没有读者交流群！加入方式很简单，公众号Java精选，回复“加群”，即可入群！

（微信小程序）：3000+道面试题，包含Java基础、并发、JVM、线程、MQ系列、Redis、Spring系列、Elasticsearch、Docker、K8s、Flink、Spark、架构设计等，在线随时刷题！

------ 特别推荐 ------

特别推荐：专注分享最前沿的技术与资讯，为弯道超车做好准备及各种开源项目与高效率软件的公众号，「大咖笔记」，专注挖掘好东西，非常值得大家关注。点击下方公众号卡片关注。

文章有帮助的话，点在看，转发吧！