【黑马点评日记02】Redis解决Tomcat集群Session共享问题

1. 用户登录
   ↓
2. Tomcat 在本地内存创建 Session 对象
   Session 对象里直接存着 {userId: 123}
   ↓
3. Tomcat 通过 Set-Cookie 返回 sessionId
   ↓
4. 浏览器存 Cookie
   ↓
5. 后续请求，浏览器带 Cookie
   ↓
6. Tomcat 根据 sessionId 从本地内存找到 Session 对象
   ↓
7. 直接内存读取，不经过 Redis

Tomcat 内存
    ┌─────────────────┐
    │ Session 对象     │
    │   sessionId: ABC │
    │   userId: 123    │ ← 数据直接存在这里
    │   cart: [...]    │
    └─────────────────┘

Tomcat 内存                    Redis
┌─────────────────┐          ┌─────────────────┐
│ Session 对象     │          │ Key: session:ABC│
│   sessionId: ABC │ ──────→ │   userId: 123   │ ← 数据存在这里
└─────────────────┘          │   cart: [...]   │
                             └─────────────────┘

单机 Session】
   一台Tomcat，Session存在本地内存
          ↓ 需求：多台Tomcat集群
          
    两条路可以走：
    
    ┌─────────────────────┐     ┌─────────────────────┐
    │  路径A：Session架构   │     │  路径B：Token架构    │
    │                     │     │                     │
    │  加Redis共享Session  │     │  放弃Session        │
    │  继续用session API   │     │  自己生成Token      │
    │                     │     │                     │
    │  分布式Session       │     │  无状态Token        │
    └─────────────────────┘     └─────────────────────┘

─────────────────────────────────────────────┐
│           整体架构（宏观层面）                │
│   单体架构 / 微服务架构 / 无服务架构          │
└─────────────────────────────────────────────┘
                    ↓
┌─────────────────────────────────────────────┐
│           应用架构（你这一层）                │
│   认证架构：Session / Token / OAuth2         │
│   分层架构：Controller → Service → DAO       │
└─────────────────────────────────────────────┘
                    ↓
┌─────────────────────────────────────────────┐
│           技术架构（具体选型）                │
│   框架：Spring Boot / Spring MVC            │
│   存储：MySQL / Redis                       │
└─────────────────────────────────────────────┘
                    ↓
┌─────────────────────────────────────────────┐
│           代码层面（实现细节）                │
│   你写的 if/else、for循环、session.setAttribute│
└─────────────────────────────────────────────┘

java

stringRedisTemplate.opsForValue().set(LOGIN_CODE_KEY + phone, code, LOGIN_CODE_TTL, TimeUnit.MINUTES);

java

// 保存用户信息到 Session
session.setAttribute("user", BeanUtil.copyProperties(user, UserDTO.class));

java

// 1. 生成随机 token（使用 UUID）
String token = UUID.randomUUID().toString(true);

// 2. 将 UserDTO 转为 Hash 结构存储到 Redis
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()));

// 3. 存储到 Redis，key 为 "login:token:" + token
String tokenKey = LOGIN_TOKEN_KEY + token;
stringRedisTemplate.opsForHash().putAll(tokenKey, userMap);

// 4. 设置 token 有效期（比如 30 分钟）
stringRedisTemplate.expire(tokenKey, LOGIN_TOKEN_TTL, TimeUnit.MINUTES);

// 5. 返回 token 给前端（不再是返回空或 Cookie）
return Result.ok(token);

java

@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
    // 从 Session 获取用户
    UserDTO user = (UserDTO) session.getAttribute("user");
    if (user == null) {
        throw new RuntimeException("未登录");
    }
    // 存入 ThreadLocal
    UserHolder.saveUser(user);
    return true;
}

java

@Override
public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
    // 1. 从请求头获取 token（前端手动放进去的）
    String token = request.getHeader("authorization");
    if (StrUtil.isBlank(token)) {
        throw new RuntimeException("未登录");
    }

    // 2. 从 Redis 获取用户信息
    String tokenKey = LOGIN_TOKEN_KEY + token;
    Map<Object, Object> userMap = stringRedisTemplate.opsForHash().entries(tokenKey);
    if (userMap.isEmpty()) {
        throw new RuntimeException("未登录");
    }

    // 3. 转为 UserDTO 对象
    UserDTO userDTO = BeanUtil.fillBeanWithMap(userMap, new UserDTO(), false);

    // 4. 存入 ThreadLocal
    UserHolder.saveUser(userDTO);

    // 5. 刷新 token 有效期（活跃用户续期）
    stringRedisTemplate.expire(tokenKey, LOGIN_TOKEN_TTL, TimeUnit.MINUTES);

    return true;
}