快捷導(dǎo)航

Redis實(shí)現(xiàn)短信登錄的示例代碼

更新時(shí)間：2023年07月04日 15:30:22 作者：Cimbala

本文主要介紹了Redis實(shí)現(xiàn)短信登錄的示例代碼，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

一、基于Session實(shí)現(xiàn)登錄

---------------------------------------------------Controller
@PostMapping("code")
public Result sendCode(@RequestParam("phone") String phone, HttpSession session) {
    //發(fā)送短信驗(yàn)證碼并保存驗(yàn)證碼
    return userService.sendCode(phone,session);
}
@PostMapping("/login")
public Result login(@RequestBody LoginFormDTO loginForm, HttpSession session){
    //實(shí)現(xiàn)登錄功能  loginForm 登錄參數(shù)，包含手機(jī)號(hào)、驗(yàn)證碼；或者手機(jī)號(hào)、密碼
    return userService.login(loginForm,session);
}
@GetMapping("/me")
public Result me(){
    // 獲取當(dāng)前登錄的用戶并返回
    UserDTO user = UserHolder.getUser();
    return Result.ok(user);
}
---------------------------------------------------Service
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {
    @Override
    public Result sendCode(String phone, HttpSession session) {
        if(RegexUtils.isPhoneInvalid(phone)){
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤");
        }
        String code = RandomUtil.randomNumbers(6);
        session.setAttribute("code",code);
        log.debug("短信驗(yàn)證碼" + code);
        return Result.ok();
    }
    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        if(RegexUtils.isPhoneInvalid(loginForm.getPhone())){
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤");
        }
        Object catchCode = session.getAttribute("code");
        String code = loginForm.getCode();
        if(catchCode == null || !catchCode.equals(code)){
            Result.fail("驗(yàn)證碼錯(cuò)誤");
        }
        User user = query().eq("phone", loginForm.getPhone()).one();
        if (user == null) {
            user = createUserWithPhone(loginForm.getPhone());
        }
        session.setAttribute("user", BeanUtil.copyProperties(user, UserDTO.class));
        return Result.ok();
    }
    private User createUserWithPhone(String phone) {
        User user = new User();
        user.setPhone(phone);
        user.setNickName(USER_NICK_NAME_PREFIX + RandomUtil.randomNumbers(3));
        save(user);
        return user;
   	}
}
---------------------------------------------------自定義攔截器
public class LoginInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        HttpSession session = request.getSession();
        Object user = session.getAttribute("user");
        if (user == null) {
            response.setStatus(401);
            return false;
        }
        UserHolder.saveUser((UserDTO) user);
        return true;
    }
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        UserHolder.removeUser();
    }
}
---------------------------------------------------添加攔截器并指定攔截的請(qǐng)求和不攔截的請(qǐng)求
@Configuration
public class MvcConfig implements WebMvcConfigurer {
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
   		 //實(shí)現(xiàn)WebMvcConfigurer接口中的addInterceptors方法把自定義的攔截器類添加進(jìn)來(lái)即可
        registry.addInterceptor(new LoginInterceptor()).excludePathPatterns(
                "/user/code",
                "/user/login",
                "/blog/hot",
                "/shop/**",
                "/shop-type/**",
                "/voucher/**"
        );
    }
}

總結(jié)： 短信驗(yàn)證碼用隨機(jī)工具生成6位數(shù)，保存了session中，在用戶使用手機(jī)號(hào)登錄時(shí)，獲取session中的驗(yàn)證碼和請(qǐng)求參數(shù)中的驗(yàn)證碼比對(duì)，一致則去庫(kù)里查該手機(jī)號(hào)的用戶是否存在，不存在則新建用戶，并把該用戶對(duì)象存在在session中。校驗(yàn)登錄狀態(tài)是使用HandlerInterceptor攔截器實(shí)現(xiàn)的，在此之前需要配置攔截哪些請(qǐng)求，不攔截哪些請(qǐng)求，從客戶端的請(qǐng)求中獲取session信息，為空返回401狀態(tài)，不為空則把用戶信息存儲(chǔ)在ThreadLocal中，在請(qǐng)求處理完之后銷毀用戶信息。

問(wèn)題： 集群的session共享問(wèn)題。多臺(tái)Tomcat并不共享session存儲(chǔ)空間，當(dāng)請(qǐng)求切換到不同Tomcat服務(wù)時(shí)導(dǎo)致數(shù)據(jù)丟失的問(wèn)題。早期的Tomcat提供session拷貝功能，但是并不能解決問(wèn)題，問(wèn)題有1.多臺(tái)Tomcat保存相同的數(shù)據(jù)信息，內(nèi)存空間浪費(fèi)；2.拷貝需要時(shí)間，在延遲之內(nèi)有用戶訪問(wèn)，多臺(tái)Tomcat依然存在數(shù)據(jù)不一致。

二、基于Redis實(shí)現(xiàn)共享Session實(shí)現(xiàn)登錄

