??本文今天主要是集合(Sorted Set)的方法的使用,以及redis對應(yīng)的Java實(shí)現(xiàn)該怎么用。因?yàn)槠鶈栴},我這里寫了一個(gè)測試類,引入RedisTemplate對象,后面例子里就不一一引入了。大家理解就行,如果大家還不知道如何通過Spring Boot整合redis則可以查看我之前的文章:SpringBoot整合redis(redis支持單節(jié)點(diǎn)和集群),這一章注定是枯燥的,但是可能也是實(shí)際中反而用得多的,大家看著辦了。
package com.alian.datastruct;
import lombok.extern.slf4j.Slf4j;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import java.util.List;
import java.util.concurrent.TimeUnit;
@Slf4j
@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest
public class RedisSortedSetTest {@Autowired
private RedisTemplateredisTemplate;
}
二、常用方法
2.1、ZADD語法
ZADD KEY_NAME SCORE1 MEMBER1... SCOREn MEMBERn
命令操作
127.0.0.1:6379>zadd zset1 95.0 taojianwen
(integer) 1
127.0.0.1:6379>zadd zset1 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 3
127.0.0.1:6379>zrange zset1 0 -1
1) "luokaocong"
2) "wanglin"
3) "tangpeng"
4) "taojianwen"
Java操作
@Test
public void zAdd() {String redisKey = "zSet1";
redisTemplate.delete(redisKey);
// 添加一個(gè)成員
redisTemplate.opsForZSet().add(redisKey, "taojianwen",95.0);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 獲取成員的信息
Set
獲取集合的信息:[luokaocong, wanglin, tangpeng, taojianwen]
2.2、ZREM語法
ZREM KEY_NAME MEMBER [MEMBER ...]
命令操作
127.0.0.1:6379>zadd zset2 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zrem zset2 luokaocong
(integer) 1
127.0.0.1:6379>zrange zset2 0 -1
1) "wanglin"
2) "tangpeng"
3) "taojianwen"
Java操作
@Test
public void zRem() {String redisKey = "zSet2";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 移除成員
Long num = redisTemplate.opsForZSet().remove(redisKey, "luokaocong");
log.info("移除成員的個(gè)數(shù):{}", num);
// 獲取成員的信息
Set
移除成員的個(gè)數(shù):1
獲取集合的信息:[wanglin, tangpeng, taojianwen]
2.3、ZSCORE語法
ZSCORE KEY_NAME MEMBER
命令操作
127.0.0.1:6379>zadd zset3 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zscore zset3 taojianwen
"95"
Java操作
@Test
public void zScore() {String redisKey = "zSet3";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 獲取成員的分?jǐn)?shù)
Double score = redisTemplate.opsForZSet().score(redisKey, "taojianwen");
log.info("獲取成員的分?jǐn)?shù):{}", score);
}
獲取成員的分?jǐn)?shù):95.0
2.4、ZINCRBY語法
ZINCRBY KEY_NAME increment MEMBER
命令操作
127.0.0.1:6379>zadd zset4 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zincrby zset4 2 taojianwen
"97"
127.0.0.1:6379>zincrby zset4 2 tangpeng
"94"
Java操作
@Test
public void zIncrBy() {String redisKey = "zSet4";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 獲取成員的分?jǐn)?shù)
redisTemplate.opsForZSet().incrementScore(redisKey, "taojianwen",2);
redisTemplate.opsForZSet().incrementScore(redisKey, "tangpeng",2);
// 獲取成員的分?jǐn)?shù)
Double score = redisTemplate.opsForZSet().score(redisKey, "taojianwen");
log.info("成員taojianwen的分?jǐn)?shù):{}", score);
Double score2 = redisTemplate.opsForZSet().score(redisKey, "tangpeng");
log.info("成員tangpeng的分?jǐn)?shù):{}", score2);
}
成員taojianwen的分?jǐn)?shù):97.0
成員tangpeng的分?jǐn)?shù):94.0
2.5、ZCARD語法
ZCARD KEY_NAME
命令操作
127.0.0.1:6379>zadd zset5 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zcard zset5
(integer) 4
Java操作
@Test
public void zCard() {String redisKey = "zSet5";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 獲取成員的分?jǐn)?shù)
Long size = redisTemplate.opsForZSet().size(redisKey);
log.info("成員的個(gè)數(shù):{}", size);
}
成員的個(gè)數(shù):4
2.6、ZRANK、ZREVRANK語法
ZRANK KEY_NAME MEMBER
ZREVRANK KEY_NAME MEMBER
命令操作
127.0.0.1:6379>zadd zset6 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zrank zset6 taojianwen
(integer) 3
127.0.0.1:6379>zrank zset6 luokaocong
(integer) 0
127.0.0.1:6379>zrevrank zset6 taojianwen
(integer) 0
127.0.0.1:6379>zrevrank zset6 luokaocong
(integer) 3
ZRANK
排名 | 0 | 1 | 2 | 3 |
---|---|---|---|---|
分值 | 90.0 | 91.0 | 92.0 | 95.0 |
成員 | luokaocong | wanglin | tangpeng | taojianwen |
ZREVRANK
排名 | 0 | 1 | 2 | 3 |
---|---|---|---|---|
分值 | 95.0 | 92.0 | 91.0 | 90.0 |
成員 | taojianwen | tangpeng | wanglin | luokaocong |
Java操作
@Test
public void zRankAndZRevRank() {String redisKey = "zSet6";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 返回有序集中指定成員的排名
Long rank1 = redisTemplate.opsForZSet().rank(redisKey,"taojianwen");
log.info("有序集中指定成員的(升序)排名為:{}", rank1);
Long rank2 = redisTemplate.opsForZSet().rank(redisKey,"luokaocong");
log.info("有序集中指定成員的(升序)排名為:{}", rank2);
Long rank3 = redisTemplate.opsForZSet().reverseRank(redisKey, "taojianwen");
log.info("有序集中指定成員的(降序)排名為:{}", rank3);
Long rank4 = redisTemplate.opsForZSet().reverseRank(redisKey, "luokaocong");
log.info("有序集中指定成員的(降序)排名為:{}", rank4);
}
有序集中指定成員的(升序)排名為:3
有序集中指定成員的(升序)排名為:0
有序集中指定成員的(降序)排名為:0
有序集中指定成員的(降序)排名為:3
2.7、ZRANGE、ZREVRANGE語法
ZRANGE KEY_NAME start stop [WITHSCORES]
ZREVRANGE KEY_NAME start stop [WITHSCORES]
命令操作
127.0.0.1:6379>zadd zset7 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zrange zset7 0 -1
1) "luokaocong"
2) "wanglin"
3) "tangpeng"
4) "taojianwen"
127.0.0.1:6379>zrevrange zset7 0 -1
1) "taojianwen"
2) "tangpeng"
3) "wanglin"
4) "luokaocong"
ZRANGE
索引 | 0 | 1 | 2 | 3 |
---|---|---|---|---|
分值 | 90.0 | 91.0 | 92.0 | 95.0 |
成員 | luokaocong | wanglin | tangpeng | taojianwen |
ZREVRANGE
索引 | 0 | 1 | 2 | 3 |
---|---|---|---|---|
分值 | 95.0 | 92.0 | 91.0 | 90.0 |
成員 | taojianwen | tangpeng | wanglin | luokaocong |
從 到 -1 就是全部
Java操作
@Test
public void zRangeAndZRevRange() {String redisKey = "zSet7";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 返回有序集中指定區(qū)間的成員
Set
有序集中指定區(qū)間的成員(分值升序):[luokaocong, wanglin, tangpeng, taojianwen]
有序集中指定區(qū)間的成員(分值降序):[taojianwen, tangpeng, wanglin, luokaocong]
2.8、ZRANGEBYSCORE、ZREVRANGEBYSCORE語法
ZRANGEBYSCORE KEY_NAME min max [WITHSCORES] [LIMIT offset count]
ZREVRANGEBYSCORE KEY_NAME max min [WITHSCORES] [LIMIT offset count]
命令操作
127.0.0.1:6379>zadd zset8 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zrangebyscore zset8 91 92 WITHSCORES
1) "wanglin"
2) "91"
3) "tangpeng"
4) "92"
127.0.0.1:6379>zrevrangebyscore zset8 92 91 WITHSCORES
1) "tangpeng"
2) "92"
3) "wanglin"
4) "91"
#查全部
127.0.0.1:6379>zrangebyscore zset8 -INF +INF WITHSCORES
1) "luokaocong"
2) "90"
3) "wanglin"
4) "91"
5) "tangpeng"
6) "92"
7) "taojianwen"
8) "95"
#查大于91小于等于95的
127.0.0.1:6379>zrangebyscore zset8 (91 95 WITHSCORES
1) "tangpeng"
2) "92"
3) "taojianwen"
4) "95"
Java操作
@Test
public void zRangeBySoreAndZRevRangeBySore() {String redisKey = "zSet8";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 通過分?jǐn)?shù)返回有序集合指定區(qū)間內(nèi)的成員
Setrange = redisTemplate.opsForZSet().rangeByScore(redisKey, 91.0, 92.0);
log.info("通過分?jǐn)?shù)返回有序集合指定區(qū)間內(nèi)的成員(分值升序):{}", range);
Setrange2 = redisTemplate.opsForZSet().reverseRangeByScore(redisKey, 91.0, 92.0);
log.info("通過分?jǐn)?shù)返回有序集合指定區(qū)間內(nèi)的成員(分值降序):{}", range2);
}
通過分?jǐn)?shù)返回有序集合指定區(qū)間內(nèi)的成員(分值升序):[wanglin, tangpeng]
通過分?jǐn)?shù)返回有序集合指定區(qū)間內(nèi)的成員(分值降序):[tangpeng, wanglin]
2.9、ZCOUNT語法
ZCOUNT KEY_NAME min max
命令操作
127.0.0.1:6379>zadd zset9 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zcount zset9 91 92
(integer) 2
127.0.0.1:6379>zcount zset9 90 95
(integer) 4
Java操作
@Test
public void zCount() {String redisKey = "zSet9";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 返回指定區(qū)間分?jǐn)?shù)的成員數(shù)
Long count = redisTemplate.opsForZSet().count(redisKey, 91.0, 92.0);
log.info("返回指定區(qū)間分?jǐn)?shù)的成員數(shù):{}", count);
Long count2 = redisTemplate.opsForZSet().count(redisKey, 90.0, 95.0);
log.info("返回指定區(qū)間分?jǐn)?shù)的成員數(shù):{}", count2);
}
返回指定區(qū)間分?jǐn)?shù)的成員數(shù):2
返回指定區(qū)間分?jǐn)?shù)的成員數(shù):4
2.10、ZREMRANGEBYRANK語法
ZREMRANGEBYRANK KEY_NAME start stop
命令操作
127.0.0.1:6379>zadd zset10 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zremrangebyrank zset10 1 2
(integer) 2
127.0.0.1:6379>zrange zset10 0 -1 withscores
1) "luokaocong"
2) "90"
3) "taojianwen"
4) "95"
Java操作
@Test
public void zRemRangeByRank() {String redisKey = "zSet10";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 移除有序集合中給定的排名區(qū)間的所有成員
Long num = redisTemplate.opsForZSet().removeRange(redisKey, 1, 2);
log.info("移除的成員數(shù):{}", num);
// 獲取成員的信息
Setrange = redisTemplate.opsForZSet().range(redisKey, 0, -1);
log.info("獲取集合的信息:{}", range);
}
移除的成員數(shù):2
獲取集合的信息:[luokaocong, taojianwen]
2.11、ZREMRANGEBYSCORE語法
ZREMRANGEBYSCORE KEY_NAME min max
命令操作
127.0.0.1:6379>zadd zset11 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zremrangebyscore zset11 91 96
(integer) 3
127.0.0.1:6379>zrange zset11 0 -1 withscores
1) "luokaocong"
2) "90"
Java操作
@Test
public void zRemRangeByScore() {String redisKey = "zSet11";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple=new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey,tuple);
// 移除有序集合中給定的分?jǐn)?shù)區(qū)間的所有成員
Long num = redisTemplate.opsForZSet().removeRangeByScore(redisKey, 91, 96);
log.info("移除的成員數(shù):{}", num);
// 獲取成員的信息
Setrange = redisTemplate.opsForZSet().range(redisKey, 0, -1);
log.info("獲取集合的信息:{}", range);
}
移除的成員數(shù):3
獲取集合的信息:[luokaocong]
2.12、ZINTERSTORE、ZUNIONSTORE語法
ZINTERSTORE destination numkeys key [key ...]
ZUNIONSTORE destination numkeys key [key ...]
命令操作
127.0.0.1:6379>zadd zset12 95.0 taojianwen 92.0 tangpeng 91.0 wanglin
(integer) 3
127.0.0.1:6379>zadd zset13 88.0 tangpeng 80.0 wanglin
(integer) 2
127.0.0.1:6379>zinterstore interStore 2 zset12 zset13
(integer) 2
127.0.0.1:6379>zrange interStore 0 -1 withscores
1) "wanglin"
2) "171"
3) "tangpeng"
4) "180"
127.0.0.1:6379>zunionstore unionStore 2 zset12 zset13
(integer) 3
127.0.0.1:6379>zrange unionStore 0 -1 withscores
1) "taojianwen"
2) "95"
3) "wanglin"
4) "171"
5) "tangpeng"
6) "180"
Java操作
@Test
public void zInterStoreAndZUnionStore() {String redisKey = "zSet12";
String redisKey1 = "zSet13";
redisTemplate.delete(redisKey);
redisTemplate.delete(redisKey1);
redisTemplate.opsForZSet().add(redisKey,"taojianwen", 95.0);
redisTemplate.opsForZSet().add(redisKey,"tangpeng", 92.0);
redisTemplate.opsForZSet().add(redisKey,"wanglin", 91.0);
redisTemplate.opsForZSet().add(redisKey1,"tangpeng", 88.0);
redisTemplate.opsForZSet().add(redisKey1,"wanglin", 80.0);
// 計(jì)算給定的一個(gè)或多個(gè)有序集的交集,存儲(chǔ)到集合interStore
Long num = redisTemplate.opsForZSet().intersectAndStore(redisKey, redisKey1, "interStore");
log.info("交集的成員數(shù):{}", num);
// 獲取成員的信息
Setrange = redisTemplate.opsForZSet().range("interStore", 0, -1);
log.info("獲取集合的信息:{}", range);
// 計(jì)算給定的一個(gè)或多個(gè)有序集的并集,存儲(chǔ)到集合unionStore
Long num1 = redisTemplate.opsForZSet().unionAndStore(redisKey, redisKey1, "unionStore");
log.info("并集的成員數(shù):{}", num1);
// 獲取成員的信息
Setrange1 = redisTemplate.opsForZSet().range("unionStore", 0, -1);
log.info("獲取集合的信息:{}", range1);
}
交集的成員數(shù):2
獲取集合的信息:[wanglin, tangpeng]
并集的成員數(shù):3
獲取集合的信息:[taojianwen, wanglin, tangpeng]
2.13、ZRANGEBYLEX、ZREVRANGEBYLEX語法
ZRANGEBYLEX KEY_NAME min max
ZREVRANGEBYLEX KEY_NAME max min
命令操作
127.0.0.1:6379>zadd zset14 100 aa 100 ab 100 bb 100 bc 100 cc 100 cd 100 dd
(integer) 7
127.0.0.1:6379>zrangebylex zset14 - +
1) "aa"
2) "ab"
3) "bb"
4) "bc"
5) "cc"
6) "cd"
7) "dd"
127.0.0.1:6379>zrangebylex zset14 (bb [cd
1) "bc"
2) "cc"
3) "cd"
127.0.0.1:6379>zrevrangebylex zset14 [cd (bb
1) "cd"
2) "cc"
3) "bc"
Java操作
@Test
public void zRangeByLexAndZRevRangeByLex() {String redisKey = "zSet14";
redisTemplate.delete(redisKey);
redisTemplate.opsForZSet().add(redisKey, "aa", 100);
redisTemplate.opsForZSet().add(redisKey, "ab", 100);
redisTemplate.opsForZSet().add(redisKey, "bb", 100);
redisTemplate.opsForZSet().add(redisKey, "bc", 100);
redisTemplate.opsForZSet().add(redisKey, "cc", 100);
redisTemplate.opsForZSet().add(redisKey, "cd", 100);
redisTemplate.opsForZSet().add(redisKey, "dd", 100);
RedisZSetCommands.Range range = new RedisZSetCommands.Range();
range.gt("bb");
range.lte("cd");
// 字典序指定范圍內(nèi)的成員
Setset1 = redisTemplate.opsForZSet().rangeByLex(redisKey, range);
log.info("字典序指定范圍內(nèi)的成員:{}", set1);
Setset2 = redisTemplate.opsForZSet().reverseRangeByLex(redisKey, range);
log.info("字典序指定范圍內(nèi)的成員:{}", set2);
}
結(jié)果未生效,官方文檔說明暫不支持該命令
2.14、ZLEXCOUNT語法
ZLEXCOUNT KEY_NAME MIN MAX
命令操作
127.0.0.1:6379>zadd zset15 100 aa 100 ab 100 bb 100 bc 100 cc 100 cd 100 dd
(integer) 7
127.0.0.1:6379>zlexcount zset15 (bb [cd
(integer) 3
Java操作
@Test
public void zLexCount() {String redisKey = "zSet15";
redisTemplate.delete(redisKey);
redisTemplate.opsForZSet().add(redisKey, "aa", 100);
redisTemplate.opsForZSet().add(redisKey, "ab", 100);
redisTemplate.opsForZSet().add(redisKey, "bb", 100);
redisTemplate.opsForZSet().add(redisKey, "bc", 100);
redisTemplate.opsForZSet().add(redisKey, "cc", 100);
redisTemplate.opsForZSet().add(redisKey, "cd", 100);
redisTemplate.opsForZSet().add(redisKey, "dd", 100);
RedisZSetCommands.Range range = new RedisZSetCommands.Range();
range.gt("bb");
range.lte("cd");
// 計(jì)算指定字典區(qū)間內(nèi)成員數(shù)量
Long count = redisTemplate.opsForZSet().lexCount(redisKey, range);
log.info("計(jì)算指定字典區(qū)間內(nèi)成員數(shù)量:{}", count);
}
結(jié)果未生效,官方文檔說明暫不支持該命令(見上圖)
2.15、ZREMRANGEBYLEX語法
ZREMRANGEBYLEX KEY_NAME min max
命令操作
127.0.0.1:6379>zadd zset16 100 aa 100 ab 100 bb 100 bc 100 cc 100 cd 100 dd
(integer) 7
127.0.0.1:6379>zremrangebylex zset16 (bb [cd
(integer) 3
127.0.0.1:6379>zrange zset16 0 -1 withscores
1) "aa"
2) "100"
3) "ab"
4) "100"
5) "bb"
6) "100"
7) "dd"
8) "100"
Java操作
@Test
public void zRemRangeByLex() {String redisKey = "zSet16";
redisTemplate.delete(redisKey);
redisTemplate.opsForZSet().add(redisKey, "aa", 100);
redisTemplate.opsForZSet().add(redisKey, "ab", 100);
redisTemplate.opsForZSet().add(redisKey, "bb", 100);
redisTemplate.opsForZSet().add(redisKey, "bc", 100);
redisTemplate.opsForZSet().add(redisKey, "cc", 100);
redisTemplate.opsForZSet().add(redisKey, "cd", 100);
redisTemplate.opsForZSet().add(redisKey, "dd", 100);
RedisZSetCommands.Range range = new RedisZSetCommands.Range();
range.gt("bb");
range.lte("cd");
// 移除有序集合中給定的字典區(qū)間的所有成員
Long count = redisTemplate.opsForZSet().removeRangeByLex(redisKey, range);
log.info("移除有序集合中給定的字典區(qū)間的所有成員:{}", count);
}
結(jié)果未生效,官方文檔說明暫不支持該命令(見上圖)
2.16、ZPOPMAX、ZPOPMIN語法
ZPOPMAX KEY_NAME [COUNT]
ZPOPMIN KEY_NAME [COUNT]
命令操作
127.0.0.1:6379>zadd zset17 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>zpopmax zset17 2
1) "taojianwen"
2) "95"
3) "tangpeng"
4) "92"
127.0.0.1:6379>zpopmin zset17 2
1) "luokaocong"
2) "90"
3) "wanglin"
4) "91"
Java操作
@Test
public void zPopMaXAndZPopMin() {String redisKey = "zSet17";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple = new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey, tuple);
// 彈出分?jǐn)?shù)最高的兩個(gè)成員
Set>typedTuples1 = redisTemplate.opsForZSet().popMax(redisKey, 2);
log.info("彈出分?jǐn)?shù)最高的兩個(gè)成員:{}", typedTuples1);
// 彈出分?jǐn)?shù)最低的兩個(gè)成員
Set>typedTuples2 = redisTemplate.opsForZSet().popMin(redisKey, 2);
log.info("彈出分?jǐn)?shù)最低的兩個(gè)成員:{}", typedTuples2);
}
彈出分?jǐn)?shù)最高的兩個(gè)成員:[DefaultTypedTuple [score=95.0, value=taojianwen], DefaultTypedTuple [score=92.0, value=tangpeng]]
彈出分?jǐn)?shù)最低的兩個(gè)成員:[DefaultTypedTuple [score=90.0, value=luokaocong], DefaultTypedTuple [score=91.0, value=wanglin]]
2.17、BZPOPMAX、BZPOPMIN語法
命令操作
127.0.0.1:6379>zadd zset18 95.0 taojianwen 92.0 tangpeng 91.0 wanglin 90.0 luokaocong
(integer) 4
127.0.0.1:6379>bzpopmax zset18 10
1) "zset18"
2) "taojianwen"
3) "95"
127.0.0.1:6379>bzpopmin zset18 10
1) "zset18"
2) "luokaocong"
3) "90"
Java操作
@Test
public void zBPopMaXAndZBPopMin() {String redisKey = "zSet18";
redisTemplate.delete(redisKey);
// 添加多個(gè)成員
Set>tuple = new HashSet<>();
tuple.add(new DefaultTypedTuple<>("taojianwen", 95.0));
tuple.add(new DefaultTypedTuple<>("tangpeng", 92.0));
tuple.add(new DefaultTypedTuple<>("wanglin", 91.0));
tuple.add(new DefaultTypedTuple<>("luokaocong", 90.0));
redisTemplate.opsForZSet().add(redisKey, tuple);
// 阻塞式彈出分?jǐn)?shù)最高的成員,如果沒有,則直到超時(shí)
ZSetOperations.TypedTupleobjectTypedTuple = redisTemplate.opsForZSet().popMax(redisKey, 10, TimeUnit.SECONDS);
log.info("彈出分?jǐn)?shù)最高的成員:{}", objectTypedTuple);
// 阻塞式彈出分?jǐn)?shù)最低的成員,如果沒有,則直到超時(shí)
ZSetOperations.TypedTupleobjectTypedTuple2 = redisTemplate.opsForZSet().popMin(redisKey, 10, TimeUnit.SECONDS);
log.info("彈出分?jǐn)?shù)最低的成員:{}", objectTypedTuple2);
}
彈出分?jǐn)?shù)最高的成員:DefaultTypedTuple [score=95.0, value=taojianwen]
彈出分?jǐn)?shù)最低的成員:DefaultTypedTuple [score=90.0, value=luokaocong]
你是否還在尋找穩(wěn)定的海外服務(wù)器提供商?創(chuàng)新互聯(lián)www.cdcxhl.cn海外機(jī)房具備T級流量清洗系統(tǒng)配攻擊溯源,準(zhǔn)確流量調(diào)度確保服務(wù)器高可用性,企業(yè)級服務(wù)器適合批量采購,新人活動(dòng)首月15元起,快前往官網(wǎng)查看詳情吧
新聞標(biāo)題:Redis集合(SortedSet)方法使用詳解-創(chuàng)新互聯(lián)
新聞來源:http://www.rwnh.cn/article2/gejoc.html
成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站改版、網(wǎng)站營銷、靜態(tài)網(wǎng)站、微信公眾號、ChatGPT、用戶體驗(yàn)
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容