欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Redis的共享session應(yīng)用實(shí)現(xiàn)短信登錄

 更新時(shí)間：2022年08月17日 08:45:30   作者：吞吞吐吐大魔王  
本文主要介紹了Redis的共享session應(yīng)用實(shí)現(xiàn)短信登錄，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧

1. 基于 session 實(shí)現(xiàn)短信登錄

1.1 短信登錄流程圖

1.2 實(shí)現(xiàn)發(fā)送短信驗(yàn)證碼

前端請(qǐng)求說(shuō)明：

 說(shuō)明
請(qǐng)求方式POST
請(qǐng)求路徑/user/code
請(qǐng)求參數(shù)phone（電話(huà)號(hào)碼）
返回值無(wú)

后端接口實(shí)現(xiàn)：

@Slf4j
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

    @Override
    public Result sendCode(String phone, HttpSession session) {
        // 1. 校驗(yàn)手機(jī)號(hào)
        if(RegexUtils.isPhoneInvalid(phone)){
            // 2. 如果不符合，返回錯(cuò)誤信息
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤！");
        }
        // 3. 符合，生成驗(yàn)證碼（設(shè)置生成6位）
        String code = RandomUtil.randomNumbers(6);
        // 4. 保存驗(yàn)證碼到 session
        session.setAttribute("code", code);
        // 5. 發(fā)送驗(yàn)證碼（這里并未實(shí)現(xiàn)，通過(guò)日志記錄）
        log.debug("發(fā)送短信驗(yàn)證碼成功，驗(yàn)證碼：{}", code);
        // 返回 ok
        return Result.ok();
    }
}

1.3 實(shí)現(xiàn)短信驗(yàn)證碼登錄、注冊(cè)

前端請(qǐng)求說(shuō)明

 說(shuō)明
請(qǐng)求方式POST
請(qǐng)求路徑/user/login
請(qǐng)求參數(shù)phone（電話(huà)號(hào)碼）；code（驗(yàn)證碼）
返回值無(wú)

后端接口實(shí)現(xiàn)：

@Slf4j
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        // 1. 校驗(yàn)手機(jī)號(hào)
        String phone = loginForm.getPhone();
        if(RegexUtils.isPhoneInvalid(phone)){
            // 不一致，返回錯(cuò)誤信息
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤！");
        }
        // 2. 校驗(yàn)驗(yàn)證碼
        String cacheCode = (String) session.getAttribute("code");
        String code = loginForm.getCode();
        if(cacheCode == null || !cacheCode.equals(cacheCode)){
            // 不一致，返回錯(cuò)誤信息
            return Result.fail("驗(yàn)證碼錯(cuò)誤！");
        }
        // 4. 一致，根據(jù)手機(jī)號(hào)查詢(xún)用戶(hù)（這里使用的 mybatis-plus）
        User user = query().eq("phone", phone).one();
        // 5. 判斷用戶(hù)是否存在
        if(user == null){
            // 6. 不存在，創(chuàng)建新用戶(hù)并保存
            user = createUserWithPhone(phone);
        }
        	// 7. 保存用戶(hù)信息到 session 中（通過(guò) BeanUtil.copyProperties 方法將 user 中的信息過(guò)濾到 UserDTO 上，即用來(lái)隱藏部分信息）
        session.setAttribute("user", BeanUtil.copyProperties(user, UserDTO.class));
        return Result.ok();
    }

    private User createUserWithPhone(String phone) {
        // 1. 創(chuàng)建用戶(hù)
        User user = new User();
        user.setPhone(phone);
        user.setNickName("user_" + RandomUtil.randomString(10));
        // 2. 保存用戶(hù)（這里使用 mybatis-plus）
        save(user);
        return user;
    }
}

1.4 實(shí)現(xiàn)登錄校驗(yàn)攔截器

登錄校驗(yàn)攔截器實(shí)現(xiàn)：

public class LoginInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 1. 獲取 session
        HttpSession session = request.getSession();
        // 2. 獲取 session 中的用戶(hù)
        UserDTO user = (UserDTO) session.getAttribute("user");
        // 3. 判斷用戶(hù)是否存在
        if(user == null){
            // 4. 不存在，攔截，返回 401 未授權(quán)
            response.setStatus(401);
            return false;
        }
        // 5. 存在，保存用戶(hù)信息到 ThreadLocal
        UserHolder.saveUser(user);
        // 6. 放行
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 移除用戶(hù)，避免內(nèi)存泄露
        UserHolder.removeUser();
    }
}

