SpringBoot+Redission實現(xiàn)排行榜功能的示例代碼

更新時間：2024年05月08日 10:03:38 作者：BaisuX

這篇文章主要介紹了基于SpringBoot+Redission實現(xiàn)排行榜功能,實現(xiàn)一個排行榜,要求按照分?jǐn)?shù)和達(dá)成這個分?jǐn)?shù)的時間排序,即相同分?jǐn)?shù)下,時間早的在上面,文中通過代碼示例介紹的非常詳細(xì),需要的朋友可以參考下

SpringBoot+Redission實現(xiàn)排行榜功能

demo地址：ranking-demo: 排行榜DEMO (gitee.com)

一、業(yè)務(wù)需求

實現(xiàn)一個排行榜，要求按照分?jǐn)?shù)和達(dá)成這個分?jǐn)?shù)的時間排序，即相同分?jǐn)?shù)下，時間早的在上面

二、Redis中的zSet(有序集合)

1.簡介

Redis 的 zSet（也稱為有序集合）是一種特殊的數(shù)據(jù)結(jié)構(gòu)，它同時包含了集合和有序列表的特性。在 zSet 中，每個成員都有一個分?jǐn)?shù)（score）與之關(guān)聯(lián)，這個分?jǐn)?shù)可以是浮點數(shù)，用于對集合中的元素進(jìn)行排序。

2.特點

元素唯一：就像集合一樣，zSet 中不允許有重復(fù)成員。
有序性：集合中的元素按照其關(guān)聯(lián)的分?jǐn)?shù)值進(jìn)行升序排序。
操作豐富：支持添加、刪除成員，獲取指定范圍的成員，根據(jù)分?jǐn)?shù)查詢成員，計算交集、并集、差集等操作。

3.常用命令

ZADD：向有序集合中添加一個或多個成員，或者更新已存在成員的分?jǐn)?shù)。
ZRANGE：返回有序集合中指定區(qū)間內(nèi)的成員，通過索引位置來獲取，從0開始。
ZRANGEBYSCORE：返回有序集合中指定分?jǐn)?shù)區(qū)間的成員。
ZCARD：獲取有序集合的成員數(shù)量。
ZREM：移除有序集合中的一個或多個成員。
ZREVRANGE：類似于 ZRANGE，但返回的是從高分到低分的成員。
ZINCRBY：為有序集合中的成員的分?jǐn)?shù)加上給定值。
ZCOUNT：計算有序集合中指定分?jǐn)?shù)區(qū)間的成員數(shù)量。
ZRANK/ZREVRANK：獲取成員在有序集合中的排名，ZRANK 是從低分到高分，ZREVRANK 是從高分到低分。

4.測試

> ZADD zsetkey 1 member1
1
> ZADD zsetkey 1 member2
1
> ZADD zsetkey 1 member9
1
> ZADD zsetkey 1 member5
1
> ZREVRANGE zsetkey 0 10 WITHSCORES
member9
1
member5
1
member2
1
member1
1

5.總結(jié)

zSet可以很好的實現(xiàn)分?jǐn)?shù)排序，但是在相同的分?jǐn)?shù)下，會按照成員的名稱進(jìn)行排序，所以要在此基礎(chǔ)上增加時間

三、增加時間數(shù)據(jù)

為了增加完成時間，我們可以引進(jìn)一個倒計時的概念，假設(shè)一共9秒

用戶A在獲得1分的時候在第2秒，那可以在Redis中存儲1*10+(9-2) => 18

用戶B在獲得1分的時候在第6秒，那可以在Redis中存儲1*10+(9-6) => 13

這樣我們在獲取分?jǐn)?shù)的時候，可以倒推出分?jǐn)?shù)和完成時間

四、SpringBoot代碼

1.引入Redis和Redission依賴

<!-- redis -->  
<dependency>  
    <groupId>org.springframework.boot</groupId>  
    <artifactId>spring-boot-starter-data-redis</artifactId>  
</dependency>  
  
<!-- redisson -->  
<dependency>  
    <groupId>org.redisson</groupId>  
    <artifactId>redisson-spring-boot-starter</artifactId>  
    <version>3.20.1</version>  
</dependency>

2.application.yml配置

--- # redis配置  
spring:  
  redis:  
    # 地址  
    host: localhost  
    # 端口，默認(rèn)為6379  
    port: 6379  
    # 數(shù)據(jù)庫索引  
    database: 0  
    # 密碼(如沒有密碼請注釋掉)  
    # password:    # 連接超時時間  
    timeout: 10s  
    # 是否開啟ssl  
    ssl: false  
  
--- # redisson配置  
redisson:  
  # redis key前綴  
  keyPrefix: ${spring.application.name}  
  # 線程池數(shù)量  
  threads: 4  
  # Netty線程池數(shù)量  
  nettyThreads: 8  
  # 單節(jié)點配置  
  singleServerConfig:  
    # 客戶端名稱  
    clientName: ${spring.application.name}  
    # 最小空閑連接數(shù)  
    connectionMinimumIdleSize: 8  
    # 連接池大小  
    connectionPoolSize: 32  
    # 連接空閑超時，單位：毫秒  
    idleConnectionTimeout: 10000  
    # 命令等待超時，單位：毫秒  
    timeout: 3000  
    # 發(fā)布和訂閱連接池大小  
    subscriptionConnectionPoolSize: 50

