redis系列：通过文章点赞排名案例学习sortedset命令

private static final String ZSET_KEY = "articleList";

private RedisTemplate redisTemplate;
//string 命令操作对象
private ValueOperations valueOperations;
//zset 命令操作对象
private ZSetOperations zSetOperations;

@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);
    }
}

@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;
}

@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;
}

ZRANK articleList "文章1"
ZREVRANK articleList "文章1"

zadd zCardKey 1 one
zcard zCardKey

@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"));
}

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));
}

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"));
}

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"));
}

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));
}

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));
}

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));
}

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));
}

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));
}