前言
這一篇文章将講述Redis中的sortedset類型指令,同樣也是通過demo來講述,其他部分這裡就不在贅述了。
項目Github位址:
https://github.com/rainbowda/learnWay/tree/master/learnRedis/case-sortedset案例
demo功能是文章點贊排名等等,整個demo的大緻頁面如下。
準備工作
首先定義一個存儲文章的key
private static final String ZSET_KEY = "articleList";
redis操作對象
private RedisTemplate redisTemplate;
//string 指令操作對象
private ValueOperations valueOperations;
//zset 指令操作對象
private ZSetOperations zSetOperations;
sortedset在Redis中的結構可以看下圖(圖檔來源于Redis in Action)。
清單查詢
@RequestMapping(value = "/getList/{sortType}", method = RequestMethod.GET)
public Set getList(@PathVariable String sortType) {
//如果沒有資料,則添加10條資料
if (zSetOperations.size(ZSET_KEY) == 0){
for (int i = 1; i <= 10; i++) {
zSetOperations.add(ZSET_KEY,"文章:"+i, (int)(Math.random()*10+i));
}
}
//ASC根據分數從小到大排序,DESC反之
if ("ASC".equals(sortType)){
return zSetOperations.rangeWithScores(ZSET_KEY, 0, -1);
} else {
return zSetOperations.reverseRangeWithScores(ZSET_KEY, 0, -1);
}
}
這裡為了省去一個個添加資料的麻煩,就在擷取清單資料中加了個判斷。當文章資料為0時,預設添加10條資料,設定随機score加上所在的索引。
然後根據url中的參數sortType來決定傳回的資料是按照分數升序還是降序排序。功能效果如下
指令介紹
指令 | 用例 | 描述 | |
---|---|---|---|
ZADD | ZADD key [NX\ | XX][CH] [INCR] score member [score member ...] | 将所有指定成員添加到鍵為 有序集合(sorted set)裡面 |
ZRANGE | ZRANGE key start stop [WITHSCORES] | 傳回有序集key中,指定區間内的成員。其中成員的位置按score值遞減(從小到大)來排列。 | |
ZREVRANGE | ZREVRANGE key start stop [WITHSCORES] | 傳回有序集key中,指定區間内的成員。其中成員的位置按score值遞減(從大到小)來排列。 |
贊或踩
java代碼如下
@RequestMapping(value = "/star", method = RequestMethod.POST)
public boolean starOrUnStar(String member, String type) {
if ("UP".equals(type)){
zSetOperations.incrementScore(ZSET_KEY, member, 1);
} else {
zSetOperations.incrementScore(ZSET_KEY, member, -1);
}
return true;
}
根據type決定是否加減分數,當type為UP時表示贊,為其他(DOWN)時表示踩。功能效果如下
ZINCRBY | ZINCRBY key increment member | 為有序集key的成員member的score值加上增量increment |
升降序排名
@RequestMapping(value = "/rank/{type}/{member}", method = RequestMethod.GET)
public Long rank(@PathVariable String member, @PathVariable String type) {
Long rank = null;
if ("ASC".equals(type)){
rank = zSetOperations.rank(ZSET_KEY, member);
} else {
rank = zSetOperations.reverseRank(ZSET_KEY, member);
}
return rank;
}
根據type決定是升序排名還是降序排名,如果是ASC則調用rank方法擷取升序排名,其他則調用reverseRank擷取降序排名。與下方redis指令類似
ZRANK articleList "文章1"
ZREVRANK articleList "文章1"
頁面效果圖如下
ZRANK | ZRANK key member | 傳回有序集key中成員member的排名。其中有序內建員按score值遞增(從小到大)順序排列。排名以0為底,也就是說,score值最小的成員排名為0。 |
ZREVRANK | ZREVRANK key member | 傳回有序集key中成員member的排名,其中有序內建員按score值從大到小排列。 |
其他指令
擷取屬性
ZCARD | ZCARD key | 傳回key的有序集元素個數。 |
ZCOUNT | ZCOUNT key min max | 傳回有序集key中,score值在min和max之間(預設包括score值等于min或max)的成員個數。 |
ZLEXCOUNT | ZLEXCOUNT key min max | 用于計算有序集合中指定成員之間的成員數量。 |
ZSCORE | ZSCORE key member | 傳回有序集key中,成員member的score值。 |
ZCARD指令
傳回key的有序集元素個數。
ZCARD key
傳回值:key存在的時候,傳回有序集的元素個數,否則傳回0。
redis用戶端執行的指令如下
zadd zCardKey 1 one
zcard zCardKey
下面是java代碼
@Test
public void zCard() {
jedis.zadd("zCardKey",1, "one");
jedis.zadd("zCardKey",2, "two");
System.out.println(jedis.zcard("zCardKey"));
System.out.println(zSetOperations.size("zCardKey"));
}
ZCOUNT指令
傳回有序集key中,score值在min和max之間(預設包括score值等于min或max)的成員數量。
ZCOUNT key min max
傳回值:指定分數範圍的元素個數。
zadd zCountKey 1 one 2 two 3 three 4 four
zcount zCountKey 2 3
執行結果如下
@Test
public void zCount() {
jedis.zadd("zCountKey",1, "one");
jedis.zadd("zCountKey",2, "two");
jedis.zadd("zCountKey",3, "three");
jedis.zadd("zCountKey",4, "four");
System.out.println(jedis.zcount("zCountKey",2, 3));
System.out.println(zSetOperations.count("zCountKey",2, 3));
}
ZLEXCOUNT指令
計算有序集合中指定成員之間的成員數量(按成員字典正序排序),可以使用 - 和 + 表示score最小值和最大值
ZLEXCOUNT key min max
ZADD zLexCountKey 2 "b" 1 "a" 3 "c" 5 "e" 4 "d"
ZLEXCOUNT zLexCountKey - +
ZLEXCOUNT zLexCountKey [b [d
@Test
public void zLexCount() {
zSetOperations.add("zLexCountKey", "b", 2);
zSetOperations.add("zLexCountKey", "a", 1);
zSetOperations.add("zLexCountKey", "c", 3);
zSetOperations.add("zLexCountKey", "e", 5);
zSetOperations.add("zLexCountKey", "d", 4);
System.out.println(jedis.zlexcount("zLexCountKey", "-", "+"));
System.out.println(jedis.zlexcount("zLexCountKey", "[b", "[d"));
}
ZSCORE指令
傳回有序集key中,成員member的score值。
ZSCORE key member
傳回值:成員member的score值
zadd zScoreKey 1 one
ZSCORE zScoreKey one
@Test
public void zScore() {
jedis.zadd("zScoreKey",1, "one");
System.out.println(jedis.zscore("zScoreKey", "one"));
System.out.println(zSetOperations.score("zScoreKey", "one"));
}
擷取成員
ZRANGEBYLEX | ZRANGEBYLEX key min max | 傳回指定成員區間内的成員,按成員字典正序排序。 |
ZRANGEBYSCORE | ZRANGEBYSCORE key min max `[LIMIT offset count]` | 傳回所有符合score條件的成員 |
ZREVRANGEBYLEX | ZREVRANGEBYLEX key max min | 傳回指定成員區間内的成員,按成員字典倒序排序。 |
ZREVRANGEBYSCORE | ZREVRANGEBYSCORE key max min | 傳回有序集合中指定分數區間内的成員,分數由高到低排序。 |
ZSCAN | ZSCAN key cursor `[COUNT count]` | 請參考 SCAN |
ZRANGEBYLEX指令
https://redis.io/commands/zrangebylex [LIMIT offset count]
傳回值:指定成員範圍的元素清單。
ZADD zRangeByLexKey 0 ba 0 a 0 ab 0 aa 0 b
ZRANGEBYLEX zRangeByLexKey - +
ZRANGEBYLEX zRangeByLexKey [aa (ba
@Test
public void zRangeByLex() {
zSetOperations.add("zRangeByLexKey", "ba", 0);
zSetOperations.add("zRangeByLexKey", "a", 0);
zSetOperations.add("zRangeByLexKey", "ab", 0);
zSetOperations.add("zRangeByLexKey", "aa", 0);
zSetOperations.add("zRangeByLexKey", "b", 0);
System.out.println(jedis.zrangeByLex("zRangeByLexKey", "-", "+"));
RedisZSetCommands.Range range = new RedisZSetCommands.Range();
range.gte("aa");
range.lt("ba");
System.out.println(zSetOperations.rangeByLex("zRangeByLexKey",range));
}
ZRANGEBYSCORE指令
擷取score在範圍之内的資料。min和max可以是-inf和+inf
[WITHSCORES]
`[LIMIT offset count] `
ZADD zRangeByScoreKey 1 ba 2 a 3 ab 4 aa 5 b
ZRANGEBYSCORE zRangeByScoreKey -inf +inf
ZRANGEBYSCORE zRangeByScoreKey 2 4
@Test
public void zRangeByScore() {
zSetOperations.add("zRangeByScoreKey", "ba", 1);
zSetOperations.add("zRangeByScoreKey", "a", 2);
zSetOperations.add("zRangeByScoreKey", "ab", 3);
zSetOperations.add("zRangeByScoreKey", "aa", 4);
zSetOperations.add("zRangeByScoreKey", "b", 5);
System.out.println(jedis.zrangeByScore("zRangeByScoreKey", "-inf", "+inf"));
RedisZSetCommands.Range range = new RedisZSetCommands.Range();
System.out.println(zSetOperations.rangeByScore("zRangeByScoreKey", 2, 4));
}
移除相關指令
ZREM | ZREM key member [member ...] | 删除有序集合中的成員 |
ZREMRANGEBYLEX | ZREMRANGEBYLEX key min max | 删除名稱按字典由低到高排序成員之間所有成員 |
ZREMRANGEBYRANK | ZREMRANGEBYRANK key start stop | 移除有序集key中,指定排名(rank)區間内的所有成員。 |
ZREMRANGEBYSCORE | ZREMRANGEBYSCORE key min max | 移除有序集key中,所有score值介于min和max之間(包括等于min或max)的成員 |
ZREM指令
ZREM key member [member ...]
傳回值:有序集合中删除的成員個數
ZADD zRemKey 1 "one" 2 "two" 3 "three"
ZREM zRemKey one
ZRANGE zRemKey 0 -1
@Test
public void zRem() {
zSetOperations.add("zRemKey", "one", 1);
zSetOperations.add("zRemKey", "two", 2);
zSetOperations.add("zRemKey", "three", 3);
//jedis.zrem("zRemKey", "one");
zSetOperations.remove("zRemKey", "one");
System.out.println(zSetOperations.range("zRemKey", 0 , -1));
}
交并集
ZINTERSTORE | ZINTERSTORE destination numkeys key `[WEIGHTS weight] [SUM\ | MIN\ | MAX]` | 計算給定的numkeys個有序集合的交集,并且把結果放到destination中 |
ZUNIONSTORE | ZUNIONSTORE destination numkeys key | 計算給定的numkeys個有序集合的并集,并且把結果放到destination中 |
ZINTERSTORE指令
計算給定的numkeys個有序集合的交集,并且把結果放到destination中。
在給定要計算的key和其它參數之前,必須先給定key個數(numberkeys)。
預設情況下,結果中一個元素的分數是有序集合中該元素分數之和,前提是該元素在這些有序集合中都存在。因為交集要求其成員必須是給定的每個有序集合中的成員,結果集中的每個元素的分數和輸入的有序集合個數相等。
對于WEIGHTS和AGGREGATE參數的描述,參見指令ZUNIONSTORE。
如果destination存在,就把它覆寫。
[key ...]
[WEIGHTS weight [weight ...]]
[AGGREGATE SUM|MIN|MAX]
傳回值:結果有序集合destination中元素個數。
ZADD zInterStoreKey1 1 "one" 2 "two"
ZADD zInterStoreKey2 1 "one" 2 "two" 3 "three"
ZINTERSTORE zInterStoreSumResult 2 zInterStoreKey1 zInterStoreKey2 WEIGHTS 2 3
ZRANGE zInterStoreSumResult 0 -1 WITHSCORES
@Test
public void zInterStore() {
zSetOperations.add("zInterStoreKey1", "one", 1);
zSetOperations.add("zInterStoreKey1", "two", 2);
zSetOperations.add("zInterStoreKey2", "one", 1);
zSetOperations.add("zInterStoreKey2", "two", 2);
zSetOperations.add("zInterStoreKey2", "three", 3);
ZParams zParams = new ZParams();
zParams.weightsByDouble(2, 3);
zParams.aggregate(ZParams.Aggregate.SUM);
jedis.zinterstore("zInterStoreSumResult", zParams, "zInterStoreKey1", "zInterStoreKey2");
printTuple("zInterStoreSumResult", jedis.zrangeWithScores("zInterStoreSumResult", 0, -1));
}
ZUNIONSTORE指令
計算給定的numkeys個有序集合的并集,并且把結果放到destination中。
WEIGHTS參數相當于權重,預設就是1,可以給不同的key設定不同的權重
AGGREGATE參數預設使用的參數SUM,還可以選擇MIN或者MAX。這個參數決定結果集的score是取給定集合中的相加值、最小值還是最大值
[key ...]
[WEIGHTS weight [weight ...] ]
[AGGREGATE SUM|MIN|MAX]
ZADD zUnionStoreKey1 1 "one" 2 "two"
ZADD zUnionStoreKey2 1 "one" 2 "two" 3 "three"
ZUNIONSTORE zUnionStoreSumResult 2 zUnionStoreKey1 zUnionStoreKey2 WEIGHTS 2 3
ZUNIONSTORE zUnionStoreMinResult 2 zUnionStoreKey1 zUnionStoreKey2 WEIGHTS 2 3 AGGREGATE MIN
ZUNIONSTORE zUnionStoreMaxResult 2 zUnionStoreKey1 zUnionStoreKey2 WEIGHTS 2 3 AGGREGATE MAX
*
ZRANGE zUnionStoreSumResult 0 -1 WITHSCORES
ZRANGE zUnionStoreMinResult 0 -1 WITHSCORES
ZRANGE zUnionStoreMaxResult 0 -1 WITHSCORES
@Test
public void zUnionStore() {
zSetOperations.add("zUnionStoreKey1", "one", 1);
zSetOperations.add("zUnionStoreKey1", "two", 2);
zSetOperations.add("zUnionStoreKey2", "one", 1);
zSetOperations.add("zUnionStoreKey2", "two", 2);
zSetOperations.add("zUnionStoreKey2", "three", 3);
ZParams zParams = new ZParams();
zParams.weightsByDouble(2, 3);
zParams.aggregate(ZParams.Aggregate.SUM);
jedis.zunionstore("zUnionStoreSumResult", zParams, "zUnionStoreKey1", "zUnionStoreKey2");
//求最小值
zParams.aggregate(ZParams.Aggregate.MIN);
jedis.zunionstore("zUnionStoreMinResult", zParams, "zUnionStoreKey1", "zUnionStoreKey2");
//求最大值
zParams.aggregate(ZParams.Aggregate.MAX);
jedis.zunionstore("zUnionStoreMaxResult", zParams, "zUnionStoreKey1", "zUnionStoreKey2");
//spring
zSetOperations.unionAndStore("zUnionStoreKey1", "zUnionStoreKey2", "zUnionStoreResult");
printTuple("zUnionStoreSumResult", jedis.zrangeWithScores("zUnionStoreSumResult", 0, -1));
printTuple("zUnionStoreMinResult", jedis.zrangeWithScores("zUnionStoreMinResult", 0, -1));
printTuple("zUnionStoreMaxResult", jedis.zrangeWithScores("zUnionStoreMaxResult", 0, -1));
printTuple("zUnionStoreResult", jedis.zrangeWithScores("zUnionStoreResult", 0, -1));
}
還是那句話建議學習的人最好每個指令都去敲下,加深印象。
紙上得來終覺淺,絕知此事要躬行。————出自《冬夜讀書示子聿》