基于redis實(shí)現(xiàn)世界杯排行榜功能項(xiàng)目實(shí)戰(zhàn)

server:
 port: 9001
spring:
 redis:
 database: 0
 url: redis://user:123@127.0.0.1:6379
 host: 127.0.0.1
 password: 123
 port: 6379
 ssl: false
 timeout: 5000

parent>
 groupId>org.springframework.boot/groupId>
 artifactId>spring-boot-starter-parent/artifactId>
 version>2.0.4.RELEASE/version>
/parent>

dependencies>
 dependency>
 groupId>org.springframework.boot/groupId>
 artifactId>spring-boot-starter-web/artifactId>
 /dependency>
 dependency>
 groupId>org.springframework.boot/groupId>
 artifactId>spring-boot-starter-data-redis/artifactId>
 /dependency>
 dependency>
 groupId>org.springframework.boot/groupId>
 artifactId>spring-boot-starter-test/artifactId>
 /dependency>
/dependencies>

 @Autowired
 private StringRedisTemplate redisTemplate;
 public static final String SCORE_RANK = "score_rank";

 /**
 * 批量新增
 */
 @Test
 public void batchAdd() {
 SetZSetOperations.TypedTupleString>> tuples = new HashSet>();
 long start = System.currentTimeMillis();
 for (int i = 0; i  100000; i++) {
 DefaultTypedTupleString> tuple = new DefaultTypedTuple>("張三" + i, 1D + i);
 tuples.add(tuple);
 }
 System.out.println("循環(huán)時(shí)間:" +( System.currentTimeMillis() - start));
 Long num = redisTemplate.opsForZSet().add(SCORE_RANK, tuples);
 System.out.println("批量新增時(shí)間:" +(System.currentTimeMillis() - start));
 System.out.println("受影響行數(shù)：" + num);
 }

 /**
 * 獲取排行列表
 */
 @Test
 public void list() {

 SetString> range = redisTemplate.opsForZSet().reverseRange(SCORE_RANK, 0, 10);
 System.out.println("獲取到的排行列表:" + JSON.toJSONString(range));
 SetZSetOperations.TypedTupleString>> rangeWithScores = redisTemplate.opsForZSet().reverseRangeWithScores(SCORE_RANK, 0, 10);
 System.out.println("獲取到的排行和分?jǐn)?shù)列表:" + JSON.toJSONString(rangeWithScores));
 }

//輸出
獲取到的排行列表:["張三99999","張三99998","張三99997","張三99996","張三99995","張三99994","張三99993","張三99992","張三99991","張三99990","張三99989"]
獲取到的排行和分?jǐn)?shù)列表:[{"score":100000.0,"value":"張三99999"},{"score":99999.0,"value":"張三99998"},{"score":99998.0,"value":"張三99997"},{"score":99997.0,"value":"張三99996"},{"score":99996.0,"value":"張三99995"},{"score":99995.0,"value":"張三99994"},{"score":99994.0,"value":"張三99993"},{"score":99993.0,"value":"張三99992"},{"score":99992.0,"value":"張三99991"},{"score":99991.0,"value":"張三99990"},{"score":99990.0,"value":"張三99989"}]

 /**
 * 單個(gè)新增
 */
 @Test
 public void add() {
 redisTemplate.opsForZSet().add(SCORE_RANK, "李四", 8899);
 }

 /**
 * 獲取單個(gè)的排行
 */
 @Test
 public void find(){
 Long rankNum = redisTemplate.opsForZSet().reverseRank(SCORE_RANK, "李四");
 System.out.println("李四的個(gè)人排名：" + rankNum);

 Double score = redisTemplate.opsForZSet().score(SCORE_RANK, "李四");
 System.out.println("李四的分?jǐn)?shù):" + score);
 }

 /**
 * 統(tǒng)計(jì)兩個(gè)分?jǐn)?shù)之間的人數(shù)
 */
 @Test
 public void count(){
 Long count = redisTemplate.opsForZSet().count(SCORE_RANK, 8001, 9000);
 System.out.println("統(tǒng)計(jì)8001-9000之間的人數(shù):" + count);
 }

 /**
 * 獲取整個(gè)集合的基數(shù)(數(shù)量大小)
 */
 @Test
 public void zCard(){
 Long aLong = redisTemplate.opsForZSet().zCard(SCORE_RANK);
 System.out.println("集合的基數(shù)為：" + aLong);
 }

 /**
 * 使用加法操作分?jǐn)?shù)
 */
 @Test
 public void incrementScore(){
 Double score = redisTemplate.opsForZSet().incrementScore(SCORE_RANK, "李四", 1000);
 System.out.println("李四分?jǐn)?shù)+1000后：" + score);
 }

//單個(gè)新增or更新
Boolean add(K key, V value, double score);
//批量新增or更新
Long add(K key, SetTypedTupleV>> tuples);
//使用加法操作分?jǐn)?shù)
Double incrementScore(K key, V value, double delta);

//通過(guò)key/value刪除
Long remove(K key, Object... values);
//通過(guò)排名區(qū)間刪除
Long removeRange(K key, long start, long end);
//通過(guò)分?jǐn)?shù)區(qū)間刪除
Long removeRangeByScore(K key, double min, double max);

//通過(guò)排名區(qū)間獲取列表值集合
SetV> range(K key, long start, long end);
//通過(guò)排名區(qū)間獲取列表值和分?jǐn)?shù)集合
SetTypedTupleV>> rangeWithScores(K key, long start, long end);
//通過(guò)分?jǐn)?shù)區(qū)間獲取列表值集合
SetV> rangeByScore(K key, double min, double max);
//通過(guò)分?jǐn)?shù)區(qū)間獲取列表值和分?jǐn)?shù)集合
SetTypedTupleV>> rangeByScoreWithScores(K key, double min, double max);
//通過(guò)Range對(duì)象刪選再獲取集合排行
SetV> rangeByLex(K key, Range range);
//通過(guò)Range對(duì)象刪選再獲取limit數(shù)量的集合排行
SetV> rangeByLex(K key, Range range, Limit limit);

//獲取個(gè)人排行
Long rank(K key, Object o);
//獲取個(gè)人分?jǐn)?shù)
Double score(K key, Object o);

//統(tǒng)計(jì)分?jǐn)?shù)區(qū)間的人數(shù)
Long count(K key, double min, double max);
//統(tǒng)計(jì)集合基數(shù)
Long zCard(K key);