3.Java代碼

Constant

/**  
 * @author Baisu  
 * @classname RankingConstant  
 * @description 排行榜常量數(shù)據(jù)  
 * @since 2024/5/6  
 */
public class RankingConstant {  
  
    public static final Long BASIC_QUANTITY = 10000000000000L;  
  
    public static final Long MAXIMUM_TIME_TIMIT = 29991231235959L;  
}

Controller

import cn.hutool.core.date.DateTime;  
import cn.hutool.core.date.DateUtil;  
import com.ranking.demo.common.R;  
import com.ranking.demo.common.constant.RankingConstant;  
import com.ranking.demo.demain.RankingVo;  
import com.ranking.demo.utils.RankingUtil;  
import com.ranking.demo.utils.RedisKey;  
import com.ranking.demo.utils.RedisUtil;  
import org.redisson.client.protocol.ScoredEntry;  
import org.springframework.beans.factory.annotation.Value;  
import org.springframework.web.bind.annotation.*;  
  
import java.util.ArrayList;  
import java.util.Collection;  
import java.util.List;  
  
/**  
 * @author Baisu  
 * @since 2024/4/28  
 */
@RestController  
public class DemoRankingController {  
  
    @Value("${spring.application.name}")  
    private String applicationName;  
  
    /**  
     * 項目啟動測試方法  
     *  
     * @return applicationName  
     */    
    @GetMapping("")  
    public String demo() {  
        return applicationName;  
    }  
  
    /**  
     * 生成測試數(shù)據(jù)  
     *  
     * @return ok  
     */    
	@GetMapping("/generate_test_data")  
    public R<Object> generateTestData() {  
        RedisUtil.addScoreByMember(RedisKey.getRankingDemoKey(), 1L, "10001");  
        RedisUtil.addScoreByMember(RedisKey.getRankingDemoKey(), 2L, "10002");  
        RedisUtil.addScoreByMember(RedisKey.getRankingDemoKey(), 3L, "10003");  
        RedisUtil.addScoreByMember(RedisKey.getRankingDemoKey(), 4L, "10004");  
        RedisUtil.addScoreByMember(RedisKey.getRankingDemoKey(), 5L, "10005");  
        return R.ok();  
    }  
  
    /**  
     * 獲取排行榜數(shù)據(jù)  
     *  
     * @param top 數(shù)量  
     * @return 排行榜數(shù)據(jù)  
     */  
    @GetMapping("/get_ranking")  
    public R<Object> getRanking(@RequestParam("top") Integer top) {  
        Collection<ScoredEntry<Object>> ranking = RedisUtil.getRanking(RedisKey.getRankingDemoKey(), 0, top - 1);  
        if (ranking.size() == 0) {  
            return R.fail("暫無排行榜數(shù)據(jù)");  
        }  
        List<RankingVo> list = new ArrayList<>();  
        for (ScoredEntry<Object> entry : ranking) {  
            RankingVo vo = new RankingVo();  
            vo.setMember(entry.getValue().toString());  
            vo.setScore(RankingUtil.getScore(entry.getScore()));  
            vo.setTime(RankingUtil.getTimeStr(entry.getScore()));  
            list.add(vo);  
        }  
        return R.ok(list);  
    }  
  
    /**  
     * 增加成員分?jǐn)?shù)值  
     *  
     * @param member 成員  
     * @return 是否增加成功  
     */  
    @GetMapping("/add_score_by_member")  
    public R<Object> addScoreByMember(@RequestParam("member") String member) {  
        Double scoreByMember = RedisUtil.getScoreByMember(RedisKey.getRankingDemoKey(), member);  
        if (scoreByMember == null) {  
            scoreByMember = 0.0;  
        }  
        RedisUtil.addScoreByMember(RedisKey.getRankingDemoKey(), RankingUtil.getScore(scoreByMember) + 1, member);  
        return R.ok();  
    }  
  
    /**  
     * 獲取成員分?jǐn)?shù)值  
     *  
     * @param member 成員  
     * @return 分?jǐn)?shù)值  
     */  
    @GetMapping("/get_score_by_member")  
    public R<Object> getScoreByMember(@RequestParam("member") String member) {  
        Double scoreByMember = RedisUtil.getScoreByMember(RedisKey.getRankingDemoKey(), member);  
        if (scoreByMember == null) {  
            return R.fail("該成員不存在");  
        }  
        RankingVo vo = new RankingVo();  
        vo.setMember(member);  
        vo.setScore(RankingUtil.getScore(scoreByMember));  
        vo.setTime(RankingUtil.getTimeStr(scoreByMember));  
        return R.ok(vo);  
    }  
  
}

Domain

import lombok.Data;  
  
/**  
 * @author Baisu  
 * @classname RankingVo  
 * @description 排行榜展示類  
 * @since 2024/5/6  
 */
