【利用Redis实现PV统计】

import redis.clients.jedis.Jedis;

public class PVStats {
    private static final String PAGE_VISIT_KEY_PREFIX = "page_visit:";
    private static final String PAGE_VISIT_COUNT_KEY_PREFIX = "page_visit_count:";

    private Jedis jedis;

    public PVStats() {
        // 初始化Redis连接
        jedis = new Jedis("localhost");
    }

    public void incrementPageVisit(String pageId) {
        // 统计页面的人数
        jedis.sadd(PAGE_VISIT_KEY_PREFIX + pageId, String.valueOf(System.currentTimeMillis()));

        // 统计页面的访问次数
        jedis.incr(PAGE_VISIT_COUNT_KEY_PREFIX + pageId);
    }

    public int getPageVisits(String pageId) {
        // 获取页面的人数
        return jedis.scard(PAGE_VISIT_KEY_PREFIX + pageId).intValue();
    }

    public int getPageVisitCount(String pageId) {
        // 获取页面的访问次数
        return Integer.parseInt(jedis.get(PAGE_VISIT_COUNT_KEY_PREFIX + pageId));
    }

    public boolean isRateLimited(String pageId, int maxVisits, long timeWindow) {
        String key = PAGE_VISIT_COUNT_KEY_PREFIX + pageId;
        // 获取当前时间戳
        long currentTime = System.currentTimeMillis();
        // 获取 timeWindow 时间窗口内的访问次数
        long visits = jedis.bitcount(key, currentTime - timeWindow, currentTime);

        // 判断是否超过限流值
        return visits >= maxVisits;
    }

    public static void main(String[] args) {
        PVStats pvStats = new PVStats();

        // 示例使用：增加页面访问次数和人数
        String pageId = "home";
        pvStats.incrementPageVisit(pageId);
        pvStats.incrementPageVisit(pageId);
        pvStats.incrementPageVisit(pageId);

        // 获取页面访问次数和人数
        int pageVisits = pvStats.getPageVisits(pageId);
        int pageVisitCount = pvStats.getPageVisitCount(pageId);

        System.out.println("Page visits: " + pageVisits);
        System.out.println("Page visit count: " + pageVisitCount);
    }
}