基于Redis实现共享session登录

搭配食用:Redis(基础篇)-CSDN博客

项目实现前的

Mysql中的表:

说明
tb_user用户表
tb_user_info用户详情表
tb_shop商户信息表
tb_shop_type商户类型表
tb_blog用户日记表(达人探店日记)
tb_follow用户关注表
tb_voucher优惠券表
tb_voucher_order优惠券的订单表

启动前端服务器:

start nginx.exe

 手机端首页:

localhost:8080

 项目架构:

  • 手机或者app端发起请求,请求我们的Nginx服务器,Nginx基于七层模型走的是HTTP协议,可以实现基于Lua直接绕开Tomcat访问Redis,也可以作为静态资源服务器,轻松扛下上万并发, 负载均衡到下游Tomcat服务器,打散流量,我们都知道一台4核8G的Tomcat,在优化和处理简单业务的加持下,大不了就处理1000左右的并发, 经过Nginx的负载均衡分流后,利用集群支撑起整个项目,同时Nginx在部署了前端项目后,更是可以做到动静分离,进一步降低Tomcat服务的压力,这些功能都得靠Nginx起作用,所以Nginx是整个项目中重要的一环。

  • 在Tomcat支撑起并发流量后,我们如果让Tomcat直接去访问Mysql,根据经验Mysql企业级服务器只要上点并发,一般是16或32 核心cpu,32 或64G内存,像企业级mysql加上固态硬盘能够支撑的并发,大概就是4000起~7000左右,上万并发, 瞬间就会让Mysql服务器的cpu,硬盘全部打满,容易崩溃,所以我们在高并发场景下,会选择使用mysql集群,同时为了进一步降低Mysql的压力,同时增加访问的性能,我们也会加入Redis,同时使用Redis集群使得Redis对外提供更好的服务。

邮箱登录 

  1. 发送验证码
    用户在提交手机号后,会校验手机号是否合法,如果不合法,则要求用户重新输入手机号
    如果手机号合法,后台此时生成对应的验证码,同时将验证码进行保存,然后再通过短信的方式将验证码发送给用户
  2. 短信验证码登录、注册
    用户将验证码和手机号进行输入,后台从session中拿到当前验证码,然后和用户输入的验证码进行校验,如果不一致,则无法通过校验,如果一致,则后台根据手机号查询用户,如果用户不存在,则为用户创建账号信息,保存到数据库,无论是否存在,都会将用户信息保存到session中,方便后续获得当前登录信息
  3. 校验登录状态
    用户在请求的时候,会从cookie中携带JsessionId到后台,后台通过JsessionId从session中拿到用户信息,如果没有session信息,则进行拦截,如果有session信息,则将用户信息保存到threadLocal中,并放行

实现发送邮箱验证码功能 

输入手机号,点击发送验证码按钮后会发送一个请求:

调用UserController中的code方法,携带参数是phone 

  • 但是黑马这里并不会真的使用短信服务发送验证码,只是随机生成了一个验证码,那我这里为了后期项目能真的部署上线,还是打算用邮箱验证
  • 由于黑马这里貌似没有设置前端的手机号正则判断,所以我们只需要去数据库中修改phone的字段类型,将varchar(11)改为varchar(100)

首先导入邮箱验证需要的maven坐标

<!-- https://mvnrepository.com/artifact/javax.activation/activation -->
<dependency><groupId>javax.activation</groupId><artifactId>activation</artifactId><version>1.1.1</version>
</dependency>
<!-- https://mvnrepository.com/artifact/javax.mail/mail -->
<dependency><groupId>javax.mail</groupId><artifactId>mail</artifactId><version>1.4.7</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.apache.commons/commons-email -->
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-email</artifactId><version>1.4</version>
</dependency>

 然后编写一个工具类,用于发送邮件验证码

