Redis 共有セッションアプリケーションは SMS ログインを実装します-Redis-php.cn

この記事では、Redisの関連知識を中心に、SMSログインを実現するためのRedisの共有セッションアプリケーションを中心に、サンプルコードを通して詳しく紹介しています。皆様の勉強や仕事の参考学習値として、皆様のお役に立てれば幸いです。

Redis 共有セッションアプリケーションは SMS ログインを実装します

1. セッションに基づいて SMS ログインを実装する

1.1 SMS ログインフローチャート

1.2 SMS 確認コード送信の実装

フロントエンドリクエスト手順:

	説明
リクエストメソッド	POST
リクエストパス	/user/code
リクエストパラメータ	phone(電話番号)
戻り値	なし

バックエンドインターフェイスの実装:

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

    @Override
    public Result sendCode(String phone, HttpSession session) {
        // 1. 校验手机号
        if(RegexUtils.isPhoneInvalid(phone)){
            // 2. 如果不符合，返回错误信息
            return Result.fail("手机号格式错误！");
        }
        // 3. 符合，生成验证码（设置生成6位）
        String code = RandomUtil.randomNumbers(6);
        // 4. 保存验证码到 session
        session.setAttribute("code", code);
        // 5. 发送验证码（这里并未实现，通过日志记录）
        log.debug("发送短信验证码成功，验证码：{}", code);
        // 返回 ok
        return Result.ok();
    }
}

ログイン後にコピー

1.3 SMS 確認コードのログインと登録を実装します

フロントエンドリクエスト手順

#リクエスト方法## リクエストパス/user/loginリクエストパラメータphone (電話番号); code (検証コード)戻り値なしバックエンドインターフェイスの実装:

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

    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        // 1. 校验手机号
        String phone = loginForm.getPhone();
        if(RegexUtils.isPhoneInvalid(phone)){
            // 不一致，返回错误信息
            return Result.fail("手机号格式错误！");
        }
        // 2. 校验验证码
        String cacheCode = (String) session.getAttribute("code");
        String code = loginForm.getCode();
        if(cacheCode == null || !cacheCode.equals(cacheCode)){
            // 不一致，返回错误信息
            return Result.fail("验证码错误！");
        }
        // 4. 一致，根据手机号查询用户（这里使用的 mybatis-plus）
        User user = query().eq("phone", phone).one();
        // 5. 判断用户是否存在
        if(user == null){
            // 6. 不存在，创建新用户并保存
            user = createUserWithPhone(phone);
        }
        	// 7. 保存用户信息到 session 中（通过 BeanUtil.copyProperties 方法将 user 中的信息过滤到 UserDTO 上，即用来隐藏部分信息）
        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. 保存用户（这里使用 mybatis-plus）
        save(user);
        return user;
    }
}

ログイン後にコピー

	説明
##POST

1.4 ログイン検証の実装interceptor

ログイン検証インターセプター実装:

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 中的用户
        UserDTO user = (UserDTO) session.getAttribute("user");
        // 3. 判断用户是否存在
        if(user == null){
            // 4. 不存在，拦截，返回 401 未授权
            response.setStatus(401);
            return false;
        }
        // 5. 存在，保存用户信息到 ThreadLocal
        UserHolder.saveUser(user);
        // 6. 放行
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 移除用户，避免内存泄露
        UserHolder.removeUser();
    }
}

ログイン後にコピー

UserHolder クラス実装: このクラスは静的 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 インターセプターを定義します:

