【 Redis | 实战篇 短信登录 】

前言：

主要完成了基于Session实现登录，解决集群的Session共享问题，从而实现了基于Redis来实现共享Session登录

1.基于Session实现登录

1.1.发送短信验证码

步骤：

前端提交手机号

==》校验手机号

==》不符合返回错误信息，符合生成验证码

==》保存验证码到Session（应该保存手机号与验证码）

==》发送验证码

==》返回数据

 

 解释：我们这个是以手机号为唯一标识，前端提交用户输入的手机号，后端校验手机号的格式，符合就生成一个随机6位的数字验证码，并保存到Session中（为了后续登录与注册时校验用户验证码是否填写正确）（当然这里应该保存手机号与验证码，不然会有一个错误）

1.2.短信验证码实现登录与注册

步骤：

前端提交手机号和验证码

==》校验手机号和验证码

==》不通过返回错误信息，通过根据手机号查询用户信息

==》判断用户是否存在

==》不存在，创建新用户，并且保存到数据库中

==》最终存在与不存在都将保存用户到Session中（方便后续校验登录状态）

==》结束

 

 @Overridepublic Result login(LoginFormDTO loginForm, HttpSession session) {//获取缓存数据Object catchPhone = session.getAttribute("phone");Object catchCode = session.getAttribute("code");//获取登录数据String code = loginForm.getCode();String phone = loginForm.getPhone();//校验if(!code.equals(catchCode) || !phone.equals(catchPhone)){return Result.fail("手机号或验证码错误");}
//        if (RegexUtils.isPhoneInvalid(phone)) {
//            return Result.fail("手机号格式错误");
//        }
//        String cacheCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);
//        if(!code.equals(cacheCode)){
//            return Result.fail("验证码错误");
//        }User user = query().eq("phone", phone).one();//判断用户是否存在if(user == null){//不存在User userNew = new User();userNew.setNickName(USER_NICK_NAME_PREFIX+RandomUtil.randomString(10));userNew.setPhone(phone);user = userNew;//保存数据库save(user);}//添加到SessionUserDTO userDTO = new UserDTO();BeanUtil.copyProperties(user,userDTO);
//        String token = UUID.randomUUID().toString(true);
//        String tokenKey = LOGIN_USER_KEY + token;
//        Map<String, Object> userMap = BeanUtil.beanToMap(userDTO,new HashMap<>(),
//                CopyOptions.create().setIgnoreNullValue(true).setFieldValueEditor((fieldName,fieldValue) -> fieldValue.toString()));
//        stringRedisTemplate.opsForHash().putAll(tokenKey,userMap);session.setAttribute("user",userDTO);
//       stringRedisTemplate.expire(tokenKey,LOGIN_USER_TTL,TimeUnit.MINUTES);return Result.ok();}

解释： 前端提交用户输入的手机号与验证码，后端从Session中取出存入的手机号与验证码与用户提交的相对比，相同那么我们就通过手机号来从数据库中查询用户信息，信息为空，那么我们需要注册一个用户并将其存入数据库中，最终存在与不存在的（我们自己注册了一个用户）都会有一个用户信息，将用户信息存入Session中（这里还有个细节）（方便后续校验登录状态，判断用户是否登录）

 注意：

老师有一个错误，在发送短信验证码的功能实现时，老师只保存了验证码到Session中，那么等到校验验证码来实现登录与注册时，如果我将手机号修改了会怎么样，只要我手机号符合格式一样可以登录与注册，所以我们需要保持前后手机号的一致性，那么存入Session的数据应该是验证码与手机号，然后登录与注册时同时校验手机号与验证码是否一致

1.3.校验登陆状态

步骤：

前端请求携带Cokie

==》后端拦截器从Session中获取用户信息

==》判断用户是否存在

==》不存在不放行，存在放行

 

public class RefreshTokenInterceptor implements HandlerInterceptor {private final StringRedisTemplate stringRedisTemplate;public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//获取请求头tokenString token = request.getHeader("authorization");//判断是否为空if (StrUtil.isBlank(token)) {return true;}
//        HttpSession session = request.getSession();//设置keyString key = LOGIN_USER_KEY + token;//获取Redis中的数据Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(key);//判断是否为空if(userMap.isEmpty()){return true;}//获取userUserDTO user = BeanUtil.fillBeanWithMap(userMap,new UserDTO(),false);//存入线程中UserHolder.saveUser( user);stringRedisTemplate.expire(key,LOGIN_USER_TTL, TimeUnit.MINUTES);return true;}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {UserHolder.removeUser();}
}

 解释：因为每次我们都需要写一堆逻辑来判断用户是否存在，那么我们可以使用AOP思想，在具体一点就是使用拦截器，但是后续服务器是不是需要用户信息，还是从Session中取出用户信息吗？不，频繁的访问Session会增加其访问开销并且造成线程不安全，所以我们依旧采用将用户信息存入TreadLocal中（线程安全）

注意：使用拦截器时，前端需要我们返回一些基础数据给它渲染用户信息，而我们之前存入Session的数据是整个用户的数据（包含密码，手机号），这些信息不适合暴露出去，所以对应之前存入Session时的数据需要做一些修改，只需要存一些基础用户信息即可（且存入Session的信息过多也是不好的）

因此我们需要隐藏用户的敏感信息（存入一些需展示的信息即可）

2.集群的Session共享问题

问题介绍：Session的数据一般存储到服务端或Redis中（手动存），而客户端只保存了一个SessionID（通过Cokie传递）（而且每个客户端的SessionID不同），那么当需要访问多个服务端时，Session数据并不共享，就会出现问题

解决：

方案一：服务器之间进行Session的拷贝（内存浪费，有延迟）

方案二：使用Redis存（Redis是存入内存的，访问速度快，多个服务器可以同时访问不会造成内存浪费）

3.基于Redis实现共享Session登录

 

  @Autowiredprivate StringRedisTemplate stringRedisTemplate;@Overridepublic Result sendCode(String phone, HttpSession session) {//1.校验手机号if (RegexUtils.isPhoneInvalid(phone)) {return Result.fail("手机号格式错误");}//2.生成验证码String code = RandomUtil.randomNumbers(6);//3.保存验证码stringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY+phone,code,LOGIN_CODE_TTL, TimeUnit.MINUTES);
//        session.setAttribute("code",code);
//        session.setAttribute("phone",phone);//4.返回验证码log.debug("当前验证码:{}",code);//5.返回return Result.ok();}@Overridepublic Result login(LoginFormDTO loginForm, HttpSession session) {
//        //获取缓存数据
//        Object catchPhone = session.getAttribute("phone");
//        Object catchCode = session.getAttribute("code");//获取登录数据String code = loginForm.getCode();String phone = loginForm.getPhone();//校验
//        if(!code.equals(catchCode) || !phone.equals(catchPhone)){
//            return Result.fail("手机号或验证码错误");
//        }if (RegexUtils.isPhoneInvalid(phone)) {return Result.fail("手机号格式错误");}String cacheCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);if(!code.equals(cacheCode)){return Result.fail("验证码错误");}User user = query().eq("phone", phone).one();//判断用户是否存在if(user == null){//不存在User userNew = new User();userNew.setNickName(USER_NICK_NAME_PREFIX+RandomUtil.randomString(10));userNew.setPhone(phone);user = userNew;//保存数据库save(user);}//添加到SessionUserDTO userDTO = new UserDTO();BeanUtil.copyProperties(user,userDTO);String token = UUID.randomUUID().toString(true);String tokenKey = LOGIN_USER_KEY + token;Map<String, Object> userMap = BeanUtil.beanToMap(userDTO,new HashMap<>(),CopyOptions.create().setIgnoreNullValue(true).setFieldValueEditor((fieldName,fieldValue) -> fieldValue.toString()));stringRedisTemplate.opsForHash().putAll(tokenKey,userMap);
//        session.setAttribute("user",userDTO);stringRedisTemplate.expire(tokenKey,LOGIN_USER_TTL,TimeUnit.MINUTES);return Result.ok(token);}
public class RefreshTokenInterceptor implements HandlerInterceptor {private final StringRedisTemplate stringRedisTemplate;public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//获取请求头tokenString token = request.getHeader("authorization");//判断是否为空if (StrUtil.isBlank(token)) {return true;}
//        HttpSession session = request.getSession();//设置keyString key = LOGIN_USER_KEY + token;//获取Redis中的数据Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(key);//判断是否为空if(userMap.isEmpty()){return true;}//获取userUserDTO user = BeanUtil.fillBeanWithMap(userMap,new UserDTO(),false);//存入线程中UserHolder.saveUser( user);stringRedisTemplate.expire(key,LOGIN_USER_TTL, TimeUnit.MINUTES);return true;}@Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {UserHolder.removeUser();}
public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {UserDTO user = UserHolder.getUser();if(user == null){response.setStatus(401);return false;}return true;}}

解释：其实最终我们只需要修改存入Session的部分，改为存入Redis即可

注意：

1.由于先前Session是用户访问一次（就是进行一次操作）就会更新登录凭证的过期时间（防止登录失效），那么我们也需要实现该功能，一般想到是在拦截器中放行之前更新时间，但是由于之前实现的拦截器有特定的拦截路径，那么没有被拦截的路径我们也需要进行更新，所以我们可以在加一个拦截器专门来更新时间（第一个拦截器更新时间，并进行存用户，第二个拦截器进行判断用户是否存在（它有特定的拦截路径），不存在不放行）

2.由于使用的是StringRedisTemplate，它要求key与value都必须为String类型，所以我们需要将数据转换成String类型再存入Redis中

3.注意拦截器的顺序，一般先添加的拦截器先执行（你也可以设置优先级order）

@Configuration
public class MvcConfig implements WebMvcConfigurer {@Autowiredprivate 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);registry.addInterceptor(new RefreshTokenInterceptor(stringRedisTemplate)).order(0).addPathPatterns("/**");}
}

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

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

