国产xxxx99真实实拍_久久不雅视频_高清韩国a级特黄毛片_嗯老师别我我受不了了小说

資訊專欄INFORMATION COLUMN

使用Redis實現關注好友的功能

whatsns / 1851人閱讀

摘要:排名以開始,也就是說值最小的為。返回值返回成員排名,不存在返回取兩個集合的交集命令格式描述計算給定的一個或多個有序集的交集。其中給定的數量必須以參數指定,并將該交集結果集儲存到。返回值保存到的結果集成員數。

使用Redis實現關注好友的功能

現在很多社交都有關注或者添加粉絲的功能, 類似于這樣的功能我們如果采用數據庫做的話只是單純得到用戶的一些粉絲或者關注列表的話是很簡單也很容易實現, 但是如果我想要查出兩個甚至多個用戶共同關注了哪些人或者想要查詢兩個或者多個用戶的共同粉絲的話就會很麻煩, 效率也不會很高. 但是如果你用redis去做的話就會相當的簡單而且效率很高. 原因是redis自己本身帶有專門針對于這種集合的交集,并集, 差集的一些操作。

設計思路如下:

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

下面我用Java寫了一個簡單的例子 maven構建

第一步: 添加Redis客戶端

    redis.clients
    jedis
    2.9.0
第二步: 封裝一個簡單的redis工具類
    import redis.clients.jedis.Jedis;
    import redis.clients.jedis.JedisPool;
    import redis.clients.jedis.JedisPoolConfig;
    public final class RedisUtil {
        //Redis服務器IP
        private static String ADDR = "localhost";
        //Redis的端口號
        private static int PORT = 6379;
        //訪問密碼
        private static String AUTH = "admin";
        //控制一個pool最多有多少個狀態為idle(空閑的)的jedis實例,默認值也是8。
        private static int MAX_IDLE = 200;
        private static int TIMEOUT = 10000;
        //在borrow一個jedis實例時,是否提前進行validate操作;如果為true,則得到的jedis實例均是可用的;
        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);
            }
        }
    }
第四步: 封裝簡單的Follow類
    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";
    
        // 關注或者取消關注
        public static int addOrRelease(String userId, String followingId) {
            if (userId == null || followingId == null) {
                return -1;
            }
            int isFollow = 0; // 0 = 取消關注 1 = 關注
            Jedis jedis = RedisUtil.getJedis();
            String followingKey = FOLLOWING + userId;
            String fansKey = FANS + followingId;
            if (jedis.zrank(followingKey, followingId) == null) { // 說明userId沒有關注過followingId
                jedis.zadd(followingKey, System.currentTimeMillis(), followingId);
                jedis.zadd(fansKey, System.currentTimeMillis(), userId);
                isFollow = 1;
            } else { // 取消關注
                jedis.zrem(followingKey, followingId);
                jedis.zrem(fansKey, fansKey);
            }
            return isFollow;
        }
    
        
         // 驗證兩個用戶之間的關系 
         // 0=沒關系  1=自己 2=userId關注了otherUserId 3= otherUserId是userId的粉絲 4=互相關注
        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是否關注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;
        }
    
        // 獲取用戶所有關注的人的id
        public static Set findFollwings(String userId) {
            return findSet(FOLLOWING + userId);
        }
    
        // 獲取用戶所有的粉絲
        public static Set findFans(String userId) {
            return findSet(FANS + userId);
        }
        
        // 獲取兩個共同關注的人
        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;
        }
        
        // 根據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;
        }
    }

這是一點點小小的總結, 希望能幫到要用到的人。

文章版權歸作者所有,未經允許請勿轉載,若此文章存在違規行為,您可以聯系管理員刪除。

轉載請注明本文地址:http://specialneedsforspecialkids.com/yun/65365.html

相關文章

  • Redis 8 大應用場景!

    摘要:之前講過的介紹,及使用帶來的優勢,這章整理了一下的應用場景,也是非常重要的,學不學得好,能正常落地是關鍵。下面一一來分析下的應用場景都有哪些。提供的有序集合數據類構能實現各種復雜的排行榜應用。 之前講過Redis的介紹,及使用Redis帶來的優勢,這章整理了一下Redis的應用場景,也是非常重要的,學不學得好,能正常落地是關鍵。 下面一一來分析下Redis的應用場景都有哪些。 1、緩存...

    CastlePeaK 評論0 收藏0
  • 使用redis實現互粉功能

    摘要:數據庫實現一下是數據庫的代碼,通過保存用戶的和關注對象的以及關注狀態來判斷用戶的關注列表和粉絲列表,通過聯查獲取用戶的基本信息,入頭像名稱。 使用redis實現互粉 最近在寫api的時候要實現一個相互關注的功能,發現如果用mysql做查詢不是很理想, 所以想能不能用redis來實現這個功能,網上一搜有很多實現的方法,結合網上的博文,實現了自己的功能。 1.數據庫實現 一下是數據庫的代...

    aikin 評論0 收藏0

發表評論

0條評論

whatsns

|高級講師

TA的文章

閱讀更多
最新活動
閱讀需要支付1元查看
<