Redis 정렬 컬렉션을 기반으로 순위 목록을 구현하는 Java 정보

Redis Tutorial 칼럼에서는 Redis 주문 세트를 기반으로 Java에서 순위 목록을 구현하는 방법을 소개하겠습니다. 도움이 필요한 친구들에게 도움이 되길 바랍니다!

머리말

순위는 인간의 비교 욕구를 불러일으키는 요소로, 특정 보물의 상품 판매 순위, 매장 평판 순위 등 순위를 구현하는 방법도 있습니다. 여러 가지 방법으로 빠른 정렬 알고리즘을 사용하고 Comparator 인터페이스를 구현하여 특정 가중치로 정렬할 수 있습니다. 현재 많은 회사에서 순위 기능을 구현하기 위해 nosql 데이터베이스인 redis를 사용하고 있습니다. 이제 우리가 해야 할 일은 회사 순위를 평가하는 것인데, 순위 기준은 해당 회사에 대한 사용자 검색 수, 상위 10개 회사의 순위입니다

1. 관련 redis 지식

순위 기능의 구현은 정렬 집합(ordered set)입니다.

정렬 집합에 대하여

집합의 특징 중 하나는 중복 요소가 없다는 것입니다. 요소와 달리 정렬 세트에는 질서정연함이라는 또 다른 특징이 있습니다.

데이터 구조 구성:

key: 정렬 집합의 고유 식별자

weight: 점수(score)라고도 함 redis는 집합의 요소를 가중치에 따라 오름차순으로 정렬(기본값), 가중치는 반복 가능

• 값: 집합 요소, 요소는 반복 불가능

• String(set key),double(权重),String(value)

정렬 집합은 해시 테이블을 통해 구현되므로 추가, 함수 및 검색의 시간 복잡도는 O(1)입니다. 각 집합은 40억 개 이상의 요소를 저장할 수 있습니다.
• 기본 명령

세트에 하나 이상의 요소 추가

ZADD "KEY" SCORE "VALUE" [ SCORE "VALUE"]

효과:

MyRedis:0>ZADD test 1 "one""1"MyRedis:0>zadd test 4 "four" 5 "five""2"

세트의 요소 수 가져오기

ZCARD "key"

Effect

MyRedis:0>ZCARD test"5"

지정된 요소 점수(가중치) 가져오기

ZSCORE "KEY" "VALUE"

Effect

MyRedis:0>ZSCORE "test" "one""2"

지정된 집합의 지정된 요소에 대해 지정된 점수를 높입니다.

ZINCRBY "key" score "value"

효과:

MyRedis:0>ZSCORE "test" "one""2"MyRedis:0>ZINCRBY "test" 1 "one""3"MyRedis:0>ZSCORE "test" "one" "3"

지정된 범위의 요소 가져오기(기본값은 점수|가중치의 오름차순)

ZRANGE "key" 开始下标 结束下标

Effect

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);
        }
    }</tbcommpany></object>

순위 가져오기

    /**
     * 获得公司排行榜(前十)
     * @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)

시간이 있는 이 회사는 오류를 최대한 줄이기 위해 자체적으로 작성할 수 있습니다

위 내용은 Redis 정렬 컬렉션을 기반으로 순위 목록을 구현하는 Java 정보의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!