相关文章

蓝桥杯14届国赛 合并数列

蓝桥杯14届国赛 合并数列

问题描述 小明发现有很多方案可以把一个很大的正整数拆成若干正整数的和。他采取了其中两种方案&#xff0c;分别将他们列为两个数组 {a1,a2,...,an} 和 {b1,b2,...,bm}。两个数组的和相同。 定义一次合并操作可以将某数组内相邻的两个数合并为一个新数&#xff0c;新数的值是…
阅读更多...
Doris和Clickhouse对比

Doris和Clickhouse对比

目录 一、Doris和Clickhouse对比1. 底层架构**DorisClickHouse** 2. 运行原理DorisClickHouse 3. 使用场景DorisClickHouse 4. 优缺点对比总结 二、MPP架构和Shared-Nothing 架构对比1. 什么是 MPP 架构&#xff1f;定义特点典型代表 2. 什么是 Shared-Nothing 架构&#xff1f…
阅读更多...
niushop单商户V5多门店版V5.5.0全插件+商品称重、商家手机端+搭建环境教程

niushop单商户V5多门店版V5.5.0全插件+商品称重、商家手机端+搭建环境教程

一.系统介绍 【全开源】niushop单商户V5多门店版V5.5.0版本&#xff0c;我看很多人都想要 商品称重、商家手机端等插件这套是全插件版本&#xff0c;整合起来本博主也花了不少啦~ Niushop系统是应用thinkphp6开发的完善的电商系统&#xff0c;拥有完善的商品机制&#xff0c;…
阅读更多...
内存、磁盘、CPU区别，Hadoop/Spark与哪个联系密切

