黑马点评【基于redis实现共享session登录】

目录

一、基于Session实现登录流程

1.发送验证码：

2.短信验证码登录、注册：

3.校验登录状态:

4.session共享问题

4.1为什么会出现 Session 集群共享问题？

4.2常见解决方案

1. 基于 Cookie 的 Session（客户端存储）

2. Session 复制（服务器间同步）

3. 集中式 Session 存储（推荐方案）

二、基于redis实现共享session登录

1.选择合适的存储结构

2.修改发送短信的逻辑

3.解决状态登录刷新问题

一、基于Session实现登录流程

1.发送验证码：

用户在提交手机号后，会校验手机号是否合法，如果不合法，则要求用户重新输入手机号

如果手机号合法，后台此时生成对应的验证码，同时将验证码进行保存，然后再通过短信的方式将验证码发送给用户

    @Overridepublic Result sendCode(String phone, HttpSession session) {// 1.校验手机号if (RegexUtils.isPhoneInvalid(phone)) {// 2.如果不符合，返回错误信息return Result.fail("手机号格式错误！");}// 3.符合，生成验证码String code = RandomUtil.randomNumbers(6);// 4.保存验证码到 sessionsession.setAttribute("code",code);// 5.发送验证码log.debug("发送短信验证码成功，验证码：{}", code);// 返回okreturn Result.ok();}

2.短信验证码登录、注册：

用户将验证码和手机号进行输入，后台从session中拿到当前验证码，然后和用户输入的验证码进行校验，如果不一致，则无法通过校验，如果一致，则后台根据手机号查询用户，如果用户不存在，则为用户创建账号信息，保存到数据库，无论是否存在，都会将用户信息保存到session中，方便后续获得当前登录信息

    @Overridepublic Result login(LoginFormDTO loginForm, HttpSession session) {// 1.校验手机号String phone = loginForm.getPhone();if (RegexUtils.isPhoneInvalid(phone)) {// 2.如果不符合，返回错误信息return Result.fail("手机号格式错误！");}// 3.校验验证码Object cacheCode = session.getAttribute("code");String code = loginForm.getCode();if(cacheCode == null || !cacheCode.toString().equals(code)){//3.不一致，报错return Result.fail("验证码错误");}//一致，根据手机号查询用户User user = query().eq("phone", phone).one();//5.判断用户是否存在if(user == null){//不存在，则创建user =  createUserWithPhone(phone);}//7.保存用户信息到session中session.setAttribute("user",user);return Result.ok();}

3.校验登录状态:

用户在请求时候，会从cookie中携带者JsessionId到后台，后台通过JsessionId从session中拿到用户信息，如果没有session信息，则进行拦截，如果有session信息，则将用户信息保存到threadLocal中，并且放行

拦截器代码：

public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//1.获取sessionHttpSession session = request.getSession();//2.获取session中的用户Object user = session.getAttribute("user");//3.判断用户是否存在if(user == null){//4.不存在，拦截，返回401状态码response.setStatus(401);return false;}//5.存在，保存用户信息到ThreadlocalUserHolder.saveUser((User)user);//6.放行return true;}
}

让拦截器生效

@Configuration
public class MvcConfig implements WebMvcConfigurer {@Resourceprivate StringRedisTemplate stringRedisTemplate;@Overridepublic void addInterceptors(InterceptorRegistry registry) {// 登录拦截器registry.addInterceptor(new LoginInterceptor()).excludePathPatterns("/shop/**","/voucher/**","/shop-type/**","/upload/**","/blog/hot","/user/code","/user/login").order(1);// token刷新的拦截器registry.addInterceptor(new RefreshTokenInterceptor(stringRedisTemplate)).addPathPatterns("/**").order(0);}
}

4.session共享问题

在分布式系统或集群环境中，Session 共享问题是指多个服务器节点之间如何共享用户会话（Session）数据，以确保用户在不同节点间切换时会话不丢失、状态一致。

4.1为什么会出现 Session 集群共享问题？

  1. 无状态协议特性
    HTTP 是无状态协议，服务器通过 Session 机制维持用户状态（如登录信息、购物车数据等）。在单体应用中，Session 通常存储在服务器内存中。
    但在集群 / 分布式架构中，用户请求可能被负载均衡器分配到不同节点，若节点间无法共享 Session，会导致：

    • 用户重复登录
    • 会话数据丢失（如购物车内容丢失）
    • 业务逻辑异常（如分布式事务状态不一致）

  2. 集群节点的独立性
    每个节点的内存独立，无法直接访问其他节点的 Session 数据。

4.2常见解决方案

1. 基于 Cookie 的 Session（客户端存储）
  • 原理：将 Session 数据序列化后存储在客户端 Cookie 中，每次请求携带 Cookie，服务器从 Cookie 中读取 Session。
  • 优点：
    • 无需服务器间共享数据，完全分布式
    • 减轻服务器存储压力
  • 缺点：
    • 安全性差（敏感数据需加密，否则易被篡改）
    • Cookie 大小受限（通常不超过 4KB）
    • 不适用于大量 Session 数据

适用场景：轻量级应用、非敏感数据场景。

2. Session 复制（服务器间同步）
  • 原理：多个节点之间通过网络实时复制 Session 数据，确保每个节点拥有全量 Session 副本。
  • 优点：
    • 透明性高，应用无需修改代码
    • 适用于中小型集群
  • 缺点：
    • 性能开销大（Session 变更时需全量同步，节点越多延迟越高）
    • 内存占用高（每个节点存储所有 Session）
    • 扩展性差，不适合大规模集群

适用场景：节点较少（≤5 个）、Session 更新不频繁的场景。

3. 集中式 Session 存储（推荐方案）

将 Session 数据存储在独立的第三方存储系统中（如 Redis、Memcached、数据库），所有节点通过访问统一存储获取 Session。

  • 优点：
    • 高性能（内存存储，Redis 支持集群和持久化）
    • 可扩展性强（支持动态扩缩容）
    • 数据安全（可配置密码、加密传输）
  • 缺点：
    • 需要额外维护缓存集群
    • 存在缓存穿透、缓存雪崩风险（需通过布隆过滤器、限流等机制防范）

适用场景：大型分布式系统、高并发场景。

这里我们使用redis

二、基于redis实现共享session登录

1.选择合适的存储结构

首先我们要思考一下利用redis来存储数据，那么到底使用哪种结构呢？由于存入的数据比较简单，我们可以考虑使用String，或者是使用哈希，如上图，如果使用String，注意他的value，用多占用一点空间，如果使用哈希，则他的value中只会存储他数据本身，如果不是特别在意内存，其实使用String就可以啦。

String 结构（以 JSON 字符串存用户信息）

优点

  • 存储直观易懂：直接将整个用户对象序列化为 JSON 字符串存到单个 key - value 中，业务侧读取时反序列化就能拿到完整用户信息，开发调试时查看数据很方便，比如快速通过 get heima:user:1 命令看到 {name:"Jack", age:21} 全貌 。
  • 整体读写高效：存和取都是针对整个用户对象操作，Redis 处理单 key 的读写命令（如 SET/GET ）本身就很高效，对于频繁需要完整用户信息的场景，一次操作就能满足需求 。

缺点

  • 局部更新成本高：若只想修改用户的 age 字段，得先 GET 整个 JSON 字符串，反序列化成对象改字段，再序列化成 JSON 存回 Redis，多了序列化 / 反序列化以及全量写的开销，操作不灵活 。
  • 内存占用相对高：每个用户对象要存完整的 JSON 字符串，包含字段名、分隔符等冗余信息，大量用户数据存储时，内存浪费会更明显 。

Hash 结构（字段独立存储）

优点

  • 操作灵活性强：支持对单个字段 CRUD，比如只想改 age，直接执行 HSET heima:user:1 age 22 即可，无需处理整个对象的序列化 / 反序列化，更新局部字段效率高 。
  • 内存更节省：只存字段名和对应值，没有额外的 JSON 格式冗余（如分隔符、字段名重复存储），相同用户数据量下，Hash 结构内存占用通常更少，适合大规模用户数据存储 。

缺点

  • 数据查看稍复杂：想看完整用户信息，得用 HGETALL 命令获取所有字段再拼接，不像 String 结构 GET 命令直接拿到直观的 JSON 结果，对调试不太友好 。
  • 批量操作有局限：若业务经常需要一次性获取 / 设置整个用户对象的多个字段，Hash 得多次调用 HSET/HGET ，相比 String 结构一次 SET/GET ，在这类场景下效率可能稍低 。

2.修改发送短信的逻辑

现在验证码要存入redis，用于之后的登录注册

发送验证码：

@Overridepublic Result sendCode(String phone) {// 1 校验手机号if(RegexUtils.isPhoneInvalid(phone)){return Result.fail("手机号格式不合法");}// 2 符合，生成验证码，不符合返回String code = RandomUtil.randomNumbers(6);// 3 保存验证码到sessionstringRedisTemplate.opsForValue().set(RedisConstants.LOGIN_CODE_KEY + phone,code,RedisConstants.LOGIN_CODE_TTL, TimeUnit.MINUTES);// 4 发送验证码log.info("发送验证码成功：{}",code);return Result.ok();}

登录注册：

@Overridepublic Result login(LoginFormDTO loginForm) {String phone = loginForm.getPhone();// 1 校验手机号if(RegexUtils.isPhoneInvalid(loginForm.getPhone())){return Result.fail("手机号格式不合法");}// 2 校验验证码String cacheCode = stringRedisTemplate.opsForValue().get(RedisConstants.LOGIN_CODE_KEY + phone);String code = loginForm.getCode();if(cacheCode == null || !cacheCode.equals(code)){return Result.fail("验证码错误");}// 3 一致，根据用户手机号查询用户User user = query().eq("phone", phone).one();if(user == null){user = createUserwithPhone(phone);}UserDTO userDTO = BeanUtil.copyProperties(user,UserDTO.class);Map<String, Object> userDtomap = BeanUtil.beanToMap(userDTO,new HashMap<>() ,CopyOptions.create().setIgnoreNullValue(true).setFieldValueEditor((fieldName,fieldValue) -> fieldValue.toString()));// 4 生成tokenString token = UUID.randomUUID().toString();stringRedisTemplate.opsForHash().putAll(RedisConstants.LOGIN_USER_KEY + token,userDtomap);stringRedisTemplate.expire(RedisConstants.LOGIN_USER_KEY + token,RedisConstants.LOGIN_USER_TTL,TimeUnit.MINUTES);return Result.ok(token);}

当注册完成后，用户去登录会去校验用户提交的手机号和验证码，是否一致，如果一致，则根据手机号查询用户信息，不存在则新建，最后将用户数据保存到redis，并且生成token作为redis的key，当我们校验用户是否登录时，会去携带着token进行访问，从redis中取出token对应的value，判断是否存在这个数据，如果没有则拦截，如果存在则将其保存到threadLocal中，并且放行。

3.解决状态登录刷新问题

在这个方案中，他确实可以使用对应路径的拦截，同时刷新登录token令牌的存活时间，但是现在这个拦截器他只是拦截需要被拦截的路径，假设当前用户访问了一些不需要拦截的路径，那么这个拦截器就不会生效，所以此时令牌刷新的动作实际上就不会执行，所以这个方案他是存在问题的

优化方案

既然之前的拦截器无法对不需要拦截的路径生效，那么我们可以添加一个拦截器，在第一个拦截器中拦截所有的路径，把第二个拦截器做的事情放入到第一个拦截器中，同时刷新令牌，因为第一个拦截器有了threadLocal的数据，所以此时第二个拦截器只需要判断拦截器中的user对象是否存在即可，完成整体刷新功能。

RefreshTokenInterceptor：

public class RefreshTokenInterceptor implements HandlerInterceptor {private StringRedisTemplate stringRedisTemplate;public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {// 1.获取请求头中的tokenString token = request.getHeader("authorization");if (StrUtil.isBlank(token)) {return true;}// 2.基于TOKEN获取redis中的用户String key  = LOGIN_USER_KEY + token;Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(key);// 3.判断用户是否存在if (userMap.isEmpty()) {return true;}// 5.将查询到的hash数据转为UserDTOUserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);// 6.存在，保存用户信息到 ThreadLocalUserHolder.saveUser(userDTO);// 7.刷新token有效期stringRedisTemplate.expire(key, LOGIN_USER_TTL, TimeUnit.MINUTES);// 8.放行return true;}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {// 移除用户UserHolder.removeUser();}
}

LoginInterceptor：

public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {// 1.判断是否需要拦截（ThreadLocal中是否有用户）if (UserHolder.getUser() == null) {// 没有，需要拦截，设置状态码response.setStatus(401);// 拦截return false;}// 有用户，则放行return true;}
}

看到这如果有用的话记得点赞关注哦，后续会更新更多内容的！！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.pswp.cn/web/82838.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Python读取阿里法拍网的html+解决登录cookie

Python读取阿里法拍网的html+解决登录cookie

效果图 import time from selenium import webdriver from selenium.webdriver.chrome.options import Options from selenium.webdriver.chrome.service import Service from webdriver_manager.chrome import ChromeDriverManager from lxml import etreedef get_taobao_auct…
阅读更多...
【win | docker开启远程配置】使用 SSH 隧道访问 Docker的前操作

【win | docker开启远程配置】使用 SSH 隧道访问 Docker的前操作

在主机A pycharm如何连接远程主机B win docker? 需要win docker配置什么&#xff1f; 快捷配置-主机B win OpenSSH SSH Server https://blog.csdn.net/z164470/article/details/121683333 winR,打开命令行&#xff0c;输入net start sshd,启动SSH。 或者右击我的电脑&#…
阅读更多...
Cursor生成Java的架构设计图

Cursor生成Java的架构设计图

文章目录 整体说明一、背景二、前置条件三、生成 Promt四、结果查看五、结果编辑 摘要&#xff1a; Cursor生成Java的架构设计图 关键词&#xff1a; Cursor、人工智能 、开发工具、Java 架构设计图 整体说明 Cursor 作为现在非常好用的开发工具&#xff0c;非常的火爆&#…
阅读更多...
1Panel运行的.net程序无法读取系统字体（因为使用了docker）

1Panel运行的.net程序无法读取系统字体（因为使用了docker）

问题来源 我之前都是使用的宝塔面板&#xff0c;之前我也部署过我的程序&#xff0c;就没有什么问题&#xff0c;但是上次我部署我的程序的时候&#xff0c;就提示无法找到字体Arial。 我的程序中使用该字体生成验证码。 我多次安装了微软的字体包&#xff0c;但是依旧没有效…
阅读更多...
面试总结。

面试总结。

一、回流&#xff08;重排&#xff09;与重绘&#xff08;Repaint&#xff09; 优化回答&#xff1a; 概念区分&#xff1a; 回流&#xff08;Reflow/Relayout&#xff09;&#xff1a;当元素的几何属性&#xff08;如宽高、位置、隐藏 / 显示&#xff09;发生改变时&#xff…
阅读更多...
TensorFlow深度学习实战（20）——自组织映射详解

TensorFlow深度学习实战（20）——自组织映射详解

TensorFlow深度学习实战&#xff08;20&#xff09;——自组织映射详解 0. 前言1. 自组织映射原理2. 自组织映射的优缺点3. 使用自组织映射实现颜色映射小结系列链接 0. 前言 自组织映射 (Self-Organizing Map, SOM) 是一种无监督学习算法&#xff0c;主要用于高维数据的降维、…
阅读更多...
Go内存泄漏排查与修复最佳实践

Go内存泄漏排查与修复最佳实践

一、引言 即使Go语言拥有强大的垃圾回收机制&#xff0c;内存泄漏仍然是我们在生产环境中经常面临的挑战。与传统印象不同&#xff0c;垃圾回收并不是万能的"记忆清道夫"&#xff0c;它只能处理那些不再被引用的内存&#xff0c;而无法识别那些仍被引用但实际上不再…
阅读更多...
LeetCode刷题 -- 542. 01矩阵 基于 DFS 更新优化的多源最短路径实现

LeetCode刷题 -- 542. 01矩阵 基于 DFS 更新优化的多源最短路径实现

LeetCode刷题 – 542. 01矩阵 基于 DFS 更新优化的多源最短路径实现 题目描述简述 给定一个 m x n 的二进制矩阵 mat&#xff0c;其中&#xff1a; 每个元素为 0 或 1返回一个同样大小的矩阵 ans&#xff0c;其中 ans[i][j] 表示 mat[i][j] 到最近 0 的最短曼哈顿距离 算法思…
阅读更多...
MySQL用户远程访问权限设置

MySQL用户远程访问权限设置

mysql相关指令 一. MySQL给用户添加远程访问权限1. 创建或者修改用户权限方法一&#xff1a;创建用户并授予远程访问权限方法二&#xff1a;修改现有用户的访问限制方法三&#xff1a;授予特定数据库的特定权限 2. 修改 MySQL 配置文件3. 安全最佳实践4. 测试远程连接5. 撤销权…
阅读更多...
如何使用 BPF 分析 Linux 内存泄漏，Linux 性能调优之 BPF 分析内核态、用户态内存泄漏

如何使用 BPF 分析 Linux 内存泄漏，Linux 性能调优之 BPF 分析内核态、用户态内存泄漏

写在前面 博文内容为 通过 BCC 工具集 memleak 进行内存泄漏分析的简单认知包括 memleak 脚本简单认知，内核态（内核模块）、用户态（Java,Python,C）内存跟踪泄漏分析 Demo理解不足小伙伴帮忙指正 😃,生活加油知其不可奈何而安之若命，德之至也。----《庄子内篇人间世》 …
阅读更多...
谷歌Sign Gemma: AI手语翻译，沟通从此无界！

谷歌Sign Gemma: AI手语翻译，沟通从此无界！

嘿&#xff0c;朋友们&#xff01;想象一下&#xff0c;语言不再是交流的障碍&#xff0c;每个人都能顺畅表达与理解。这听起来是不是很酷&#xff1f;谷歌最新发布的Sign Gemma AI模型&#xff0c;正朝着这个激动人心的未来迈出了一大步&#xff01;它就像一位随身的、不知疲倦…
阅读更多...
全生命周期的智慧城市管理

全生命周期的智慧城市管理

前言 全生命周期的智慧城市管理。未来&#xff0c;城市将在 实现从基础设施建设、日常运营到数据管理的 全生命周期统筹。这将避免过去智慧城市建设 中出现的“碎片化”问题&#xff0c;实现资源的高效配 置和项目的协调发展。城市管理者将运用先进 的信息技术&#xff0c;如物…
阅读更多...
最新Spring Security实战教程（十七）企业级安全方案设计 - 多因素认证（MFA）实现

最新Spring Security实战教程（十七）企业级安全方案设计 - 多因素认证（MFA）实现

&#x1f337; 古之立大事者&#xff0c;不惟有超世之才&#xff0c;亦必有坚忍不拔之志 &#x1f390; 个人CSND主页——Micro麦可乐的博客 &#x1f425;《Docker实操教程》专栏以最新的Centos版本为基础进行Docker实操教程&#xff0c;入门到实战 &#x1f33a;《RabbitMQ》…
阅读更多...
logstash拉取redisStream的流数据，并存储ES

logstash拉取redisStream的流数据，并存储ES

先说结论&#xff0c; window验证logstash截至2025-06-06 是没有原生支持的。 为啥考虑用redisStream呢&#xff1f;因为不想引入三方的kafka等组件&#xff0c; 让服务部署轻量化&#xff0c; 所以使用现有的redis来实现&#xff0c; 为啥不用list呢&#xff1f; 已经用strea…
阅读更多...
IEC 61347-1:2015 灯控制装置安全通用要求详解

IEC 61347-1:2015 灯控制装置安全通用要求详解

IEC 61347-1:2015 灯控制装置安全通用要求详解 IEC 61347-1:2015《灯控制装置 第1部分&#xff1a;一般要求和安全要求》是国际电工委员会&#xff08;IEC&#xff09;制定的关于灯控制装置安全性能的核心基础标准。它为各类用于启动和稳定工作电流的灯控制装置&#xff08;如…
阅读更多...
26、跳表

26、跳表

在C标准库中&#xff0c;std::map 和 std::set 是使用红黑树作为底层数据结构的容器。 红黑树是一种自平衡二叉搜索树&#xff0c;能够保证插入、删除和查找操作的时间复杂度为O(log n)。 以下是一些使用红黑树的C标准库容器&#xff1a; std::map&#xff1a;一种关联容器&a…
阅读更多...
LabVIEW音频测试分析

LabVIEW音频测试分析

LabVIEW通过读取指定WAV 文件&#xff0c;实现对音频信号的播放、多维度测量分析功能&#xff0c;为音频设备研发、声学研究及质量检测提供专业工具支持。 主要功能 文件读取与播放&#xff1a;支持持续读取示例数据文件夹内的 WAV 文件&#xff0c;可实时播放音频以监听被测信…
阅读更多...
JUC并发编程（二）Monitor/自旋/轻量级/锁膨胀/wait/notify/锁消除

JUC并发编程（二）Monitor/自旋/轻量级/锁膨胀/wait/notify/锁消除

目录 一 基础 1 概念 2 卖票问题 3 转账问题 二 锁机制与优化策略 0 Monitor 1 轻量级锁 2 锁膨胀 3 自旋 4 偏向锁 5 锁消除 6 wait /notify 7 sleep与wait的对比 8 join原理 一 基础 1 概念 临界区 一段代码块内如果存在对共享资源的多线程读写操作&#xf…
阅读更多...
Doris 与 Elasticsearch：谁更适合你的数据分析需求？

Doris 与 Elasticsearch：谁更适合你的数据分析需求？

一、Doris 和 Elasticsearch 的基本概念 &#xff08;一&#xff09;Doris 是什么&#xff1f; Doris 是一个用于数据分析的分布式 MPP&#xff08;大规模并行处理&#xff09;数据库。它主要用于存储和分析大量的结构化数据&#xff08;比如表格数据&#xff09;&#xff0c…
阅读更多...
使用Virtual Serial Port Driver+com2tcp(tcp2com)进行两台电脑的串口通讯

使用Virtual Serial Port Driver+com2tcp(tcp2com)进行两台电脑的串口通讯

使用Virtual Serial Port Drivercom2tcp或tcp2com进行两台电脑的串口通讯 问题说明解决方案方案三具体操作流程网上教程软件安装拓扑图准备工作com2tcp和tcp2com操作使用串口助手进行验证 方案三存在的问题数据错误通讯延时 问题说明 最近想进行串口通讯的一个测试&#xff0c…
阅读更多...
最新文章

Copyright @ 2022~2023