摘要：排名以開始，也就是說值最小的為。返回值返回成員排名，不存在返回取兩個(gè)集合的交集命令格式描述計(jì)算給定的一個(gè)或多個(gè)有序集的交集。其中給定的數(shù)量必須以參數(shù)指定，并將該交集結(jié)果集儲(chǔ)存到。返回值保存到的結(jié)果集成員數(shù)。

現(xiàn)在很多社交都有關(guān)注或者添加粉絲的功能, 類似于這樣的功能我們?nèi)绻捎脭?shù)據(jù)庫(kù)做的話只是單純得到用戶的一些粉絲或者關(guān)注列表的話是很簡(jiǎn)單也很容易實(shí)現(xiàn), 但是如果我想要查出兩個(gè)甚至多個(gè)用戶共同關(guān)注了哪些人或者想要查詢兩個(gè)或者多個(gè)用戶的共同粉絲的話就會(huì)很麻煩, 效率也不會(huì)很高. 但是如果你用redis去做的話就會(huì)相當(dāng)?shù)暮?jiǎn)單而且效率很高. 原因是redis自己本身帶有專門針對(duì)于這種集合的交集,并集, 差集的一些操作。

? 總體思路我們采用redis里面的zset完成整個(gè)功能, 原因是zset有排序(我們要按照關(guān)注時(shí)間的倒序排列), 去重(我們不能多次關(guān)注同一用戶)功能. 一個(gè)用戶我們存貯兩個(gè)集合, 一個(gè)是保存用戶關(guān)注的人 另一個(gè)是保存關(guān)注用戶的人.
用到的命令是:
? 1、 zadd 添加成員：命令格式: zadd key score member [score …]
? 2、zrem 移除某個(gè)成員：命令格式: zrem key member [member ...]
? 3、 zcard 統(tǒng)計(jì)集合內(nèi)的成員數(shù)：命令格式: zcard key
? 4、 zrange 查詢集合內(nèi)的成員：命令格式: ZRANGE key start stop [WITHSCORES]
? 描述：返回指定區(qū)間的成員。其中成員位置按 score 值遞增(從小到大)來排序。 WITHSCORES選項(xiàng)是用來讓成員和它的score值一并返回.
? 5、 zrevrange跟zrange作用相反
? 6、zrank獲取成員的排名：命令格式： zrank key member
? 描述：返回有序集key中成員member的排名。成員按 score 值遞增(從小到大)順序排列。排名以0開始，也就是說score 值最小的為0。返回值：返回成員排名，member不存在返回nil.
? 7、 zinterstore 取兩個(gè)集合的交集：命令格式：ZINTERSTORE destination numkeys key key ...] [AGGREGATE SUM|MIN|MAX]
? 描述：計(jì)算給定的一個(gè)或多個(gè)有序集的交集。其中給定 key 的數(shù)量必須以 numkeys 參數(shù)指定，并將該交集(結(jié)果集)儲(chǔ)存到 destination 。默認(rèn)情況下，結(jié)果集中某個(gè)成員的 score 值是所有給定集下該成員 score 值之 和 。
返回值：保存到 destination 的結(jié)果集成員數(shù)。