@Data  
public class RankingVo {  
  
    /**  
     * 成員  
     */  
    private String member;  
    /**  
     * 分?jǐn)?shù)值  
     */  
    private Long score;  
    /**  
     * 時間  
     */  
    private String time;  
  
}

/**  
 * @author Baisu  
 * @classname RedisKey  
 * @description Redis索引  
 * @since 2024/5/6  
 */
public class RedisKey {  
  
    private static final String RANKING_DEMO_KEY = "ranking_demo";  
  
    public static String getRankingDemoKey() {  
        return RANKING_DEMO_KEY;  
    }  
}

import cn.hutool.core.date.DateTime;  
import cn.hutool.core.date.DateUtil;  
import cn.hutool.extra.spring.SpringUtil;  
import com.ranking.demo.common.constant.RankingConstant;  
import org.redisson.api.RScoredSortedSet;  
import org.redisson.api.RedissonClient;  
import org.redisson.client.protocol.ScoredEntry;  
  
import java.util.Collection;  
  
/**  
 * @author Baisu  
 * @classname RedisUtil  
 * @description Redis工具類  
 * @since 2024/5/6  
 */
public class RedisUtil {  
  
    private static final RedissonClient REDISSON_CLIENT = SpringUtil.getBean(RedissonClient.class);  
  
    /**  
     * 向有序集合中添加指定分?jǐn)?shù)的成員  
     *  
     * @param key    有序集索引  
     * @param score  分?jǐn)?shù)  
     * @param member 成員  
     * @return 是否成功  
     */  
    public static boolean addScoreByMember(String key, Long score, String member) {  
        RScoredSortedSet<String> rScoredSortedSet = REDISSON_CLIENT.getScoredSortedSet(key);  
        double v = score * RankingConstant.BASIC_QUANTITY + (RankingConstant.MAXIMUM_TIME_TIMIT - Long.parseLong(DateUtil.format(DateTime.now(), RankingUtil.FORMAT)));  
        return rScoredSortedSet.add(v, member);  
    }  
  
    /**  
     * 返回有序集中成員的分?jǐn)?shù)值  
     *  
     * @param key    有序集索引  
     * @param member 成員  
     * @return 分?jǐn)?shù)值(Double)  
     */    
     public static Double getScoreByMember(String key, String member) {  
        RScoredSortedSet<Object> scoredSortedSet = REDISSON_CLIENT.getScoredSortedSet(key);  
        return scoredSortedSet.getScore(member);  
    }  
  
    /**  
     * 返回有序集中指定位置的成員集合  
     *  
     * @param key   有序集索引  
     * @param start 開始索引  
     * @param end   結(jié)束索引  
     * @return 成員集合  
     */  
    public static Collection<ScoredEntry<Object>> getRanking(String key, int start, int end) {  
        RScoredSortedSet<Object> rScoredSortedSet = REDISSON_CLIENT.getScoredSortedSet(key);  
        return rScoredSortedSet.entryRangeReversed(start, end);  
    }  
  
}

import cn.hutool.core.date.DateUtil;  
import com.ranking.demo.common.constant.RankingConstant;  
  
/**  
 * @author Baisu  
 * @classname RankingUtil  
 * @description 排行榜工具類  
 * @since 2024/5/7  
 */
 public class RankingUtil {  
  
    public static final String FORMAT = "yyyyMMddHHmmss";  
  
    public static Long getScore(Double score) {  
        return Math.round(Math.floor(score / RankingConstant.BASIC_QUANTITY));  
    }  
  
    public static String getTimeStr(Double score) {  
        return String.valueOf(DateUtil.parse(String.valueOf(RankingConstant.MAXIMUM_TIME_TIMIT - Math.round(Math.floor(score)) % RankingConstant.BASIC_QUANTITY)));  
    }  
}

4、接口文檔

ranking_demo接口文檔

以上就是SpringBoot+Redission實現(xiàn)排行榜功能的示例代碼的詳細(xì)內(nèi)容，更多關(guān)于SpringBoot Redission排行榜的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章:

最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

SpringBoot+Redission實現(xiàn)排行榜功能的示例代碼

目錄

SpringBoot+Redission實現(xiàn)排行榜功能

一、業(yè)務(wù)需求

二、Redis中的zSet(有序集合)

1.簡介

2.特點

3.常用命令

4.測試

5.總結(jié)

三、增加時間數(shù)據(jù)

四、SpringBoot代碼

1.引入Redis和Redission依賴

2.application.yml配置

3.Java代碼

4、接口文檔

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

SpringBoot+Redission實現(xiàn)排行榜功能的示例代碼

目錄

SpringBoot+Redission實現(xiàn)排行榜功能

一、業(yè)務(wù)需求

二、Redis中的zSet(有序集合)

1.簡介

2.特點

3.常用命令

4.測試

5.總結(jié)

三、增加時間數(shù)據(jù)

四、SpringBoot代碼

1.引入Redis和Redission依賴

2.application.yml配置

3.Java代碼

4、接口文檔

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

一、業(yè)務(wù)需求

二、Redis中的zSet(有序集合)

四、SpringBoot代碼