内存、磁盘、CPU区别，Hadoop/Spark与哪个联系密切

1. 内存、磁盘、CPU的区别和作用 1.1 内存&#xff08;Memory&#xff09; 作用&#xff1a; 内存是计算机的短期存储器&#xff0c;用于存储正在运行的程序和数据。它的访问速度非常快&#xff0c;比磁盘快几个数量级。在分布式计算中&#xff0c;内存用于缓存中间结果、存储…
阅读更多...
Jenkins linux安装

Jenkins linux安装

jenkins启动 service jenkins start 重启 service jenkins restart 停止 service jenkins stop jenkins安装 命令切换到自己的下载目录 直接用命令下载 wget http://pkg.jenkins-ci.org/redhat-stable/jenkins-2.190.3-1.1.noarch.rpm 下载直接安装 rpm -ivh jenkins-2.190.3-…
阅读更多...
RabbitMQ ②-工作模式

RabbitMQ ②-工作模式

RabbitMQ 工作模式 官方提供了七种工作模式 Simple&#xff08;简单模式&#xff09; P&#xff1a;生产者&#xff0c;发布消息到队列C&#xff1a;消费者&#xff0c;从队列中获取消息并消费Queue&#xff1a;消息队列&#xff0c;存储消息。 一个生产者&#xff0c;一个…
阅读更多...
（2）python开发经验

