Source/plt-web/plt-web-parent/plt-web-base/src/main/java/com/vci/starter/web/redis/RedisService.java

@@ -397,9 +397,12 @@
    public void increOnlineUser(String currentLoggedUserKey) {
        // 检查键是否存在
        if (!redisTemplate.hasKey(currentLoggedUserKey)) {
            //log.info("===========================键不存在");
            // 如果键不存在，初始化为0
            redisTemplate.opsForValue().set(currentLoggedUserKey, 0);
        }
        int currentCount = (int)redisTemplate.opsForValue().get(currentLoggedUserKey);
        //log.info("===========================开始自增"+currentCount);
        // 自增在线用户数
        redisTemplate.opsForValue().increment(currentLoggedUserKey);
    }
@@ -410,10 +413,10 @@
     */
    public void decreOnlineUser(String currentLoggedUserKey) {
        // 检查当前在线用户数
        Integer currentLoggedUser = (Integer)redisTemplate.opsForValue().get(currentLoggedUserKey);
        Object obj = redisTemplate.opsForValue().get(currentLoggedUserKey);

        if (currentLoggedUser != null) {
            Integer currentCount = Integer.parseInt(redisTemplate.opsForValue().get(currentLoggedUserKey)+"");
        if (obj != null) {
            int currentCount = (int)redisTemplate.opsForValue().get(currentLoggedUserKey);
            if(currentCount > 0){
                // 自减在线用户数
                redisTemplate.opsForValue().decrement(currentLoggedUserKey);
@@ -427,6 +430,10 @@
     * @return
     */
    public long getCurrentOnlineUserCount(String currentLoggedUserKey) {
        Object obj = redisTemplate.opsForValue().get(currentLoggedUserKey);
        if(obj == null){
            return 0L;
        }
        return Long.parseLong(redisTemplate.opsForValue().get(currentLoggedUserKey)+"");
    }