[redis]redis實現分頁的方法

每個主題下的用戶的評論組裝好寫入Redis中，每個主題會有一個topicId，每一條評論會和topicId關聯起來，大致的數據模型如下：
{ topicId: 'xxxxxxxx', comments: [ { username: 'niuniu', createDate: 1447747334791, content: '在Redis中分頁', commentId: 'xxxxxxx', reply: [ { content: 'yyyyyy' username: 'niuniu' }, ... ] }, ... ]}
將評論數據從MySQL查詢出來組裝好存到Redis后，以后每次就可以從Redis獲取組裝好的評論數據，從上面的數據模型可以看出數據都是key-value型數據，無疑要采用hash進行存儲，但是每次拿取評論數據時需要分頁而且還要按createDate字段進行排序，hash肯定是不能做到分頁和排序的。

那么，就挨個看一下Redis所支持的數據類型：

1、String: 主要用於存儲字符串，顯然不支持分頁和排序。
2、Hash: 主要用於存儲key-value型數據，評論模型中全是key-value型數據，所以在這里Hash無疑會用到。
3、List: 主要用於存儲一個列表，列表中的每一個元素按元素的插入時的順序進行保存，如果我們將評論模型按createDate排好序后再插入List中，似乎就能做到排序了，而且再利用List中的LRANGE key start stop指令還能做到分頁。嗯，到這里List似乎滿足了我們分頁和排序的要求，但是評論還會被刪除，就需要更新Redis中的數據，如果每次刪除評論后都將Redis中的數據全部重新寫入一次，顯然不夠優雅，效率也會大打折扣，如果能刪除指定的數據無疑會更好，而List中涉及到刪除數據的就只有LPOP和RPOP這兩條指令，但LPOP和RPOP只能刪除列表頭和列表尾的數據，不能刪除指定位置的數據,(備注：其實還有 LREM命令可以做到刪除，但是非常不方便)，而且當存在接口高並發訪問時，這個list可能會無限延長，且里面的數據會存在很多重復，這就會影響到正常的業務，所以List也不太適合。

4、Set: 主要存儲無序集合，無序！排除。
5、SortedSet: 主要存儲有序集合，SortedSet的添加元素指令ZADD key score member [[score,member]…]會給每個添加的元素member綁定一個用於排序的值score，SortedSet就會根據score值的大小對元素進行排序，在這里就可以將createDate當作score用於排序，SortedSet中的指令ZREVRANGE key start stop又可以返回指定區間內的成員，可以用來做分頁，SortedSet的指令ZREM key member可以根據key移除指定的成員，能滿足刪評論的要求，所以，SortedSet在這里是最適合的（時間復雜度O(log(N))）。

所以，需要用到的數據類型有SortSet和Hash，SortSet用於做分頁排序，Hash用於存儲具體的鍵值對數據。SortSet結構中將每個主題的topicId作為set的key，將與該主題關聯的評論的createDate和commentId分別作為set的score和member，commentId的順序就根據createDate的大小進行排列。
當需要查詢某個主題某一頁的評論時，就可主題的topicId通過指令zrevrange topicId (page-1)×10 (page-1)×10+perPage這樣就能找出某個主題下某一頁的按時間排好順序的所有評論的commintId。page為查詢第幾頁的頁碼，perPage為每頁顯示的條數。
當找到所有評論的commentId后，就可以把這些commentId作為key去Hash結構中去查詢該條評論對應的內容。
這樣就利用SortSet和Hash兩種結構在Redis中達到了分頁和排序的目的。

當然，也可以直接只使用SrotedSet類型，而不使用Hash類型，直接將評論存放在member中。
但為什么要將評論和排序放到不同的類型里？其中的好處是，可以對評論設置不同的排序類型，比如按時間的正反序，點贊的正反序，查看次數的正反序等。而這樣只需要維護不同的SrotedSet排序，不需要維護多套評論的內容了。

 

下面是示例：

需要引用下面兩個jar包

采用的jedis-2.8.1.jar

因為JedisPool引用了第三方類庫，需要再加入 commons-pool2-2.4.2.jar

 

代碼如下：

 public static void main(String[] args)
    {
        for (int i = 1; i <= 100; i += 1) {
            // 初始化CommentId索引 SortSet
            RedisClient.zadd("topicId", i, "commentId" + i);
            // 初始化Comment數據 Hash
            RedisClient.hset("Comment_Key", "commentId" + i, "comment content "+ i +" .......");
        }
        // 倒序取 從0條開始取 5條 Id 數據
        Set<String> sets = RedisClient.zrevrangebyscore("topicId", "100", "1", 0, 10);
        String[] items = new String[]{};
        System.out.println(sets.toString());
        // 根據id取comment數據
        List<String> list = RedisClient.hmget("Comment_Key", sets.toArray(items));
        for (String str : list) {
            System.out.println(str);
        }

    }

其中的RedisClient類的代碼如下：

import java.util.LinkedHashSet;
import java.util.List;
import java.util.Set;

import redis.clients.jedis.Jedis;
import redis.clients.jedis.JedisCommands;
import redis.clients.jedis.JedisPool;
import redis.clients.jedis.JedisPoolConfig;