（2）python开发经验

文章目录 1 pyside6加载ui文件2 使用pyinstaller打包 更多精彩内容&#x1f449;内容导航 &#x1f448;&#x1f449;Qt开发 &#x1f448;&#x1f449;python开发 &#x1f448; 1 pyside6加载ui文件 方法1&#xff1a; 直接加载ui文件 from PySide6.QtWidgets import QAp…
阅读更多...
【C++】互斥锁（Mutex）

【C++】互斥锁（Mutex）

在C中&#xff0c;互斥锁&#xff08;Mutex&#xff09;是用于线程同步的重要工具&#xff0c;用于保护共享资源&#xff0c;防止多线程同时访问导致的数据竞争&#xff08;Data Race&#xff09;问题。 以下是C中互斥锁的核心用法和示例&#xff1a; 一、基本互斥锁 std::mut…
阅读更多...
Jsoup与HtmlUnit：两大Java爬虫工具对比解析

Jsoup与HtmlUnit：两大Java爬虫工具对比解析

Jsoup&#xff1a;HTML解析利器 定位&#xff1a;专注HTML解析的轻量级库&#xff08;也就是快&#xff0c;但动态页面无法抓取&#xff09; 核心能力&#xff1a; DOM树解析与CSS选择器查询 HTML净化与格式化 支持元素遍历与属性提取 应用场景&#xff1a;静态页面数据抽…
阅读更多...
小白成长之路-vim编辑

小白成长之路-vim编辑

文章目录 Vim一、命令模式二、插入模式3.a:进入插入模式&#xff0c;在当前光标的后一个字符插入![在这里插入图片描述](https://i-blog.csdnimg.cn/direct/fd293c3832ed49e2974abfbb63eeb5bb.png)4.o: 在当前光标的下一行插入5.i:在当前光标所在字符插入&#xff0c;返回命令模…
阅读更多...
[redis进阶六]详解redis作为缓存分布式锁

[redis进阶六]详解redis作为缓存分布式锁

目录 一 什么是缓存 缓存总结板书: 二 使⽤Redis作为缓存 三 缓存的更新策略 1) 定期⽣成 2) 实时⽣成 四 面试重点:缓存预热,缓存穿透,缓存雪崩 和缓存击穿 1)缓存预热 2)缓存穿透 3)缓存雪崩 4)缓存击穿 五 分布式锁 板书: 1)什么是分布式锁 2)分布式锁的基…
阅读更多...
【MySQL】数据表插入数据

【MySQL】数据表插入数据

个人主页&#xff1a;Guiat 归属专栏&#xff1a;MySQL 文章目录 1. 插入数据概述1.1 插入数据的重要性1.2 插入数据的基本原则 2. 基本插入语句2.1 INSERT INTO语法2.2 插入多行数据2.3 不指定列名的插入2.4 插入NULL和默认值 3. 高级插入技术3.1 使用子查询插入数据3.2 IGNOR…
阅读更多...
软考-软件设计师中级备考 14、刷题 算法

软考-软件设计师中级备考 14、刷题 算法