UserHolder 類(lèi)的實(shí)現(xiàn)： 該類(lèi)中定義了一個(gè)靜態(tài)的 ThreadLocal

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();
    }
}

配置攔截器：

@Configuration
public class MvcConfig implements WebMvcConfigurer {

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new LoginInterceptor())
                .excludePathPatterns(
                        "/user/login",
                        "/user/code"
                );
    }
}

前端請(qǐng)求說(shuō)明：

 說(shuō)明
請(qǐng)求方式POST
請(qǐng)求路徑/user/me
請(qǐng)求參數(shù)無(wú)
返回值無(wú)

后端接口實(shí)現(xiàn)：

@Slf4j
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

    @Override
    public Result me() {
        UserDTO user = UserHolder.getUser();
        return Result.ok(user);
    }
}

2. 集群的 session 共享問(wèn)題

session 共享問(wèn)題：

多臺(tái) tomcat 并不共享 session 存儲(chǔ)空間，當(dāng)請(qǐng)求切換到不同 tomcat 服務(wù)時(shí)會(huì)導(dǎo)致數(shù)據(jù)丟失的問(wèn)題。

session 的替代方案應(yīng)該滿(mǎn)足以下條件：

  • 數(shù)據(jù)共享（不同的 tomcat 都能夠訪(fǎng)問(wèn) Redis 中的數(shù)據(jù)）
  • 內(nèi)存存儲(chǔ)（Redis 通過(guò)內(nèi)存存儲(chǔ)）
  • key、value 結(jié)構(gòu)（Redis 是 key-value 結(jié)構(gòu)）

3. 基于 Redis 實(shí)現(xiàn)共享 session 登錄

3.1 Redis 實(shí)現(xiàn)共享 session 登錄流程圖

3.2 實(shí)現(xiàn)發(fā)送短信驗(yàn)證碼

前端請(qǐng)求說(shuō)明：

 說(shuō)明
請(qǐng)求方式POST
請(qǐng)求路徑/user/code
請(qǐng)求參數(shù)phone（電話(huà)號(hào)碼）
返回值無(wú)

后端接口實(shí)現(xiàn)：

@Slf4j
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @Override
    public Result sendCode(String phone, HttpSession session) {
        // 1. 校驗(yàn)手機(jī)號(hào)
        if (RegexUtils.isPhoneInvalid(phone)) {
            // 2. 如果不符合，返回錯(cuò)誤信息
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤！");
        }
        // 3. 符合，生成驗(yàn)證碼（設(shè)置生成6位）
        String code = RandomUtil.randomNumbers(6);
        // 4. 保存驗(yàn)證碼到 Redis（以手機(jī)號(hào)為 key，設(shè)置有效期為 2min）
        stringRedisTemplate.opsForValue().set("login:code:" + phone, code, 2, TimeUnit.MINUTES);
        // 5. 發(fā)送驗(yàn)證碼（這里并未實(shí)現(xiàn)，通過(guò)日志記錄）
        log.debug("發(fā)送短信驗(yàn)證碼成功，驗(yàn)證碼：{}", code);
        // 返回 ok
        return Result.ok();
    }
}

3.3 實(shí)現(xiàn)短信驗(yàn)證碼登錄、注冊(cè)

前端請(qǐng)求說(shuō)明：

 說(shuō)明
請(qǐng)求方式POST
請(qǐng)求路徑/user/login
請(qǐng)求參數(shù)phone（電話(huà)號(hào)碼）；code（驗(yàn)證碼）
返回值無(wú)

后端接口實(shí)現(xiàn)：