package com.hmdp.utils;import javax.mail.*;
import javax.mail.internet.InternetAddress;
import javax.mail.internet.MimeMessage;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Properties;public class MailUtils {public static void main(String[] args) throws MessagingException {sendTestMail("1796491347@qq.com", new MailUtils().achieveCode());}public static void sendTestMail(String email, String code) throws MessagingException {//创建Properties类用于记录邮箱的一些属性Properties props = new Properties();//设置发送邮件的邮件服务器的属性(这里使用腾讯的smtp服务器)//表示SMTP发送邮件,必须进行身份验证props.put("mail.smtp.auth", "true");//此处填写SMTP服务器props.put("mail.smtp.host", "smtp.qq.com");//端口号,QQ邮箱端口587props.put("mail.smtp.port", "587");//此处填写,写信人的QQ账号props.put("mail.user", "1796491347@qq.com");//此处填写16位STMP授权码props.put("mail.password", "dpvzxlrnbycdegaf");//构建授权信息,用于进行SMTP进行身份验证Authenticator authenticator = new Authenticator() {protected PasswordAuthentication getPasswordAuthentication() {//用户名、密码String username = props.getProperty("mail.user");String password = props.getProperty("mail.password");return new PasswordAuthentication(username, password);}};//使用环境属性和授权信息,创建邮件会话Session mailSession = Session.getInstance(props, authenticator);//创建邮件消息MimeMessage message = new MimeMessage(mailSession);//设置发件人InternetAddress form = new InternetAddress(props.getProperty("mail.user"));message.setFrom(form);//设置收件人的邮箱地址InternetAddress to = new InternetAddress(email);message.setRecipient(MimeMessage.RecipientType.TO,to);//设置邮件标题message.setSubject("验证码 邮件测试");//设置邮件的内容体message.setContent("验证码是:"+code,"text/html;charset=UTF-8");//发送邮件Transport.send(message);}public static String achieveCode(){//由于数字1、0和字母O、I容易混淆,所以这里生成的验证码不包含1和OString[] beforeShuffle = new String[]{"2", "3", "4", "5", "6", "7", "8", "9","A", "B", "C", "D", "E", "F", "G", "H", "I", "J", "K", "L", "M","N", "P", "Q", "R", "S", "T", "U", "V", "W", "X", "Y", "Z","a", "b", "c", "d", "e", "f", "g", "h", "i", "j", "k", "m","n", "p", "q", "r", "s", "t", "u", "v", "w", "x", "y", "z"};List<String> list = Arrays.asList(beforeShuffle);//将数组转换为集合Collections.shuffle(list);//打乱集合内元素顺序StringBuilder sb = new StringBuilder();for(String s : list){sb.append(s);//获取打乱顺序后的集合元素,并拼接成字符串}return sb.substring(3,8);}
}

授权码:

修改sendCode方法,逻辑如下 

        验证手机号/邮箱格式 

                不正确则返回错误信息

                 正确则发送验证码

 然后输入邮箱,发送验证码,看看能否接收到验证码

    /*** 发送手机验证码*/@PostMapping("code")public Result sendCode(@RequestParam("phone") String phone, HttpSession session) throws MessagingException {// TODO 发送短信验证码并保存验证码if(RegexUtils.isEmailInvalid(phone)){return Result.fail("邮箱格式错误");}String code = MailUtils.achieveCode();session.setAttribute(phone,code);log.info("发送登录验证码:{}",code);MailUtils.sendTestMail(phone,code);return Result.ok();}

 实现登录、注册功能

点击登录按钮,查看发送的请求 

请求网址: http://localhost:8080/api/user/login
请求方法: POST 

 

UserController中的login方法,携带的参数也就是我们的邮箱和验证码 

{phone: "1796491347@qq.com", code: "4Nr3k"}

 邮箱和验证码封装到了LoginFormDto中

  • 修改login方法,逻辑如下
    • 校验手机号/邮箱
      • 不正确则返回错误信息
      • 正确则继续校验验证码
        • 不一致则报错
        • 一致则先根据手机号/邮箱查询用户
          • 用户不存在则创建
          • 存在则继续执行程序
        • 保存用户信息到session中
    /*** 登录功能* @param loginForm 登录参数,包含手机号、验证码;或者手机号、密码*/@PostMapping("/login")public Result login(@RequestBody LoginFormDTO loginForm, HttpSession session){// TODO 实现登录功能//获取登录账号String phone = loginForm.getPhone();//获取登录验证码String code = loginForm.getCode();//获取session中的验证码Object cacheCode = session.getAttribute(phone);//1. 校验邮箱if(RegexUtils.isEmailInvalid(phone)){//2.不符合格式则报错return Result.fail("邮箱格式错误");}//3.校验验证码log.info("code:{},cacheCode{}",code,cacheCode);if(code == null || !cacheCode.toString().equals(code)){//4.不一致则报错return Result.fail("验证码错误");}//5.根据账号查询用户是否存在LambdaQueryWrapper<User> queryWrapper = new LambdaQueryWrapper<>();queryWrapper.eq(User::getPhone,phone);User user = userService.getOne(queryWrapper);//6.用户不存在则创建新用户if(user == null){//创建的逻辑封装成一个方法user = createUserWithPhone(phone);}//7.保存用户信息到session中session.setAttribute("user",user);return Result.ok();}
private User createUserWithPhone(String phone) {//创建用户User user = new User();//设置手机号user.setPhone(phone);//设置昵称(默认名),一个固定前缀+随机字符串user.setNickName("user_" + RandomUtil.randomString(8));//保存到数据库userService.save(user);return user;
}

 实现登录拦截功能(拦截器)

 创建一个LoginInterceptor类,实现HandlerInterceptor接口,重写其中的两个方法,前置拦截器和完成处理方法,前置拦截器主要用于我们登陆之前的权限校验,完成处理方法是用于处理登录后的信息,避免内存泄露 

utils包下的工具类-拦截器 

/*** 拦截器*/
public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.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;}@Overridepublic void afterCompletion(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Object handler, Exception ex) throws Exception {// 移除用户UserHolder.removeUser();}
}

 config包下的配置类

import com.hmdp.utils.LoginInterceptor;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;/*** MVC配置类,用于自定义Spring MVC的配置。*/
@Configuration
public class MvcConfig implements WebMvcConfigurer {/*** 添加拦截器配置。** 本方法旨在注册一个登录拦截器,并排除一些不需要拦截的路径。* 排除的路径通常是一些公共资源路径或者登录相关路径,这些路径不需要用户登录即可访问。** @param registry 拦截器注册表,用于添加和配置拦截器。*/@Overridepublic void addInterceptors(InterceptorRegistry registry) {// 添加登录拦截器registry.addInterceptor(new LoginInterceptor())// 排除不需要拦截的路径.excludePathPatterns("/shop/**", // 商城相关路径"/shop-type/**", // 商城类型路径"/upload/**", // 上传路径"/blog/hot", // 热门博客路径"/user/code", // 用户验证码路径"/user/login" // 用户登录路径);}
}

 utils包下的工具类-保存用户信息到ThreadLocal

import com.hmdp.entity.User;public class UserHolder {private static final ThreadLocal<User> tl = new ThreadLocal<>();public static void saveUser(User userId){tl.set(userId);}public static User getUser(){return tl.get();}public static void removeUser(){tl.remove();}
}

 UserController中的方法

    @GetMapping("/me")public Result me(){// TODO 获取当前登录的用户并返回User user = UserHolder.getUser();return Result.ok(user);}

短信登录

实现发送短信验证码功能(短信功能同邮箱一样需要阿里云服务支持)

UserController 

    @PostMapping("code")public Result sendCode(@RequestParam("phone") String phone, HttpSession session) throws MessagingException {// 发送短信验证码并保存验证码return userService.sendCode(phone, session);}

服务类IUserService 

public interface IUserService extends IService<User> {Result sendCode(String phone, HttpSession session);
}

 服务类的实现类

@Service
@Slf4j
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@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);// 6.返回okreturn Result.ok();}
}

 正则表达式校验手机号格式工具类

public class RegexUtils {/*** 是否是无效手机格式* @param phone 要校验的手机号* @return true:符合,false:不符合*/public static boolean isPhoneInvalid(String phone){return mismatch(phone, RegexPatterns.PHONE_REGEX);}/*** 是否是无效邮箱格式* @param email 要校验的邮箱* @return true:符合,false:不符合*/public static boolean isEmailInvalid(String email){return mismatch(email, RegexPatterns.EMAIL_REGEX);}/*** 是否是无效验证码格式* @param code 要校验的验证码* @return true:符合,false:不符合*/public static boolean isCodeInvalid(String code){return mismatch(code, RegexPatterns.VERIFY_CODE_REGEX);}// 校验是否不符合正则格式private static boolean mismatch(String str, String regex){if (StrUtil.isBlank(str)) {return true;}return !str.matches(regex);}
}

实现登录功能

 UserController

    @PostMapping("/login")public Result login(@RequestBody LoginFormDTO loginForm, HttpSession session){//  实现登录功能return userService.login(loginForm, session);}

 服务类IUserService 

public interface IUserService extends IService<User> {Result login(LoginFormDTO loginForm, HttpSession session);
}

  服务类的实现类

@Service
@Slf4j
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@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)) {// 4.不一致,报错return Result.fail("验证码错误");}// 5.一致,根据手机号查询用户 select * from tb_user where phone = ?User user = query().eq("phone", phone).one();// 6.判断用户是否存在if (user == null) {// 7.不存在,创建新用户并保存user = createUserWithPhone(phone);}// 8.保存用户信息到sessionsession.setAttribute("user",user);return Result.ok();}private User createUserWithPhone(String phone) {// 1.创建用户User user = new User();user.setPhone(phone);user.setNickName("user_" + RandomUtil.randomString(10));// 2.保存用户save(user);return user;}
}

实现登录拦截功能(拦截器) 

 

 utils包下的工具类-拦截器 

/*** 拦截器*/
public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.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;}@Overridepublic void afterCompletion(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Object handler, Exception ex) throws Exception {// 移除用户UserHolder.removeUser();}
}

 config包下的配置类

import com.hmdp.utils.LoginInterceptor;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;/*** MVC配置类,用于自定义Spring MVC的配置。*/
@Configuration
public class MvcConfig implements WebMvcConfigurer {/*** 添加拦截器配置。** 本方法旨在注册一个登录拦截器,并排除一些不需要拦截的路径。* 排除的路径通常是一些公共资源路径或者登录相关路径,这些路径不需要用户登录即可访问。** @param registry 拦截器注册表,用于添加和配置拦截器。*/@Overridepublic void addInterceptors(InterceptorRegistry registry) {// 添加登录拦截器registry.addInterceptor(new LoginInterceptor())// 排除不需要拦截的路径.excludePathPatterns("/shop/**", // 商城相关路径"/shop-type/**", // 商城类型路径"/upload/**", // 上传路径"/blog/hot", // 热门博客路径"/user/code", // 用户验证码路径"/user/login" // 用户登录路径);}
}

 utils包下的工具类-保存用户信息到ThreadLocal

import com.hmdp.entity.User;public class UserHolder {private static final ThreadLocal<User> tl = new ThreadLocal<>();public static void saveUser(User userId){tl.set(userId);}public static User getUser(){return tl.get();}public static void removeUser(){tl.remove();}
}

 UserController中的方法

    @GetMapping("/me")public Result me(){// TODO 获取当前登录的用户并返回User user = UserHolder.getUser();return Result.ok(user);}

 隐藏用户敏感信息

在点击”我的“ 时会发起一个GET请求查询用户信息,但是返回来的结果包含了用户敏感信息。

 

 

现在需要在登录的

响应请求给前端的不包含隐私信息的UserDTO类 

import lombok.Data;@Data
public class UserDTO {private Long id;private String nickName;private String icon;
}

 UserController中响应的方法改成返回DTO

    @GetMapping("/me")public Result me(){// 获取当前登录的用户并返回UserDTO user = UserHolder.getUser();return Result.ok(user);}

UserHolder改成DTO

该UserHolder类主要用于在多线程环境中保存和管理用户信息(UserDTO对象)。 

public class UserHolder {private static final ThreadLocal<UserDTO> tl = new ThreadLocal<>();public static void saveUser(UserDTO user){tl.set(user);}public static UserDTO getUser(){return tl.get();}public static void removeUser(){tl.remove();}
}

登录拦截的时候若存在则将DTO保存到线程而不是具有全部信息的user,那样前端保存着太多信息会有很多负载。 

public class LoginInterceptor implements HandlerInterceptor {@Overridepublic boolean preHandle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.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((UserDTO) user);// 6.放行return true;}@Overridepublic void afterCompletion(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Object handler, Exception ex) throws Exception {// 移除用户UserHolder.removeUser();}
}

 修改8.保存用户信息到session

登录的时候保存到session的是userDTO,若登录时创建用户信息保存到数据库的是user

@Service
@Slf4j
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@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)) {// 4.不一致,报错return Result.fail("验证码错误");}// 5.一致,根据手机号查询用户 select * from tb_user where phone = ?User user = query().eq("phone", phone).one();// 6.判断用户是否存在if (user == null) {// 7.不存在,创建新用户并保存user = createUserWithPhone(phone);}// 8.保存用户信息到session// BeanUtil.copyProperties可以使得省略给DTO一个一个赋值session.setAttribute("user", BeanUtil.copyProperties(user, UserDTO.class));return Result.ok();}private User createUserWithPhone(String phone) {// 1.创建用户User user = new User();user.setPhone(phone);user.setNickName("user_" + RandomUtil.randomString(10));// 2.保存用户save(user);return user;}
}

集群的Session共享问题

当请求nginx时会负载均衡到tomcat集群中的一台,但是在不同的tomcat中其session中的内容不共享。

但是每一台都存储同样的session信息会造成资源浪费,负载大。

因此使用redis解决:1、redis集群是数据共享的(主从复制)2、redis内容存储(读写分离)3、redis的key-value结构刚好可以存储session信息。

基于redis实现共享session登录 

 

redis存储信息的两种方式:

UserServiceImpl实现类: 

 @Resourceprivate StringRedisTemplate stringRedisTemplate;@Overridepublic Result sendCode(String phone, HttpSession session) {// 1.校验手机号if (RegexUtils.isPhoneInvalid(phone)) {// 2.如果不符合,返回错误信息return Result.fail("手机号格式错误!");}// 3.符合,生成验证码String code = RandomUtil.randomNumbers(6);// 4.保存验证码到redis 有效期2分钟以避免redis一直存验证码不删除stringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY + phone, code, LOGIN_CODE_TTL, TimeUnit.MINUTES);// 5.发送验证码log.debug("发送短信验证码成功,验证码:{}", code);// 6.返回okreturn Result.ok();}@Overridepublic Result login(LoginFormDTO loginForm, HttpSession session) {// 1.校验手机号String phone = loginForm.getPhone();if (RegexUtils.isPhoneInvalid(phone)) {// 2.如果不符合,返回错误信息return Result.fail("手机号格式错误!");}// 3.从redis获取验证码并校验String cacheCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);// 获取用户填写的验证码String code = loginForm.getCode();if (cacheCode == null || !cacheCode.equals(code)) {// 4.不一致,报错return Result.fail("验证码错误");}// 5.一致,根据手机号查询用户 select * from tb_user where phone = ?User user = query().eq("phone", phone).one();// 6.判断用户是否存在if (user == null) {// 7.不存在,创建新用户并保存user = createUserWithPhone(phone);}
//        // 8.保存用户信息到session
//        // BeanUtil.copyProperties可以使得省略给DTO一个一个赋值
//        session.setAttribute("user", BeanUtil.copyProperties(user, UserDTO.class));// 8.保存用户信息到redis// 1、随机生成token,作为登录令牌String token = UUID.randomUUID().toString(true);// 2、将User对象转为HashMap存储// 3、存储到redis中UserDTO userDTO = BeanUtil.copyProperties(user, UserDTO.class);// redis要求key 和 value 都是String类型,所以需要设置一个编辑器  DTO中的属性不全是String类型Map<String, Object> userMap = BeanUtil.beanToMap(userDTO, new HashMap<>(),CopyOptions.create().setIgnoreNullValue(true).setFieldValueEditor((fieldName, fieldValue) -> fieldValue.toString()));String tokenKey = LOGIN_USER_KEY + token;stringRedisTemplate.opsForHash().putAll(tokenKey, userMap);// 设置token为key,userDTO为value,设置有效期stringRedisTemplate.expire("user:" + token, LOGIN_USER_TTL, TimeUnit.MINUTES);// 9.返回tokenreturn Result.ok(token);}

 MvcConfig

@Configuration
public class MvcConfig implements WebMvcConfigurer {@Resourceprivate StringRedisTemplate stringRedisTemplate;/*** 添加拦截器配置。** 本方法旨在注册一个登录拦截器,并排除一些不需要拦截的路径。* 排除的路径通常是一些公共资源路径或者登录相关路径,这些路径不需要用户登录即可访问。** @param registry 拦截器注册表,用于添加和配置拦截器。*/@Overridepublic void addInterceptors(InterceptorRegistry registry) {// 添加登录拦截器registry.addInterceptor(new LoginInterceptor(stringRedisTemplate))// 排除不需要拦截的路径.excludePathPatterns("/shop/**", // 商城相关路径"/shop-type/**", // 商城类型路径"/upload/**", // 上传路径"/blog/hot", // 热门博客路径"/user/code", // 用户验证码路径"/user/login" // 用户登录路径);}
}

拦截器 

public class LoginInterceptor implements HandlerInterceptor {private StringRedisTemplate stringRedisTemplate;public LoginInterceptor(StringRedisTemplate stringRedisTemplate) {this.stringRedisTemplate = stringRedisTemplate;}@Overridepublic boolean preHandle(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Object handler) throws Exception {
//        // 1.获取Session
//        HttpSession session = request.getSession();// 1.获取请求头中的tokenString token = request.getHeader("authorization");if(StrUtil.isBlank(token)){// 不存在,拦截,返回401状态码response.setStatus(401);return false;}//        // 2.获取Session中的用户
//        Object user = session.getAttribute("user");// 2.基于token从redis中获取用户Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(RedisConstants.LOGIN_USER_KEY + token);// 3.判断用户是否存在if (userMap.isEmpty()) {// 4.不存在,拦截,返回401状态码response.setStatus(401);return false;}// 5.将查询到的Map用户数据转为UserDTOUserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);// 6.存在,保存用户到ThreadLocalUserHolder.saveUser(userDTO);// 7.刷新token有效期stringRedisTemplate.expire(RedisConstants.LOGIN_USER_KEY + token, RedisConstants.LOGIN_USER_TTL, java.util.concurrent.TimeUnit.MINUTES);return true;}@Overridepublic void afterCompletion(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, Object handler, Exception ex) throws Exception {// 移除用户UserHolder.removeUser();}
}

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

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

相关文章

if/case条件测试语句

一 条件测试 1.1返回码 $? $? 返回码 用来哦按段命令或者脚本是否执行成功 0 true为真就是成功成立 非0 false 失败或者异常 1.2 test 命令 可以进行条件测试 然后根据返回值来判断条件是否成立 -e &#xff1a;exist 测试目录或者目录是否存在 -d : director…

【产品经理】订单处理6-审单方案

电商系统中订单管理员会对特殊类型的订单进行审核&#xff0c;普通订单则自动审核&#xff0c;本节讲述自动审单方案、手动审单以及加急审单。 一、自动审单 自动审单方案可按照方案形式制定&#xff0c;可一次性制定多套审单方案。 1. 审单通过条件有 执行店铺&#xff…

同三维T80006EHL-4K30CN 单路4K30 HDMI编码器(全国产化)

同三维T80006EHL-4K30CN 单路4K30 HDMI编码器 带1路HDMI环出和1路3.5音频输入&#xff0c;支持4K30&#xff0c;所有元器件全国产 一、 产品简介&#xff1a; T80006EHL-4K30CN 4K编码器&#xff08;采集盒&#xff09;是一款全国产化的专业4K HDMI音视频编码产品&#xff0c;…

2024年先进机械电子、电气工程与自动化国际学术会议(ICAMEEA 2024)

2024年先进机械电子、电气工程与自动化国际学术会议(ICAMEEA 2024) 2024 International Conference on Advanced Mechatronic, Electrical Engineering and Automation 会议地点&#xff1a;杭州&#xff0c;中国 网址&#xff1a;www.icameea.com 邮箱: icameeasub-conf.c…

5.How Fast Should You Be When Learning?(你应该用多快的速度学习?)

Normally when I talk about learing quickly, I’m using speed as a synonym for efficiency.Use more effective methods and you’ll learn more in less time.All else being equal, that means you’re learing faster. 通常我在谈到快速学习时&#xff0c;是把“速度&qu…

【自记录】记一台i7四代老爷笔记本重装Win10 22H2

1 背景 手上有一台退役的老爷笔记本&#xff0c;清华同方锋锐 U430。因为比较轻便&#xff0c;最近重新翻出来用于临时抓个包和简单的脚本语言&#xff08;比方说Python&#xff09;编辑工作。但是现在像VSCode的新版本都要求Win10以上&#xff0c;像Continue这类的AI插件都跑…

ssh-add id_rsa_gitlab1 Error connecting to agent: No such file or directory

ssh-add id_rsa_gitlab1 Error connecting to agent: No such file or directory 目录 ssh-add id_rsa_gitlab1 Error connecting to agent: No such file or directory1. 启动 SSH 代理2. 添加 SSH 密钥3. 使用 Git Bash 或其他终端4. 使用 Pageant&#xff08;适用于 PuTTY 用…

基于DDD的编码实践

分层设计 领域驱动设计&#xff08;Domain-driven design, DDD&#xff09; 作为一种复杂软件系统的应对方案&#xff0c;在设计和编码提供了一种新的解决方式&#xff0c;即领域驱动&#xff0c;要求程序员在设计和编码时从领域专家的角度出发来实现架构/代码&#xff0c;做到…

工作随机:oracle集群下的vip intermediate,failed over处理

文章目录 前言一、问题排查二、恢复db2使用1.确认db2 vip状态2.恢复db2 的vip3.检查监听&#xff1a; 前言 在对数据库进行巡检发现&#xff0c;集群中一个节点的备份没有执行&#xff0c;未生成当天的任何日志&#xff0c;查询/var/spool/oracle 信息发现提示&#xff1a;no …

经验分享,在线文本比较工具

这里分享一个在线文本比较工具&#xff0c;打开网页即用&#xff0c;很方便 网址&#xff1a; https://www.jq22.com/textDifference 截图&#xff1a;

Python语言在地球科学交叉领域中的实践技术融合应用

Python是功能强大、免费、开源&#xff0c;实现面向对象的编程语言&#xff0c;Python能够运行在Linux、Windows、Macintosh、AIX操作系统上及不同平台&#xff08;x86和arm&#xff09;&#xff0c;Python简洁的语法和对动态输入的支持&#xff0c;再加上解释性语言的本质&…

代码审计中XSS挖掘一些体会

0x01 XSS的挖掘思路 1.1 反射型 直接搜索 echo print_r print之类的函数即可 也可以寻找$_GET变量来判断是否存在输出&#xff08;不过对于代码审计来说除非实在挖不出漏洞&#xff0c;否则没必要关注反射xss&#xff09; 1.2 dom型 和反射型差不多 需要看网站的前端javascr…

openGauss 6.0一主二备高可用架构部署,可靠很行

作者&#xff1a;IT邦德 中国DBA联盟(ACDU)成员&#xff0c;10余年DBA工作经验&#xff0c; Oracle、PostgreSQL ACE CSDN博客专家及B站知名UP主&#xff0c;全网粉丝10万 擅长主流Oracle、MySQL、PG、高斯及Greenplum备份恢复&#xff0c; 安装迁移&#xff0c;性能优化、故障…

MySQL JDBC驱动包引入有版本要求吗

提示&#xff1a;有关数据库的任何操作&#xff0c;请事先都做好备份&#xff0c;一定不会错的&#xff1b; 文章目录 前言一、com.mysql.jdbc.Driver和com.mysql.cj.jdbc.Driver如何选择&#xff1f;1、概念2、引入驱动3、总结 前言 新老项目的交替中&#xff0c;如果你使用的…

【并发编程实战】内存模型--解决可见性和有序性的利器

一.前言 在前面讲了三个问题&#xff0c; 缓存导致的可见性问题&#xff0c;编译优化带来的有序性问题&#xff0c;线程切换带来的原子性问题。既然存在问题&#xff0c;那么总要有解决方案的&#xff0c;这一章里主要就是解决这三个问题的关键点--内存模型 二.内存模型 2.1 …

hdfs高可用文件系统架构

1、整体架构 2、角色简介 2.1、namenode NameNode 是 HDFS 集群中的核心组件&#xff0c;负责管理文件系统的元数据、处理客户端请求、管理数据块、确保数据完整性和高可用性。由于其重要性&#xff0c;NameNode 的性能和可靠性直接影响整个 HDFS 集群的性能和可靠性。在生产…

【漏洞复现】CRMEB开源电商系统 /api/products SQL注入漏洞(CVE-2024-36837)

0x01 产品简介 CRMEB开源电商系统是一款由西安众邦网络科技有限公司打造的全栈式电商解决方案&#xff0c;旨在为开发者和商家提供高性能、智能化的电商平台服务。该系统集成了CRM(客户关系管理)、ERP(企业资源规划)和EB(电子商务)的功能&#xff0c;通过深度结合这些功能&…

1.4k star 项目 CMakeTutorial 阅读和点评

1.4k star 项目 CMakeTutorial 阅读和点评 文章目录 1.4k star 项目 CMakeTutorial 阅读和点评0. 概要1. CUDA 目录2. FindPackage 目录3. Installation 目录4. PackageManage 目录5. PythonExtension 目录6. ImportExternalProject 目录总结 0. 概要 在 github 搜索关键字 CM…

骨传导耳机品牌排行前五名揭晓:精选5款音质卓越、佩戴舒适的优选产品!

骨传导耳机是目前非常热门的蓝牙耳机&#xff0c;有很多人都想去尝试&#xff0c;但又很多消费者再入手后&#xff0c;都出现了佩戴不舒服&#xff0c;音质刺耳等问题&#xff0c;作为一位拥有十多年经验的数码测评师&#xff0c;我有必要提醒大家&#xff0c;尽管市面上各种骨…

【2024最新华为OD-C/D卷试题汇总】[支持在线评测] A先生的货运计划(200分) - 三语言AC题解(Python/Java/Cpp)

🍭 大家好这里是清隆学长 ,一枚热爱算法的程序员 ✨ 本系列打算持续跟新华为OD-C/D卷的三语言AC题解 💻 ACM银牌🥈| 多次AK大厂笔试 | 编程一对一辅导 👏 感谢大家的订阅➕ 和 喜欢💗 📎在线评测链接 A先生的货运计划(200分) 🌍 评测功能需要 订阅专栏 后私信…