您好,欢迎访问一九零五行业门户网

关于java基于redis有序集合实现排行榜

下面由redis教程栏目给大家介绍关于java基于redis有序集合实现排行榜,希望对需要的朋友有所帮助!
前言排行榜作为互联网应用中几乎必不可少的一个元素,能勾起人类自身对比的欲望,某宝中的商品销量排行,店铺信誉排行等,实现排行榜的方式也有很多种,可以使用快速排序算法 + 实现comparator接口实现按某项权重排序,现在很多公司都在使用redis这个nosql数据库实现排行榜的功能
基于redis实现排行榜现在要做的是对公司进行排行,排行的标准是用户对公司的搜索次数,做一个前十公司的排行榜
1.相关的redis知识与排行榜功能实现相关的redis数据结构是sort set(有序集合)
关于sort set我们知道set是一种集合,集合有一个特点就是无重复元素,sort set除了无重复元素外,还有一个特点就是有序性。
数据结构组成:
key:sort set 的唯一标识权重:也叫分数(score)redis通过权重为集合中的元素进行升序排序(默认),权重可以重复value:集合元素,元素不可重复string(set key),double(权重),string(value)
sort set是通过哈希表实现的,所以添加,函数,查找的时间复杂度都是o(1),每个集合可以存储40多亿个元素
基本命令向集合中添加一个或多个元素
zadd key score value [ score value]
效果:
myredis:0>zadd test 1 one1myredis:0>zadd test 4 four 5 five2
获取集合的元素数量
zcard key
效果
myredis:0>zcard test5
获取指定元素分数(权重)
zscore key value
效果
myredis:0>zscore test one2
指定集合的指定元素增加指定分数
zincrby key score value
效果:
myredis:0>zscore test one2myredis:0>zincrby test 1 one3myredis:0>zscore test one 3
获取指定范围的元素(默认按照分数|权重的升序排列)
zrange key 开始下标 结束下标
效果
myredis:0>zrange test 0 1 1)  two 2)  one
完成这个需求大概需要这么多命令,接下来开始实现我们的这个需求
2.springboot + redis实现导入redis依赖
        <dependency>            <groupid>org.springframework.boot</groupid>            <artifactid>spring-boot-starter-data-redis</artifactid>        </dependency>
编写工具类
    //=============================== sort set =================================    /**     * 添加指定元素到有序集合中     * @param key     * @param score     * @param value     * @return     */    public boolean sortsetadd(string key,double score,string value){        try{            return redistemplate.opsforzset().add(key,value,score);        }catch (exception e){            e.printstacktrace();            return false;        }    }    /**     * 有序集合中对指定成员的分数加上增量 increment     * @param key     * @param value     * @param i     * @return     */    public double sortsetzincrby(string key,string value,double i){        try {            //返回新增元素后的分数            return redistemplate.opsforzset().incrementscore(key, value, i);        }catch(exception e){            e.printstacktrace();            return -1;        }    }    /**     * 获得有序集合指定范围元素 (从大到小)     * @param key     * @param start     * @param end     * @return     */    public set sortsetrange(string key,int start,int end){        try {            return redistemplate.opsforzset().reverserange(key, start, end);        }catch (exception e){            e.printstacktrace();            return null;        }    }
业务实现:
因为排行榜对实时性要求比较高,个人认为没必要进行持久化到数据库
    /**     * 根据公司名找到指定公司     * @param companyname     * @return     */    @override    public ajaxresult selectcompanyname(string companyname) {        set<object> set =  redisutils.sget(company);        for(object i : set){            string json = jsonobject.tojsonstring(i);            jsonobject jsonobject = jsonobject.parseobject(json);            if(jsonobject.getstring(companyname).equals(companyname)){                //搜索次数 + 1                redisutils.sortsetzincrby(companyrank,companyname,1);                log.info(直接缓存中返回);                return new ajaxresult().ok(jsonobject);            }        }        log.error(缓存中没有,查数据库);        tbcommpanyexample tbcommpanyexample = new tbcommpanyexample();        tbcommpanyexample.createcriteria().andcompanynameequalto(companyname);        list<tbcommpany> list = tbcommpanymapper.selectbyexample(tbcommpanyexample);        if(list.size() != 0){            //放入缓存中            redisutils.sset(company,list.get(0));            //数据库中存在            //搜索次数 + 1            redisutils.sortsetzincrby(companyrank,companyname,1);            log.info(sql);            return new ajaxresult().ok(list.get(0));        }else{            return new ajaxresult().error(没有找到该公司:+companyname);        }    }
获取排名
    /**     * 获得公司排行榜(前十)     * @return     */    @override    public ajaxresult getcompanyrank() {        set set = redisutils.sortsetrange(companyrank,0,9);        if(set.size() == 0){            return new ajaxresult().error(公司排行榜为空);        }        return new ajaxresult().ok(set);    }
3.测试与总结
postman测试:
还有一个问题就是相同分数的排行问题
如果我希望a是先到的排在相同分数但是后到的b前边,这个问题该如何解决呢?
要解决这个问题,我们可以考虑在分数中加入时间戳,计算公式为:
带时间戳的分数 = 实际分数*10000000000 + (9999999999 – timestamp)
这个带时间的公司可以自己编写,尽量缩减误差
以上就是关于java基于redis有序集合实现排行榜的详细内容。
其它类似信息

推荐信息