下面我用Java寫了一個(gè)簡(jiǎn)單的例子 maven構(gòu)建

    redis.clients
    jedis
    2.9.0

    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    public final class RedisUtil {
        //Redis服務(wù)器IP
        private static String ADDR = "localhost";
        //Redis的端口號(hào)
        private static int PORT = 6379;
        //訪問密碼
        private static String AUTH = "admin";
        //控制一個(gè)pool最多有多少個(gè)狀態(tài)為idle(空閑的)的jedis實(shí)例，默認(rèn)值也是8。
        private static int MAX_IDLE = 200;
        private static int TIMEOUT = 10000;
        //在borrow一個(gè)jedis實(shí)例時(shí)，是否提前進(jìn)行validate操作；如果為true，則得到的jedis實(shí)例均是可用的；
        private static boolean TEST_ON_BORROW = true;
        private static JedisPool jedisPool = null;
        
        static {
            try {
                JedisPoolConfig config = new JedisPoolConfig();
                config.setMaxIdle(MAX_IDLE);
                config.setTestOnBorrow(TEST_ON_BORROW);
                jedisPool = new JedisPool(config, ADDR, PORT, TIMEOUT, AUTH);
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
        
        public synchronized static Jedis getJedis() {
            try {
                if (jedisPool != null) {
                    Jedis resource = jedisPool.getResource();
                    return resource;
                } else {
                    return null;
                }
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
       
        @SuppressWarnings("deprecation")
        public static void returnResource(final Jedis jedis) {
            if (jedis != null) {
                jedisPool.returnResource(jedis);
            }
        }
    }

    import java.util.HashSet;
    import java.util.Set;
    
    import redis.clients.jedis.Jedis;
    
    import com.indulgesmart.base.util.RedisUtil;
    public class FollowUtil {
    
        private static final String FOLLOWING = "FOLLOWING_";
        private static final String FANS = "FANS_";
        private static final String COMMON_KEY = "COMMON_FOLLOWING";
    
        // 關(guān)注或者取消關(guān)注
        public static int addOrRelease(String userId, String followingId) {
            if (userId == null || followingId == null) {
                return -1;
            }
            int isFollow = 0; // 0 = 取消關(guān)注 1 = 關(guān)注
            Jedis jedis = RedisUtil.getJedis();
            String followingKey = FOLLOWING + userId;
            String fansKey = FANS + followingId;
            if (jedis.zrank(followingKey, followingId) == null) { // 說明userId沒有關(guān)注過followingId
                jedis.zadd(followingKey, System.currentTimeMillis(), followingId);
                jedis.zadd(fansKey, System.currentTimeMillis(), userId);
                isFollow = 1;
            } else { // 取消關(guān)注
                jedis.zrem(followingKey, followingId);
                jedis.zrem(fansKey, fansKey);
            }
            return isFollow;
        }
    
        
         // 驗(yàn)證兩個(gè)用戶之間的關(guān)系 
         // 0=沒關(guān)系  1=自己 2=userId關(guān)注了otherUserId 3= otherUserId是userId的粉絲 4=互相關(guān)注
        public int checkRelations (String userId, String otherUserId) {
    
            if (userId == null || otherUserId == null) {
                return 0;
            }
            
            if (userId.equals(otherUserId)) {
                return 1;
            }
            Jedis jedis = RedisUtil.getJedis();
            String followingKey = FOLLOWING + userId;
            int relation = 0;
            if (jedis.zrank(followingKey, otherUserId) != null) { // userId是否關(guān)注otherUserId
                relation = 2;
            }
            String fansKey = FANS + userId;
            if (jedis.zrank(fansKey, userId) != null) {// userId粉絲列表中是否有otherUserId
                relation = 3;
            }
            if ((jedis.zrank(followingKey, otherUserId) != null) 
                    && jedis.zrank(fansKey, userId) != null) {
                relation = 4;
            }
            return relation;
        }
    
        // 獲取用戶所有關(guān)注的人的id
        public static Set findFollwings(String userId) {
            return findSet(FOLLOWING + userId);
        }
    
        // 獲取用戶所有的粉絲
        public static Set findFans(String userId) {
            return findSet(FANS + userId);
        }
        
        // 獲取兩個(gè)共同關(guān)注的人
        public static Set findCommonFollowing(String userId, String otherUserId) {
            if (userId == null || otherUserId == null) {
                return new HashSet<>();
            }
            Jedis jedis = RedisUtil.getJedis();
            String commonKey = COMMON_KEY + userId + "_" + otherUserId;
            // 取交集
            jedis.zinterstore(commonKey + userId + "_" + otherUserId, FOLLOWING + userId, FOLLOWING + otherUserId); 
            Set result = jedis.zrange(commonKey, 0, -1);
            jedis.del(commonKey);
            return result;
        }
        
        // 根據(jù)key獲取set
        private static Set findSet(String key) {
            if (key == null) {
                return new HashSet<>();
            }
            Jedis jedis = RedisUtil.getJedis();
            Set result = jedis.zrevrange(key, 0, -1); // 按照score從大到小排序
            return result;
        }
    }

這是一點(diǎn)點(diǎn)小小的總結(jié), 希望能幫到要用到的人。