通过Redis实现Token黑名单机制的具体方案

Key: token:blacklist:{token}
Value: "blacklisted"
Expire: Token剩余有效时间

/**
 * 将Token加入黑名单，实现主动失效
 *
 * @param token JWT token
 * @return 是否成功加入黑名单
 */
public boolean addToBlacklist(String token) {
    try {
        // 获取Token的过期时间
        Date expirationDate = getExpirationDateFromToken(token);
        if (expirationDate == null) {
            return false;
        }

        // 计算剩余有效时间
        long remainingTime = expirationDate.getTime() - System.currentTimeMillis();
        if (remainingTime <= 0) {
            return false;
        }

        // 将Token加入Redis黑名单，设置过期时间为Token剩余有效时间
        String key = TOKEN_BLACKLIST_PREFIX + token;
        return redisUtil.set(key, "blacklisted", remainingTime / 1000);
    } catch (Exception e) {
        return false;
    }
}

/**
 * 检查Token是否在黑名单中
 *
 * @param token JWT token
 * @return 是否在黑名单中
 */
public boolean isTokenInBlacklist(String token) {
    String key = TOKEN_BLACKLIST_PREFIX + token;
    return redisUtil.exists(key);
}

/**
 * 从黑名单中移除Token
 *
 * @param token JWT token
 * @return 是否成功移除
 */
public boolean removeFromBlacklist(String token) {
    String key = TOKEN_BLACKLIST_PREFIX + token;
    return redisUtil.del(key) > 0;
}

/**
 * 验证Token是否合法且未过期
 *
 * @param token JWT token
 * * @return 是否有效
 */
public Boolean validateToken(String token) {
    try {
        // 检查Token是否在黑名单中
        if (isTokenInBlacklist(token)) {
            return false;
        }

        JwtParser parser = Jwts.parser().verifyWith(secretKey).build();
        parser.parseSignedClaims(token);
        return true;
    } catch (JwtException e) {
        System.out.println("JWT exception: " + e.getMessage());
    } catch (IllegalArgumentException e) {
        System.out.println("JWT claims string is empty: " + e.getMessage());
    }
    return false;
}

@PostMapping("/logout")
public ResultBean<String> logout(@RequestHeader("Authorization") String token) {
    if (token != null && token.startsWith("Bearer ")) {
        token = token.substring(7);
      
        // 将Token加入黑名单
        boolean added = tokenUtil.addToBlacklist(token);
        if (added) {
            return ResultBean.success("注销成功");
        }
    }
    return ResultBean.error("注销失败");
}

@Component
public class TokenInterceptor implements HandlerInterceptor {
  
    @Autowired
    private TokenUtil tokenUtil;
  
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String token = request.getHeader("Authorization");
      
        if (token != null && token.startsWith("Bearer ")) {
            token = token.substring(7);
          
            // 验证Token（会自动检查黑名单）
            if (!tokenUtil.validateToken(token)) {
                response.setStatus(HttpStatus.UNAUTHORIZED.value());
                return false;
            }
        }
      
        return true;
    }
}

@PostMapping("/admin/forceLogout")
public ResultBean<String> forceLogout(@RequestParam String token) {
    // 将Token加入黑名单
    boolean added = tokenUtil.addToBlacklist(token);
    if (added) {
        return ResultBean.success("用户已强制下线");
    }
    return ResultBean.error("操作失败");
}