• Springboot 整合 JWT + Redis 实现双Token 校验Demo（简单实现）

    一、新建一个SpringBoot 项目，springboot项目创建过程详见 

    mac idea 创建 springboot 项目_JAVA·Ｄ·WangJing的博客-CSDN博客_mac idea创建springboot项目

    二、SpringBoot 整合使用 Rdis

    SpringBoot 项目 添加 redis配置_JAVA·Ｄ·WangJing的博客-CSDN博客_springboot添加redis

    三、SpringBoot 整合 JWT

    3.1、pom.xml依赖配置

    1. <!-- JWT依赖 -->
    2.  
    3. <dependency>
    4.  
    5. <groupId>io.jsonwebtoken</groupId>
    6.  
    7. <artifactId>jjwt</artifactId>
    8.  
    9. <version>0.7.0</version>
    10.  
    11. </dependency>
    12.  
    13. <dependency>
    14.  
    15. <groupId>com.auth0</groupId>
    16.  
    17. <artifactId>java-jwt</artifactId>
    18.  
    19. <version>3.4.0</version>
    20.  
    21. </dependency>
    22.  
    23. <!-- JSON 解析器和生成器 -->
    24.  
    25. <dependency>
    26.  
    27. <groupId>com.alibaba</groupId>
    28.  
    29. <artifactId>fastjson</artifactId>
    30.  
    31. <version>1.2.83</version>
    32.  
    33. </dependency>

    3.2、application.yml 增加配置

    1. # 应用服务 WEB 访问端口
    2. server:
    3.   port: 8080
    4.  
    5. spring:
    6.   # 应用名称
    7.   application:
    8.     name: jwt-demo
    9.   # redis配置
    10.   redis:
    11.     # 地址
    12.     host: 127.0.0.1
    13.     # 端口，默认为6379
    14.     port: 6379
    15.     # 连接超时时间
    16.     timeout: 10s
    17.     # 密码
    18.     password: wangjing
    19.  
    20. # JWT 配置
    21. jwt:
    22.   # 加密密钥
    23.   secret: wangjing
    24.   # header 名称
    25.   header: Authorization
    26.   # token有效时长 S
    27.   expire:
    28.     accessToken: 3600
    29.     refreshToken: 4000

    3.3、JwtToken 工具类

    1. package com.wangjing.jwtdemo.util;
    2.  
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.wangjing.jwtdemo.constants.Constants;
    5. import com.wangjing.jwtdemo.vo.UserToken;
    6. import com.wangjing.jwtdemo.vo.UserTokenInfo;
    7. import io.jsonwebtoken.Claims;
    8. import io.jsonwebtoken.Jwts;
    9. import io.jsonwebtoken.SignatureAlgorithm;
    10. import org.springframework.beans.BeanUtils;
    11. import org.springframework.beans.factory.annotation.Autowired;
    12. import org.springframework.beans.factory.annotation.Value;
    13. import org.springframework.stereotype.Component;
    14.  
    15. import java.util.Date;
    16.  
    17. /**
    18.  * @author: wangjing
    19.  * @createTime: 2022-11-23 14:55
    20.  * @version: 1.0.0
    21.  * @Description: JwtToken 工具类
    22.  */
    23. @Component
    24. public class JwtTokenUtil {
    25.  
    26.     @Value("${jwt.secret}")
    27.     public String secret;
    28.  
    29.     @Value("${jwt.header}")
    30.     public String header;
    31.  
    32.     @Value("${jwt.expire.accessToken}")
    33.     public Integer accessTokenExpire;
    34.  
    35.     @Value("${jwt.expire.refreshToken}")
    36.     public Integer refreshTokenExpire;
    37.  
    38.     @Autowired
    39.     RedisUtil redisUtil;
    40.  
    41.  
    42.     /**
    43.      * 创建 刷新令牌 与 访问令牌 关联关系
    44.      *
    45.      * @param userToken
    46.      * @param refreshTokenExpireDate
    47.      */
    48.     public void tokenAssociation(UserToken userToken, Date refreshTokenExpireDate) {
    49.         Long time = (refreshTokenExpireDate.getTime() - System.currentTimeMillis()) / 1000 + 100;
    50.         redisUtil.set(userToken.getRefreshToken(), userToken.getAccessToken(), time);
    51.     }
    52.  
    53.     /**
    54.      * 根据 刷新令牌 获取 访问令牌
    55.      *
    56.      * @param refreshToken
    57.      */
    58.     public String getAccessTokenByRefresh(String refreshToken) {
    59.         Object value = redisUtil.get(refreshToken);
    60.         return value == null ? null : String.valueOf(value);
    61.     }
    62.  
    63.  
    64.     /**
    65.      * 添加至黑名单
    66.      *
    67.      * @param token
    68.      * @param expireTime
    69.      */
    70.     public void addBlacklist(String token, Date expireTime) {
    71.         Long expireTimeLong = (expireTime.getTime() - System.currentTimeMillis()) / 1000 + 100;
    72.         redisUtil.set(getBlacklistPrefix(token), "1", expireTimeLong);
    73.     }
    74.  
    75.     /**
    76.      * 校验是否存在黑名单
    77.      *
    78.      * @param token
    79.      * @return true 存在 false不存在
    80.      */
    81.     public Boolean checkBlacklist(String token) {
    82.         return redisUtil.hasKey(getBlacklistPrefix(token));
    83.     }
    84.  
    85.     /**
    86.      * 获取黑名单前缀
    87.      *
    88.      * @param token
    89.      * @return
    90.      */
    91.     public String getBlacklistPrefix(String token) {
    92.         return Constants.TOKEN_BLACKLIST_PREFIX + token;
    93.     }
    94.  
    95.  
    96.     /**
    97.      * 获取 token 信息
    98.      *
    99.      * @param userTokenInfo
    100.      * @return
    101.      */
    102.     public UserToken createToekns(UserTokenInfo userTokenInfo) {
    103.         Date nowDate = new Date();
    104.         Date accessTokenExpireDate = new Date(nowDate.getTime() + accessTokenExpire * 1000);
    105.         Date refreshTokenExpireDate = new Date(nowDate.getTime() + refreshTokenExpire * 1000);
    106.  
    107.         UserToken userToken = new UserToken();
    108.         BeanUtils.copyProperties(userTokenInfo, userToken);
    109.         userToken.setAccessToken(createToken(userTokenInfo, nowDate, accessTokenExpireDate));
    110.         userToken.setRefreshToken(createToken(userTokenInfo, nowDate, refreshTokenExpireDate));
    111.  
    112.         // 创建 刷新令牌 与 访问令牌 关联关系
    113.         tokenAssociation(userToken, refreshTokenExpireDate);
    114.         return userToken;
    115.     }
    116.  
    117.     /**
    118.      * 生成token
    119.      *
    120.      * @param userTokenInfo
    121.      * @return
    122.      */
    123.     public String createToken(UserTokenInfo userTokenInfo, Date nowDate, Date expireDate) {
    124.         return Jwts.builder()
    125.                 .setHeaderParam("typ", "JWT")
    126.                 .setSubject(JSONObject.toJSONString(userTokenInfo))
    127.                 .setIssuedAt(nowDate)
    128.                 .setExpiration(expireDate)
    129.                 .signWith(SignatureAlgorithm.HS512, secret)
    130.                 .compact();
    131.     }
    132.  
    133.     /**
    134.      * 获取 token 中注册信息
    135.      *
    136.      * @param token
    137.      * @return
    138.      */
    139.     public Claims getTokenClaim(String token) {
    140.         try {
    141.             return Jwts.parser().setSigningKey(secret).parseClaimsJws(token).getBody();
    142.         } catch (Exception e) {
    143.             return null;
    144.         }
    145.     }
    146.  
    147.     /**
    148.      * 验证 token 是否过期失效
    149.      *
    150.      * @param token
    151.      * @return true 过期 false 未过期
    152.      */
    153.     public Boolean isTokenExpired(String token) {
    154.         return getExpirationDate(token).before(new Date());
    155.     }
    156.  
    157.     /**
    158.      * 获取 token 失效时间
    159.      *
    160.      * @param token
    161.      * @return
    162.      */
    163.     public Date getExpirationDate(String token) {
    164.         return getTokenClaim(token).getExpiration();
    165.     }
    166.  
    167.  
    168.     /**
    169.      * 获取 token 发布时间
    170.      *
    171.      * @param token
    172.      * @return
    173.      */
    174.     public Date getIssuedAtDate(String token) {
    175.         return getTokenClaim(token).getIssuedAt();
    176.     }
    177.  
    178.  
    179.     /**
    180.      * 获取用户信息
    181.      *
    182.      * @param token
    183.      * @return
    184.      */
    185.     public UserTokenInfo getUserInfoToken(String token) {
    186.         String subject = getTokenClaim(token).getSubject();
    187.         UserTokenInfo userTokenInfo = JSONObject.parseObject(subject, UserTokenInfo.class);
    188.         return userTokenInfo;
    189.     }
    190.  
    191.     /**
    192.      * 获取用户名
    193.      *
    194.      * @param token
    195.      * @return
    196.      */
    197.     public String getUserName(String token) {
    198.         UserTokenInfo userInfoToken = getUserInfoToken(token);
    199.         return userInfoToken.getUserName();
    200.     }
    201.  
    202.     /**
    203.      * 获取用户Id
    204.      *
    205.      * @param token
    206.      * @return
    207.      */
    208.     public Long getUserId(String token) {
    209.  
    210.         UserTokenInfo userInfoToken = getUserInfoToken(token);
    211.         return userInfoToken.getUserId();
    212.     }
    213.  
    214. }

    3.4、JwtFilter 拦截器

    1. package com.wangjing.jwtdemo.filter;
    2.  
    3. import com.wangjing.jwtdemo.util.JwtTokenUtil;
    4. import com.wangjing.jwtdemo.vo.UserTokenInfo;
    5. import lombok.extern.slf4j.Slf4j;
    6. import org.springframework.stereotype.Component;
    7. import org.springframework.util.StringUtils;
    8. import org.springframework.web.servlet.handler.HandlerInterceptorAdapter;
    9.  
    10. import javax.annotation.Resource;
    11. import javax.servlet.http.HttpServletRequest;
    12. import javax.servlet.http.HttpServletResponse;
    13.  
    14. /**
    15.  * @author: wangjing
    16.  * @createTime: 2022-10-17 19:03
    17.  * @version: 1.0.0
    18.  * @Description: Jwt 拦截器
    19.  */
    20. @Slf4j
    21. @Component
    22. public class JwtFilter extends HandlerInterceptorAdapter {
    23.  
    24.     @Resource
    25.     JwtTokenUtil jwtTokenUtil;
    26.  
    27.  
    28.     @Override
    29.     public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
    30.         // 获取token
    31.         String token = request.getHeader(jwtTokenUtil.header);
    32.  
    33.         if (StringUtils.isEmpty(token)) {
    34.             token = request.getParameter(jwtTokenUtil.header);
    35.         }
    36.  
    37.         if (StringUtils.isEmpty(token)) {
    38.             // 只是简单DEMO，这里直接返回false，可以自己进行添加
    39.             log.error("token 不能为空！");
    40.             return false;
    41.         }
    42.  
    43.         // 判断token是否超时
    44.         if (jwtTokenUtil.isTokenExpired(token)) {
    45.             log.error("token 已失效！");
    46.             return false;
    47.         }
    48.  
    49.         // 判断 token 是否已在黑名单
    50.         if (jwtTokenUtil.checkBlacklist(token)) {
    51.             log.error("token 已被加入黑名单！");
    52.             return false;
    53.         }
    54.  
    55.         // 获取用户信息
    56.         UserTokenInfo userInfoToken = jwtTokenUtil.getUserInfoToken(token);
    57.         // 通过用户信息去判断用户状态，等业务
    58.         //TODO 涉及到业务，这里不在阐述
    59.  
    60.         return true;
    61.     }
    62. }

    3.5、WebConfig 类（注入拦截器）

    1. package com.wangjing.jwtdemo.config;
    2.  
    3. import com.wangjing.jwtdemo.filter.JwtFilter;
    4. import org.springframework.context.annotation.Configuration;
    5. import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
    6. import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
    7.  
    8. import javax.annotation.Resource;
    9.  
    10. /**
    11.  * @author: wangjing
    12.  * @createTime: 2022-10-17 19:02
    13.  * @version: 1.0.0
    14.  * @Description: 请求拦截器
    15.  */
    16. @Configuration
    17. public class WebConfig implements WebMvcConfigurer {
    18.     @Resource
    19.     private JwtFilter jwtFilter;
    20.  
    21.     /**
    22.      * 不需要拦截地址
    23.      */
    24.     public static final String[] EXCLUDE_URLS = {
    25.             "/login/**"
    26.     };
    27.  
    28.     @Override
    29.     public void addInterceptors(InterceptorRegistry registry) {
    30.         registry.addInterceptor(jwtFilter).addPathPatterns("/**")
    31.                 .excludePathPatterns(EXCLUDE_URLS);
    32.     }
    33. }

    3.6、LoginController（简单的代码实现）

    1. package com.wangjing.jwtdemo.controller;
    2.  
    3.  
    4. import com.wangjing.jwtdemo.entity.Result;
    5. import com.wangjing.jwtdemo.enums.ResultTypeEnum;
    6. import com.wangjing.jwtdemo.util.JwtTokenUtil;
    7. import com.wangjing.jwtdemo.vo.LoginBody;
    8. import com.wangjing.jwtdemo.vo.UserToken;
    9. import com.wangjing.jwtdemo.vo.UserTokenInfo;
    10. import org.springframework.beans.factory.annotation.Autowired;
    11. import org.springframework.util.StringUtils;
    12. import org.springframework.web.bind.annotation.*;
    13.  
    14.  
    15. /**
    16.  * @author wangjing
    17.  * @since 2022-10-18
    18.  */
    19. @RestController
    20. @RequestMapping("/login")
    21. public class LoginController {
    22.  
    23.     @Autowired
    24.     JwtTokenUtil jwtTokenUtil;
    25.  
    26.     /**
    27.      * 登录
    28.      *
    29.      * @param loginBody
    30.      * @return
    31.      */
    32.     @PostMapping("/login")
    33.     public Result<UserToken> login(@RequestBody LoginBody loginBody) {
    34.         // 业务验证：入参校验 + 用户信息校验查询
    35.         //TODO 涉及到业务，这里不在阐述
    36.         UserTokenInfo userTokenInfo = new UserTokenInfo();
    37.         userTokenInfo.setUserId(1L);
    38.         userTokenInfo.setUserName("wangjing");
    39.         userTokenInfo.setRealName("王京");
    40.  
    41.         // 生成Token
    42.         UserToken userToken = jwtTokenUtil.createToekns(userTokenInfo);
    43.  
    44.         return new Result<>(ResultTypeEnum.SUCCESS, userToken);
    45.     }
    46.  
    47.     /**
    48.      * 刷新令牌
    49.      *
    50.      * @param refreshToken
    51.      * @return
    52.      */
    53.     @PostMapping("/refreshToken/{refreshToken}")
    54.     public Result<UserToken> refreshToken(@PathVariable("refreshToken") String refreshToken) {
    55.  
    56.         // 判断token是否超时
    57.         if (jwtTokenUtil.isTokenExpired(refreshToken)) {
    58.             return new Result<>(ResultTypeEnum.TOKEN_INVALID);
    59.         }
    60.  
    61.         // 刷新令牌 放入黑名单
    62.         jwtTokenUtil.addBlacklist(refreshToken, jwtTokenUtil.getExpirationDate(refreshToken));
    63.         // 访问令牌 放入黑名单
    64.         String odlAccessToken = jwtTokenUtil.getAccessTokenByRefresh(refreshToken);
    65.         if (!StringUtils.isEmpty(odlAccessToken)) {
    66.             jwtTokenUtil.addBlacklist(odlAccessToken, jwtTokenUtil.getExpirationDate(odlAccessToken));
    67.         }
    68.  
    69.         // 生成新的 访问令牌 和 刷新令牌
    70.         UserTokenInfo userInfoToken = jwtTokenUtil.getUserInfoToken(refreshToken);
    71.  
    72.         // 生成Token
    73.         UserToken userToken = jwtTokenUtil.createToekns(userInfoToken);
    74.  
    75.         return new Result<>(ResultTypeEnum.TOKEN_INVALID, userToken);
    76.     }
    77.  
    78.  
    79.     /**
    80.      * 登出
    81.      *
    82.      * @return
    83.      */
    84.     @PostMapping("/logOut/{token}")
    85.     public Result logOut(@PathVariable("token") String token) {
    86.         // 放入黑名单
    87.         jwtTokenUtil.addBlacklist(token, jwtTokenUtil.getExpirationDate(token));
    88.         return new Result<>(ResultTypeEnum.SUCCESS);
    89.     }
    90.  
    91.     /**
    92.      * 注销
    93.      *
    94.      * @return
    95.      */
    96.     @PostMapping("/logOff/{token}")
    97.     public Result logOff(@PathVariable("token") String token) {
    98.         // 修改用户状态
    99.         //TODO 涉及到业务，这里不在阐述
    100.  
    101.         // 放入黑名单
    102.         jwtTokenUtil.addBlacklist(token, jwtTokenUtil.getExpirationDate(token));
    103.  
    104.         return new Result<>(ResultTypeEnum.SUCCESS);
    105.     }
    106.  
    107.  
    108. }

     3.7、本文只列出相对重要的类，具体Demo 下载地址：

    https://download.csdn.net/download/wang_jing_jing/87127439

    四、通过postman 简单测试

    注：以上内容仅提供参考和交流，请勿用于商业用途，如有侵权联系本人删除！

  • 相关阅读:
    （附源码）mysql+ssm医院挂号系统 毕业设计 250858
    1、Flutter移动端App实战教程【环境配置、模拟器配置】
    在ensp上配置真机实验 待更新~
    flink 流的合并
    spring cloud 微服务
    [网络工程师]-防火墙-防火墙技术
    USB 转串口芯片 CH340
    一文带你了解线程池原理
    C/C++网络编程基础知识超详细讲解上部分（系统性学习day11）
    【JAVA基础】ReentrantLock 加锁和释放锁流程源码级深度解析（包括公平锁和非公平锁实现）
  • 原文地址：https://blog.csdn.net/wang_jing_jing/article/details/128001792