/**
 * Redis 客戶端
 */
public class RedisClient {

    private static JedisPool jedisPool;
    
    static {

        JedisPoolConfig config = new JedisPoolConfig();

        config.setMaxTotal(123);
        config.setMaxTotal(1024);
        config.setMaxIdle(10);
        config.setMaxWaitMillis(1000);
        config.setTestOnBorrow(true);
        config.setTestOnReturn(true);

        String ip = "192.168.80.128";
        int port = 6379;
        int timeOut = 2000;
        String password="jdd.com";

        jedisPool = new JedisPool(config,ip,port,timeOut,password);

    }

    public static String set(String key, String value) {
        Jedis jedis = jedisPool.getResource();
        String result = jedis.set(key, value);
        jedis.close();
        return result;
    }

    public static String get(String key) {
        Jedis jedis = jedisPool.getResource();
        String result = jedis.get(key);
        jedis.close();
        return result;
    }

    public static Long hset(String key, String item, String value) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.hset(key, item, value);
        jedis.close();
        return result;
    }

    public static String hget(String key, String item) {
        Jedis jedis = jedisPool.getResource();
        String result = jedis.hget(key, item);
        jedis.close();
        return result;
    }

    /**
     * Redis Hmget 命令用於返回哈希表中，一個或多個給定字段的值。
     * 如果指定的字段不存在於哈希表，那么返回一個 nil 值。
     *
     * @param key
     * @param item
     * @return 一個包含多個給定字段關聯值的表，表值的排列順序和指定字段的請求順序一樣。
     */
    public static List<String> hmget(String key, String... item) {
        Jedis jedis = jedisPool.getResource();
        List<String> result = jedis.hmget(key, item);
        jedis.close();
        return result;
    }

    public static Long incr(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.incr(key);
        jedis.close();
        return result;
    }

    public static Long decr(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.decr(key);
        jedis.close();
        return result;
    }

    public static Long expire(String key, int second) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.expire(key, second);
        jedis.close();
        return result;
    }

    public static Long ttl(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.ttl(key);
        jedis.close();
        return result;
    }

    public static Long hdel(String key, String item) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.hdel(key, item);
        jedis.close();
        return result;
    }

    public static Long del(String key) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.del(key);
        jedis.close();
        return result;
    }

    public static Long rpush(String key, String... strings) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.rpush(key, strings);
        jedis.close();
        return result;
    }

    /**
     * Redis Lrange 返回列表中指定區間內的元素，區間以偏移量 START 和 END 指定。 其中 0 表示列表的第一個元素， 1 表示列表的第二個元素，以此類推。
     * 你也可以使用負數下標，以 -1 表示列表的最后一個元素， -2 表示列表的倒數第二個元素，以此類推。
     *
     * @param string
     * @param start
     * @param end
     * @return
     */
    public static List<String> lrange(String key, int start, int end) {
        Jedis jedis = jedisPool.getResource();
        List<String> result = jedis.lrange(key, start, end);
        jedis.close();
        return result;
    }

    /**
     * 從列表中從頭部開始移除count個匹配的值。如果count為零，所有匹配的元素都被刪除。如果count是負數，內容從尾部開始刪除。
     *
     * @param string
     * @param string2
     * @param i
     */
    public static Long lrem(String key, Long count, String value) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.lrem(key, count, value);
        jedis.close();
        return result;
    }

    /**
     * Redis Zadd 命令用於將一個或多個成員元素及其分數值加入到有序集當中。
     * 如果某個成員已經是有序集的成員，那么更新這個成員的分數值，並通過重新插入這個成員元素，來保證該成員在正確的位置上。
     * 分數值可以是整數值或雙精度浮點數。
     * 如果有序集合 key 不存在，則創建一個空的有序集並執行 ZADD 操作。
     * 當 key 存在但不是有序集類型時，返回一個錯誤。
     *
     * @param string
     * @param i
     * @param string2
     * @return 被成功添加的新成員的數量，不包括那些被更新的、已經存在的成員。
     */
    public static Long zadd(String key, double score, String member) {
        Jedis jedis = jedisPool.getResource();
        Long result = jedis.zadd(key, score, member);
        jedis.close();
        return result;
    }

    /**
     * Redis Zrevrangebyscore 返回有序集中指定分數區間內的所有的成員。有序集成員按分數值遞減(從大到小)的次序排列。
     * 具有相同分數值的成員按字典序的逆序(reverse lexicographical order )排列。
     * 除了成員按分數值遞減的次序排列這一點外， ZREVRANGEBYSCORE 命令的其他方面和 ZRANGEBYSCORE 命令一樣。
     *
     * @param key
     * @param max
     * @param min
     * @param offset
     * @param count
     * @return 指定區間內，帶有分數值(可選)的有序集成員的列表。
     */
    public static Set<String> zrevrangebyscore(String key, String max, String min, int offset, int count) {
        Jedis jedis = jedisPool.getResource();
        Set<String> result =  jedis.zrevrangeByScore(key, max, min, offset, count);
        jedis.close();
        return result;
    }
}