@Slf4j
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        // 1. 校驗(yàn)手機(jī)號(hào)
        String phone = loginForm.getPhone();
        if(RegexUtils.isPhoneInvalid(phone)){
            // 不一致，返回錯(cuò)誤信息
            return Result.fail("手機(jī)號(hào)格式錯(cuò)誤！");
        }
        // 2. 校驗(yàn)驗(yàn)證碼
        String cacheCode = (String) session.getAttribute("code");
        String code = loginForm.getCode();
        if(cacheCode == null || !cacheCode.equals(cacheCode)){
            // 不一致，返回錯(cuò)誤信息
            return Result.fail("驗(yàn)證碼錯(cuò)誤！");
        }
        // 4. 一致，根據(jù)手機(jī)號(hào)查詢(xún)用戶(hù)（這里使用的 mybatis-plus）
        User user = query().eq("phone", phone).one();
        // 5. 判斷用戶(hù)是否存在
        if(user == null){
            // 6. 不存在，創(chuàng)建新用戶(hù)并保存
            user = createUserWithPhone(phone);
        }
        	// 7. 保存用戶(hù)信息到 session 中（通過(guò) BeanUtil.copyProperties 方法將 user 中的信息過(guò)濾到 UserDTO 上，即用來(lái)隱藏部分信息）
        session.setAttribute("user", BeanUtil.copyProperties(user, UserDTO.class));
        return Result.ok();
    }

    private User createUserWithPhone(String phone) {
        // 1. 創(chuàng)建用戶(hù)
        User user = new User();
        user.setPhone(phone);
        user.setNickName("user_" + RandomUtil.randomString(10));
        // 2. 保存用戶(hù)（這里使用 mybatis-plus）
        save(user);
        return user;
    }
}

3.4 實(shí)現(xiàn)登錄校驗(yàn)攔截器

這里將原有的一個(gè)攔截器分成兩個(gè)攔截器，第一個(gè)攔截器對(duì)所有的請(qǐng)求進(jìn)行攔截，每次攔截刷新 token 的有效期，并將能查詢(xún)到的用戶(hù)信息保存到 ThreadLocal 中。第二個(gè)攔截器則進(jìn)行攔截功能，對(duì)需要登錄的路徑進(jìn)行攔截。

刷新 token 攔截器實(shí)現(xiàn)：

public class RefreshTokenInterceptor implements HandlerInterceptor {

    private StringRedisTemplate stringRedisTemplate;

    public RefreshTokenInterceptor(StringRedisTemplate stringRedisTemplate){
        this.stringRedisTemplate = stringRedisTemplate;
    }

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 1. 獲取請(qǐng)求頭中的 token
        String token = request.getHeader("authorization");
        if (StrUtil.isBlank(token)) {
            return true;
        }
        // 2. 基于 token 獲取 redis 中的用戶(hù)
        String tokenKey = "login:token:" + token;
        Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(tokenKey);
        // 3. 判斷用戶(hù)是否存在
        if (userMap.isEmpty()) {
            return true;
        }
        // 5. 將查詢(xún)到的 Hash 數(shù)據(jù)轉(zhuǎn)為 UserDTO 對(duì)象
        UserDTO user = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);
        // 6. 存在，保存用戶(hù)信息到 ThreadLocal
        UserHolder.saveUser(user);
        // 7. 刷新 token 有效期 30 min
        stringRedisTemplate.expire(tokenKey, 30, TimeUnit.MINUTES);
        // 8. 放行
        return true;
    }
}

登錄校驗(yàn)攔截器實(shí)現(xiàn)：

public class LoginInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 1. 獲取 session
        HttpSession session = request.getSession();
        // 2. 獲取 session 中的用戶(hù)
        UserDTO user = (UserDTO) session.getAttribute("user");
        // 3. 判斷用戶(hù)是否存在
        if(user == null){
            // 4. 不存在，攔截，返回 401 未授權(quán)
            response.setStatus(401);
            return false;
        }
        // 5. 存在，保存用戶(hù)信息到 ThreadLocal
        UserHolder.saveUser(user);
        // 6. 放行
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 移除用戶(hù)，避免內(nèi)存泄露
        UserHolder.removeUser();
    }
}

UserHolder 類(lèi)的實(shí)現(xiàn)： 該類(lèi)中定義了一個(gè)靜態(tài)的 ThreadLocal

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();
    }
}

配置攔截器：

@Configuration
public class MvcConfig implements WebMvcConfigurer {

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new RefreshTokenInterceptor(stringRedisTemplate))
                .addPathPatterns("/**").order(0);
        registry.addInterceptor(new LoginInterceptor())
                .excludePathPatterns(
                        "/user/login",
                        "/user/code"
                ).order(1);
    }
}

前端請(qǐng)求說(shuō)明：

 說(shuō)明
請(qǐng)求方式POST
請(qǐng)求路徑/user/me
請(qǐng)求參數(shù)無(wú)
返回值無(wú)

后端接口實(shí)現(xiàn)：

@Slf4j
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {

    @Override
    public Result me() {
        UserDTO user = UserHolder.getUser();
        return Result.ok(user);
    }
}