一、考点归纳 1&#xff09;排序 2、查找 3、复杂度 4、经典问题 0 - 1 背包动态规划0 - 1 背包问题具有最优子结构性质和重叠子问题性质。通过动态规划可以利用一个二维数组来记录子问题的解&#xff0c;避免重复计算&#xff0c;从而高效地求解出背包能装下的最大价值。分…
阅读更多...
【阿里云】阿里云 Ubuntu 服务器无法更新 systemd（Operation not permitted）的解决方法

【阿里云】阿里云 Ubuntu 服务器无法更新 systemd（Operation not permitted）的解决方法

零、前言 目前正在使用的Ubuntu服务器中&#xff0c;仅阿里云&#xff08;不止一台&#xff09;出现了这个问题&#xff0c;因此我判定是阿里云服务器独有的问题。如果你的服务器提供商不是阿里云&#xff0c;那么这篇文章可能对你没有帮助。 如果已经因为升级错误导致依赖冲突…
阅读更多...
css 点击后改变样式

css 点击后改变样式

背景&#xff1a; 期望实现效果&#xff1a;鼠标点击之后&#xff0c;保持选中样式。 实现思路&#xff1a;在css样式中&#xff0c;:active 是一种伪类&#xff0c;用于表示用户当前正在与被选定的元素进行交互。当用户点击或按住鼠标时&#xff0c;元素将被激活&#xff0c;此…
阅读更多...
采用AI神经网络降噪算法的语言降噪消回音处理芯片NR2049-P

采用AI神经网络降噪算法的语言降噪消回音处理芯片NR2049-P

随着AI时代来临.通话设备的环境噪音抑制也进入AI降噪算法时代. AI神经网络降噪技术是一款革命性的语音处理技术&#xff0c;他突破了传统单麦克风和双麦克风降噪的局限性,利用采集的各种日常环境中的噪音样本进行训练学习.让降噪算法具有自适应噪声抑制功能&#xff0c;可以根…
阅读更多...
不用联网不用编程，PLC通过智能网关快速实现HTTP协议JSON格式与MES等系统平台双向数据通讯

不用联网不用编程，PLC通过智能网关快速实现HTTP协议JSON格式与MES等系统平台双向数据通讯

智能网关IGT-DSER集成了多种PLC的原厂协议&#xff0c;方便实现各种PLC、智能仪表通过HTTP协议与MES等各种系统平台通讯对接。PLC内不用编写程序&#xff0c;设备不用停机&#xff0c;通过网关的参数配置软件(下载地址)配置JSON文件的字段与PLC寄存器地址等参数即可。 …
阅读更多...
如何将两台虚拟机进行搭桥

如何将两台虚拟机进行搭桥

将两台虚拟机实现网络互通&#xff08;“搭桥”&#xff09;需配置虚拟网络&#xff0c;以下是基于 VMware Workstation 和 VirtualBox 的详细操作指南&#xff08;以 Windows 系统为例&#xff0c;Linux 原理类似&#xff09;&#xff1a; 一、VMware Workstation 配置&#x…
阅读更多...
Xianyu AutoAgent，AI闲鱼客服机器人

Xianyu AutoAgent，AI闲鱼客服机器人

Xianyu AutoAgent是一款专为闲鱼平台开发的智能客服机器人系统&#xff0c;旨在提供全天候的自动化服务。它具备多专家协同决策、智能议价和上下文感知对话等功能&#xff0c;能够管理轻量级的对话记忆&#xff0c;利用完整的对话历史为用户提供更自然的交流体验。 Xianyu Aut…
阅读更多...
键盘输出希腊字符方法

键盘输出希腊字符方法

在不同操作系统中&#xff0c;输出希腊字母的方法有所不同。以下是针对 Windows 和 macOS 系统的详细方法&#xff0c;以及一些通用技巧&#xff1a; 1.Windows 系统 1.1 使用字符映射表 字符映射表是一个内置工具&#xff0c;可以方便地找到并插入希腊字母。 • 步骤&#xf…
阅读更多...
最新文章

Copyright @ 2022~2023