@Configuration
public class MvcConfig implements WebMvcConfigurer {

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

ログイン後にコピー

フロントエンドリクエスト説明:

説明リクエストメソッドPOSTリクエストパス/user/meリクエストパラメータなしなしバックエンドインターフェイス実装:

@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共有の問題:

複数の Tomcat はセッションストレージスペースを共有しません。リクエストが別の Tomcat サービスに切り替わると、データ損失が発生します。

セッションの代替案は次の条件を満たす必要があります:

データ共有 (さまざまな Tomcat が Redis 内のデータにアクセス可能)

メモリストレージ (メモリストレージを介した Redis)

キー、値の構造 (Redis はキーと値の構造です)

3.1 Redis は共有セッションログインを実装しますフローチャート

##3.2 SMS 認証コード送信の実装

#フロントエンドリクエストの説明:

Descriptionバックエンドインターフェイスの実装: 3.3 SMS 検証コードの実装ログイン、登録フロントエンドリクエストの説明:

リクエストメソッド	POST
リクエストパス	/user/code
リクエストパラメータ	phone(電話番号)
戻り値	なし
	@Slf4j @Service public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService { @Resource private StringRedisTemplate stringRedisTemplate; @Override public Result sendCode(String phone, HttpSession session) { // 1. 校验手机号 if (RegexUtils.isPhoneInvalid(phone)) { // 2. 如果不符合，返回错误信息 return Result.fail("手机号格式错误！"); } // 3. 符合，生成验证码（设置生成6位） String code = RandomUtil.randomNumbers(6); // 4. 保存验证码到 Redis（以手机号为 key，设置有效期为 2min） stringRedisTemplate.opsForValue().set("login:code:" + phone, code, 2, TimeUnit.MINUTES); // 5. 发送验证码（这里并未实现，通过日志记录） log.debug("发送短信验证码成功，验证码：{}", code); // 返回 ok return Result.ok(); } } ログイン後にコピー

説明##POSTリクエストパス #/user/loginリクエストパラメータphone (電話番号); code (検証コード) 戻り値なし

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

    @Override
    public Result login(LoginFormDTO loginForm, HttpSession session) {
        // 1. 校验手机号
        String phone = loginForm.getPhone();
        if(RegexUtils.isPhoneInvalid(phone)){
            // 不一致，返回错误信息
            return Result.fail("手机号格式错误！");
        }
        // 2. 校验验证码
        String cacheCode = (String) session.getAttribute("code");
        String code = loginForm.getCode();
        if(cacheCode == null || !cacheCode.equals(cacheCode)){
            // 不一致，返回错误信息
            return Result.fail("验证码错误！");
        }
        // 4. 一致，根据手机号查询用户（这里使用的 mybatis-plus）
        User user = query().eq("phone", phone).one();
        // 5. 判断用户是否存在
        if(user == null){
            // 6. 不存在，创建新用户并保存
            user = createUserWithPhone(phone);
        }
        	// 7. 保存用户信息到 session 中（通过 BeanUtil.copyProperties 方法将 user 中的信息过滤到 UserDTO 上，即用来隐藏部分信息）
        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. 保存用户（这里使用 mybatis-plus）
        save(user);
        return user;
    }
}

ログイン後にコピー

元のインターセプターは 2 つのインターセプターに分割されています。最初のインターセプターはすべてのリクエストをインターセプトします。このインターセプトにより、トークンの有効期間が更新され、ユーザーが保存されます。 ThreadLocal にクエリできる情報。 2 番目のインターセプターはインターセプト機能を実行し、ログインを必要とするパスをインターセプトします。

リクエストメソッド



バックエンドインターフェイスの実装:	3.4 ログイン検証インターセプターの実装

リフレッシュトークンインターセプターの実装:

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. 获取请求头中的 token
        String token = request.getHeader("authorization");
        if (StrUtil.isBlank(token)) {
            return true;
        }
        // 2. 基于 token 获取 redis 中的用户
        String tokenKey = "login:token:" + token;
        Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(tokenKey);
        // 3. 判断用户是否存在
        if (userMap.isEmpty()) {
            return true;
        }
        // 5. 将查询到的 Hash 数据转为 UserDTO 对象
        UserDTO user = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);
        // 6. 存在，保存用户信息到 ThreadLocal
        UserHolder.saveUser(user);
        // 7. 刷新 token 有效期 30 min
        stringRedisTemplate.expire(tokenKey, 30, TimeUnit.MINUTES);
        // 8. 放行
        return true;
    }
}

ログイン後にコピー

ログイン検証インターセプターの実装:

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 中的用户
        UserDTO user = (UserDTO) session.getAttribute("user");
        // 3. 判断用户是否存在
        if(user == null){
            // 4. 不存在，拦截，返回 401 未授权
            response.setStatus(401);
            return false;
        }
        // 5. 存在，保存用户信息到 ThreadLocal
        UserHolder.saveUser(user);
        // 6. 放行
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 移除用户，避免内存泄露
        UserHolder.removeUser();
    }
}

ログイン後にコピー

UserHolder クラスの実装: このクラスは、静的な 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 インターセプターを定義します。

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

ログイン後にコピー

フロントエンドリクエストの説明:

説明

リクエストメソッドPOSTリクエストパス/user/meリクエストパラメータなし戻り値なしバックエンドインターフェイスの実装:

以上がRedis 共有セッションアプリケーションは SMS ログインを実装しますの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。





@Slf4j @Service public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService { @Override public Result me() { UserDTO user = UserHolder.getUser(); return Result.ok(user); } } ログイン後にコピーログイン後にコピー推奨学習:	Redis ビデオチュートリアル

Redis 共有セッション アプリケーションは SMS ログインを実装します

1. セッションに基づいて SMS ログインを実装する

1.1 SMS ログイン フローチャート

1.2 SMS 確認コード送信の実装

1.3 SMS 確認コードのログインと登録を実装します

複数の Tomcat はセッション ストレージ スペースを共有しません。リクエストが別の Tomcat サービスに切り替わると、データ損失が発生します。

Redis 共有セッションアプリケーションは SMS ログインを実装します

1.1 SMS ログインフローチャート

複数の Tomcat はセッションストレージスペースを共有しません。リクエストが別の Tomcat サービスに切り替わると、データ損失が発生します。