到此這篇關(guān)于Redis的共享session應(yīng)用實(shí)現(xiàn)短信登錄的文章就介紹到這了,更多相關(guān)Redis session 短信登錄內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

相關(guān)文章

  • Redisson實(shí)現(xiàn)Redis分布式鎖的幾種方式

    Redisson實(shí)現(xiàn)Redis分布式鎖的幾種方式

    本文在講解如何使用Redisson實(shí)現(xiàn)Redis普通分布式鎖，以及Redlock算法分布式鎖的幾種方式的同時(shí)，也附帶解答這些同學(xué)的一些疑問(wèn)，感興趣的可以了解一下
    2021-08-08
  • 提高redis緩存命中率的方法

    提高redis緩存命中率的方法

    在本篇文章里小編給大家整理了關(guān)于怎么提高redis緩存命中率的相關(guān)知識(shí)點(diǎn)內(nèi)容，有興趣的朋友們跟著學(xué)習(xí)下。
    2019-06-06
  • 關(guān)于Redis中bitmap的原理和使用詳解

    關(guān)于Redis中bitmap的原理和使用詳解

    這篇文章主要介紹了關(guān)于Redis中bitmap的原理和使用詳解,BitMap即位圖，使用每個(gè)位表示某種狀態(tài)，適合處理整型的海量數(shù)據(jù),本質(zhì)上是哈希表的一種應(yīng)用實(shí)現(xiàn),需要的朋友可以參考下
    2023-05-05
  • Redis的LRU機(jī)制介紹

    Redis的LRU機(jī)制介紹

    這篇文章主要介紹了Redis的LRU機(jī)制介紹,Redis會(huì)按LRU算法刪除設(shè)置了過(guò)期時(shí)間但還沒(méi)有過(guò)期的key,而對(duì)于沒(méi)有設(shè)置過(guò)期時(shí)間的key,Redis是永遠(yuǎn)保留的,需要的朋友可以參考下
    2015-06-06
  • 推薦幾款 Redis 可視化工具(太厲害了)

    推薦幾款 Redis 可視化工具(太厲害了)

    這篇文章主要介紹了推薦幾款 Redis 可視化工具,小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧
    2021-04-04
  • redis中zSet實(shí)現(xiàn)排行榜的使用示例

    redis中zSet實(shí)現(xiàn)排行榜的使用示例

    在工作中,有時(shí)候需要實(shí)現(xiàn)排行榜功能，本文主要介紹了redis中zSet實(shí)現(xiàn)排行榜的使用示例，具有一定的參考價(jià)值，感興趣的可以了解一下
    2023-10-10
  • 一文帶你了解Redis中RDB與AOF的區(qū)別

    一文帶你了解Redis中RDB與AOF的區(qū)別

    Redis 在持久化時(shí)，給我們提供了兩種方式，這兩種方式就是 RDB 與 AOF，那這兩種方式有什么區(qū)別呢，本文就帶大家詳細(xì)的了解一下二者的區(qū)別,需要的朋友可以參考下
    2023-06-06
  • 關(guān)于Redis的讀寫(xiě)一致問(wèn)題

    關(guān)于Redis的讀寫(xiě)一致問(wèn)題

    在項(xiàng)目使用Redis過(guò)程中,當(dāng)數(shù)據(jù)更新時(shí),我們要保證緩存和數(shù)據(jù)庫(kù)的一致性,否則會(huì)導(dǎo)致很多臟數(shù)據(jù)出現(xiàn),此時(shí)我們就要思考如何去進(jìn)行數(shù)據(jù)更新,本文就給大家講講關(guān)于redis的讀寫(xiě)一致問(wèn)題,需要的朋友可以參考下
    2023-08-08
  • Redisson 主從一致性問(wèn)題詳解

    Redisson 主從一致性問(wèn)題詳解

    這篇文章主要為大家介紹了Redisson 主從一致性問(wèn)題詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪
    2022-08-08
  • Redis教程(八)：事務(wù)詳解

    Redis教程(八)：事務(wù)詳解

    這篇文章主要介紹了Redis教程(八)：事務(wù)詳解,本文講解了,本文講解了事務(wù)概述、相關(guān)命令列表、命令使用示例、WATCH命令和基于CAS的樂(lè)觀鎖等內(nèi)容,需要的朋友可以參考下
    2015-04-04

最新評(píng)論