五分钟内重复登录 QQ 号定位：数据结构选型与高效实现方案

[QQ登录请求] → [拦截器/过滤器] → [重复登录判断模块] → [登录业务逻辑]                          ↓                 [哈希表+双端队列]（内存存储）                          ↓                 [过期数据清理]（登录时触发）

import java.util.Deque;import java.util.HashMap;import java.util.LinkedList;import java.util.Map;/** * 五分钟内重复登录QQ号检测器（本地内存版） */public class QQDuplicateLoginDetector {    // 核心存储：key=QQ号（字符串，避免长数字溢出），value=登录时间戳队列（毫秒级）    private final Map<String, Deque<Long>> loginRecordMap = new HashMap<>();    // 时间窗口：5分钟=300000毫秒    private static final long TIME_WINDOW = 5 * 60 * 1000;    // 并发安全锁：避免多线程操作同一QQ号的队列导致异常    private final Object lock = new Object();    /**     * 判断当前登录是否为“五分钟内重复登录”     * @param qqNumber QQ号     * @return true=重复登录，false=非重复     */    public boolean isDuplicateLogin(String qqNumber) {        // 1. 获取当前时间戳（毫秒）        long currentTime = System.currentTimeMillis();                // 2. 并发安全：同一QQ号的操作加锁（避免多线程同时修改队列）        synchronized (lock) {            // 3. 获取该QQ号的登录记录队列，无则创建新队列            Deque<Long> loginTimes = loginRecordMap.computeIfAbsent(qqNumber, k -> new LinkedList<>());                        // 4. 清理队列中“超过5分钟的过期记录”（关键：只保留有效数据）            while (!loginTimes.isEmpty()) {                long earliestTime = loginTimes.peekFirst(); // 队头是最早的登录时间                if (currentTime - earliestTime > TIME_WINDOW) {                    loginTimes.pollFirst(); // 过期则删除                } else {                    break; // 队头未过期，后续记录更不会过期（队列按时间排序）                }            }                        // 5. 判断是否重复登录：清理后队列非空（说明有5分钟内的登录记录）            boolean isDuplicate = !loginTimes.isEmpty();                        // 6. 将当前登录时间加入队列（队尾追加）            loginTimes.offerLast(currentTime);                        // 7. 优化：若队列长度超过2，删除最早的记录（仅需保留最近2条即可判断重复）            if (loginTimes.size() > 2) {                loginTimes.pollFirst();            }                        // 8. 优化：若队列空，从哈希表中删除（释放内存，避免无效key占用空间）            if (loginTimes.isEmpty()) {                loginRecordMap.remove(qqNumber);            }                        return isDuplicate;        }    }    // 测试示例    public static void main(String[] args) throws InterruptedException {        QQDuplicateLoginDetector detector = new QQDuplicateLoginDetector();        String qq = "123456789";                // 第一次登录：非重复        System.out.println(detector.isDuplicateLogin(qq)); // false                // 2分钟后第二次登录：重复        Thread.sleep(2 * 60 * 1000);        System.out.println(detector.isDuplicateLogin(qq)); // true                // 6分钟后第三次登录：非重复（前两次记录已过期）        Thread.sleep(6 * 60 * 1000);        System.out.println(detector.isDuplicateLogin(qq)); // false    }}

[QQ登录请求] → [API网关] → [分布式登录服务集群] → [Redis集群]                          ↓                      ↓                    [重复登录判断]         [Sorted Set存储登录记录]                          ↓                    [安全告警/业务处理]

import redis.clients.jedis.Jedis;import redis.clients.jedis.JedisPool;import redis.clients.jedis.params.ZAddParams;import java.util.Set;/** * 五分钟内重复登录QQ号检测器（分布式Redis版） */public class RedisQQDuplicateLoginDetector {    private final JedisPool jedisPool;    // 时间窗口：5分钟=300000毫秒    private static final long TIME_WINDOW = 5 * 60 * 1000;    // Redis key前缀：避免与其他业务key冲突    private static final String KEY_PREFIX = "qq:login:record:";    // Redis key过期时间：6分钟（比时间窗口多1分钟，确保过期记录被清理）    private static final int KEY_EXPIRE_SECONDS = 6 * 60;    public RedisQQDuplicateLoginDetector(JedisPool jedisPool) {        this.jedisPool = jedisPool;    }    public boolean isDuplicateLogin(String qqNumber) {        long currentTime = System.currentTimeMillis();        String redisKey = KEY_PREFIX + qqNumber;                try (Jedis jedis = jedisPool.getResource()) {            // 1. 清理过期记录：删除score（时间戳）< 当前时间-TIME_WINDOW的记录            jedis.zremrangeByScore(redisKey, 0, currentTime - TIME_WINDOW);                        // 2. 判断是否重复登录：记录数≥1说明有5分钟内的登录            long recordCount = jedis.zcard(redisKey);            boolean isDuplicate = recordCount > 0;                        // 3. 插入当前登录记录：score=currentTime，member=currentTime（避免重复member）            // ZAddParams.xx()：仅当key存在时才插入（可选，避免无效插入）            jedis.zadd(redisKey, currentTime, String.valueOf(currentTime), ZAddParams.zAddParams().nx());                        // 4. 优化：保留最近2条记录（删除最早的记录）            if (recordCount >= 2) {                // ZRANGE获取最早的记录（0-0是第一条），再删除                Set<String> earliestMembers = jedis.zrange(redisKey, 0, 0);                if (!earliestMembers.isEmpty()) {                    jedis.zrem(redisKey, earliestMembers.iterator().next());                }            }                        // 5. 设置key过期时间（确保6分钟后自动删除，释放内存）            jedis.expire(redisKey, KEY_EXPIRE_SECONDS);                        return isDuplicate;        }    }    // 测试示例（需提前启动Redis服务）    public static void main(String[] args) throws InterruptedException {        JedisPool jedisPool = new JedisPool("localhost", 6379);        RedisQQDuplicateLoginDetector detector = new RedisQQDuplicateLoginDetector(jedisPool);        String qq = "987654321";                // 第一次登录：非重复        System.out.println(detector.isDuplicateLogin(qq)); // false                // 3分钟后第二次登录：重复        Thread.sleep(3 * 60 * 1000);        System.out.println(detector.isDuplicateLogin(qq)); // true                // 7分钟后第三次登录：非重复（key已过期）        Thread.sleep(7 * 60 * 1000);        System.out.println(detector.isDuplicateLogin(qq)); // false                jedisPool.close();    }}