-------------------只記錄有變化的--------------------------------Service
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {
    @Resource
    private StringRedisTemplate stringRedisTemplate;
    @Override
    public Result sendCode(String phone, HttpSession session) {
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤");
        }
        String code = RandomUtil.randomNumbers(6);
        stringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY + phone, code, LOGIN_CODE_TTL, TimeUnit.MINUTES);
        log.debug("短信驗(yàn)證碼" + code);
        return Result.ok();
    }
    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        String phone = loginForm.getPhone();
        if (RegexUtils.isPhoneInvalid(phone)) {
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤");
        }
        String cacheCode = stringRedisTemplate.opsForValue().get(LOGIN_CODE_KEY + phone);
        String code = loginForm.getCode();
        if (cacheCode == null || !cacheCode.equals(code)) {
            return Result.fail("驗(yàn)證碼錯(cuò)誤");
        }
        User user = query().eq("phone", phone).one();
        if (user == null) {
            user = createUserWithPhone(phone);
        }
        String token = UUID.randomUUID().toString(true);
        UserDTO userDTO = BeanUtil.copyProperties(user, UserDTO.class);
        Map<String, Object> userMap = BeanUtil.beanToMap(userDTO, new HashMap<>(),CopyOptions.create()
                .setIgnoreNullValue(true).setFieldValueEditor((fieldName, fieldValue) -> fieldValue.toString()));
        stringRedisTemplate.opsForHash().putAll(LOGIN_USER_KEY + token, userMap);
        stringRedisTemplate.expire(LOGIN_USER_KEY + token, LOGIN_USER_TTL, TimeUnit.MINUTES);
        return Result.ok(token);
    }
}
---------------------------------------------------添加攔截器并指定攔截的請(qǐng)求和不攔截的請(qǐng)求
@Configuration
public class MvcConfig implements WebMvcConfigurer {
    @Resource
    private StringRedisTemplate stringRedisTemplate;
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new LoginInterceptor()).excludePathPatterns(
                "/user/code",
                "/user/login",
                "/blog/hot",
                "/shop/**",
                "/shop-type/**",
                "/voucher/**"
        ).order(1);
        registry.addInterceptor(new RefreshTokenInterceptor(stringRedisTemplate)).addPathPatterns("/**").order(0);
    }
}
---------------------------------------------------自定義攔截器
public class LoginInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        //判斷ThreadLocal中是否有用戶
        if(UserHolder.getUser() == null){
            response.setStatus(401);
            return false;
        }
        return true;
    }
}
public class RefreshTokenInterceptor implements HandlerInterceptor {
    private StringRedisTemplate stringRedisTemplate;
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String token = request.getHeader("authorization");
        if (StrUtil.isBlank(token)) {
            return true;
        }
        Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(RedisConstants.LOGIN_USER_KEY + token);
        if (userMap.isEmpty()) {
            return true;
        }
        UserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);
        //保存在ThreadLocal中
        UserHolder.saveUser(userDTO);
        //刷新token有效期
        stringRedisTemplate.expire(RedisConstants.LOGIN_USER_KEY + token,RedisConstants.LOGIN_USER_TTL, TimeUnit.MINUTES);
        return true;
    }
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        UserHolder.removeUser();
    }
    public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate) {
        this.stringRedisTemplate = stringRedisTemplate;
    }
}

總結(jié)： 短信驗(yàn)證碼修改為以手機(jī)號(hào)為key驗(yàn)證碼為value保存在redis中，在用戶使用手機(jī)號(hào)登錄時(shí)，獲取redis中的驗(yàn)證碼和請(qǐng)求參數(shù)中的驗(yàn)證碼比對(duì)，一致則去庫(kù)里查該手機(jī)號(hào)的用戶是否存在，不存在則新建用戶，并把該用戶對(duì)象存在在redis中。校驗(yàn)登錄狀態(tài)是使用HandlerInterceptor攔截器實(shí)現(xiàn)的，在此之前需要配置攔截哪些請(qǐng)求，不攔截哪些請(qǐng)求，從客戶端的請(qǐng)求頭中獲取token信息，并從redis中獲取用戶信息， 為空返回401狀態(tài)，不為空則把用戶信息存儲(chǔ)在ThreadLocal中，還把驗(yàn)證碼和用戶信息設(shè)置有效時(shí)間，時(shí)間一過(guò)，則退出用戶登錄。在請(qǐng)求處理完之后銷毀用戶信息。

改造的點(diǎn)：

發(fā)送短信驗(yàn)證碼時(shí)，key使用手機(jī)號(hào)來(lái)確保唯一存儲(chǔ)在redis中，在用戶登錄時(shí)可以根據(jù)key來(lái)取出驗(yàn)證碼校對(duì)。
短信驗(yàn)證碼登錄時(shí)，key使用UUID來(lái)確保唯一存儲(chǔ)在redis中，為確保將來(lái)前端能把token發(fā)送過(guò)來(lái)進(jìn)行校驗(yàn)，在請(qǐng)求結(jié)束前把token返回給客戶端。

問(wèn)題：

1.攔截器能否真正的實(shí)現(xiàn)只要用戶一直在訪問(wèn)，token就不會(huì)過(guò)期？

不行，因?yàn)閿r截器只攔截需要登錄的路徑，如果用戶在有效期內(nèi)一直訪問(wèn)不需要登錄的路徑，那么redis中的token就會(huì)過(guò)期。問(wèn)題解決如下圖。