SELECT COUNT(1) AS `online_user_count` FROM `user` WHERE `last_active` BETWEEN  '2020-12-22 13:00:00' AND '020-12-22 13:05:00';

ZADD key score member [score member ...]

ZCARD key

ZCOUNT key min max

ZREMRANGEBYSCORE key min max

> zadd lang 999 php 10 java 9 go 8 python 7 javascript
"5"

> zcard lang
"5"

> zcount lang 8 10
"3"

> ZREMRANGEBYSCORE lang 8 1000
"4"

zadd users 1608616915109 10000

zcount users 1608616615109 1608616915109 

ZREMRANGEBYSCORE users 0 1608616615109 

import java.time.Duration;
import java.time.Instant;
import java.time.LocalDateTime;
import java.time.ZoneId;

import javax.annotation.Resource;

import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;

/**
 * 
 * 
 * 在線用戶統(tǒng)計(jì)
 * 
 * @author Administrator
 *
 */
@Component
public class OnlineUserStatsService {
    
    private static final String ONLINE_USERS = "onlie_users";

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    /**
     * 添加用戶在線信息
     * @param userId
     * @return 
     */
    public Boolean online(Integer userId) {
        return this.stringRedisTemplate.opsForZSet().add(ONLINE_USERS, userId.toString(), Instant.now().toEpochMilli());
    }
    
    /**
     * 獲取一定時(shí)間內(nèi)，在線的用戶數(shù)量
     * @param duration
     * @return
     */
    public Long count(Duration duration) {
        LocalDateTime now = LocalDateTime.now();
        return this.stringRedisTemplate.opsForZSet().count(ONLINE_USERS, 
                                    now.minus(duration).atZone(ZoneId.systemDefault()).toInstant().toEpochMilli(), 
                                    now.atZone(ZoneId.systemDefault()).toInstant().toEpochMilli());
    }
    
    /**
     * 獲取所有在線過的用戶數(shù)量，不論時(shí)間
     * @return
     */
    public Long count() {
        return this.stringRedisTemplate.opsForZSet().zCard(ONLINE_USERS);
    }
    
    /**
     * 清除超過一定時(shí)間沒在線的用戶數(shù)據(jù)
     * @param duration
     * @return
     */
    public Long clear(Duration duration) {
        return this.stringRedisTemplate.opsForZSet().removeRangeByScore(ONLINE_USERS, 0, 
                LocalDateTime.now().minus(duration).atZone(ZoneId.systemDefault()).toInstant().toEpochMilli());
    }
}

@Resource
private OnlineUserStatsService onlineUserStatsService;

@Test
public void test() {
    
    // ID為1的用戶發(fā)送了心跳包
    boolean result = this.onlineUserStatsService.online(1);
    System.out.println("online=" + result);
    
    // 獲取5分鐘內(nèi)，發(fā)送過心跳包的用戶數(shù)量，也就是在線用戶的數(shù)量
    Long count = this.onlineUserStatsService.count(Duration.ofMinutes(5));
    System.out.println("oneline count=" + count);
    
    // 獲取所有發(fā)送過心跳包的用戶數(shù)量
    count = this.onlineUserStatsService.count();
    System.out.println("all count=" + count);
    
    // 清除超過1天都沒發(fā)送過心跳包的用戶
    Long clear = this.onlineUserStatsService.clear(Duration.ofDays(1));
    System.out.println("clear=" + clear);
}

String userId = "10010";
System.out.println(userId.getBytes().length); // 以字符串形式存儲(chǔ) => 需要5個(gè)字節(jié)

byte[] bin = ByteBuffer.allocate(4).putInt(Integer.valueOf(userId)).array();
System.out.println(bin.length);                    // 序列化為字節(jié)形式存儲(chǔ) => 需要4個(gè)字節(jié)

System.out.println(ByteBuffer.wrap(bin).getInt());    // 反序列化為ID => 10010