redis中HyperLogLog的使用

x33g5p2x  于2021-10-10 转载在 Redis  
字(2.2k)|赞(0)|评价(0)|浏览(347)

1.pv和uv的概念?

pv即为page view,代表网页的浏览次数。uv即为user view,代表用户个数

2.使用HyperLogLog统计个数

2.1 实现原理

使用pfadd来添加数据,类似于sadd,会自动去重!使用pfcount来统计个数,类似于scard

2.2 pom.xml

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>org.example</groupId>
    <artifactId>distribute-lock</artifactId>
    <version>1.0-SNAPSHOT</version>

    <dependencies>
        <!--json依赖-->
        <dependency>
            <groupId>com.fasterxml.jackson.core</groupId>
            <artifactId>jackson-databind</artifactId>
            <version>2.12.3</version>
        </dependency>
        <!--jedis依赖-->
        <dependency>
               <groupId>redis.clients</groupId>
               <artifactId>jedis</artifactId>
               <version>3.2.0</version>
               <type>jar</type>
               <scope>compile</scope>
        </dependency>
    </dependencies>

</project>

2.3 JedisUtils

package com.yl;

import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisPool;

public class JedisUtils {
    private static JedisPool jedisPool = null;

    public static Jedis getJedisObject() {
        if (jedisPool == null) {
            GenericObjectPoolConfig config = new GenericObjectPoolConfig();
            //最大空闲数
            config.setMaxIdle(400);
            //最大连接数
            config.setMaxTotal(2000);
            //连接最大等待时间,-1代表没有限制
            config.setMaxWaitMillis(300000);
            /** * 配置连接池的地址,端口号,超时时间,密码 */
            jedisPool = new JedisPool(config,"192.168.244.129",6379,30000,"root123");
        }
        try {
            //通过连接池获取jedis对象
            Jedis jedis = jedisPool.getResource();
            jedis.auth("root123");
            return jedis;
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}

2.4 测试模仿统计网站的用户个数

package com.yl;

import redis.clients.jedis.Jedis;

public class HyperLogLogTest {
    public static void main(String[] args) {
        Jedis jedis = JedisUtils.getJedisObject();
        for (int i = 1; i <= 10000;i++) {
            jedis.pfadd("uv","uv"+i);
        }
        long pfcount = jedis.pfcount("uv");
        System.out.println(pfcount);
    }
}

结果:理论上是有10000个的,但结果只显示9859,是有误差的,但是统计uv对精确度要求不高,可以接受!

2.pfmerge命令

1.作用:合并结果集

pfmerge uv1 uv2

相关文章

微信公众号

最新文章

更多