高并发场景下的Session处理方案

// 使用Redis存储Session的示例
public class RedisSessionManager {
    private Jedis jedis;

    public RedisSessionManager(String host, int port) {
        this.jedis = new Jedis(host, port);
    }

    public void setSession(String sessionId, String data) {
        jedis.set(sessionId, data);
        jedis.expire(sessionId, 3600); // 设置过期时间为1小时
    }

    public String getSession(String sessionId) {
        return jedis.get(sessionId);
    }

    public void removeSession(String sessionId) {
        jedis.del(sessionId);
    }
}

// 使用Token管理Session的示例
public class TokenSessionManager {
    private Map<String, String> tokenMap = new ConcurrentHashMap<>();

    public String generateToken(String userId) {
        String token = UUID.randomUUID().toString();
        tokenMap.put(token, userId);
        return token;
    }

    public String getUserId(String token) {
        return tokenMap.get(token);
    }

    public void removeToken(String token) {
        tokenMap.remove(token);
    }
}

// 序列化Session数据的示例
public class SessionSerializer {
    public static String serialize(Object obj) {
        try {
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            ObjectOutputStream oos = new ObjectOutputStream(baos);
            oos.writeObject(obj);
            oos.close();
            return Base64.getEncoder().encodeToString(baos.toByteArray());
        } catch (IOException e) {
            e.printStackTrace();
            return null;
        }
    }

    public static Object deserialize(String data) {
        try {
            byte[] bytes = Base64.getDecoder().decode(data);
            ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
            ObjectInputStream ois = new ObjectInputStream(bais);
            return ois.readObject();
        } catch (IOException | ClassNotFoundException e) {
            e.printStackTrace();
            return null;
        }
    }
}