仿微博社交平台系统设计[三]--使用redis的zset存储好友关系的实现

Redis 有序集合(sorted set)
Redis 有序集合和集合同样也是string类型元素的集合,且不容许重复的成员。

不一样的是每一个元素都会关联一个double类型的分数。redis正是经过分数来为集合中的成员进行从小到大的排序。

有序集合的成员是惟一的,但分数(score)却能够重复。

实例

redis 127.0.0.1:6379> ZADD runoobkey 1 redis
(integer) 1
redis 127.0.0.1:6379> ZADD runoobkey 2 mongodb
(integer) 1
redis 127.0.0.1:6379> ZADD runoobkey 3 mysql
(integer) 1
redis的相关命令:
 ZADD key score1 member1 [score2 member2]

实际api与命令score和memeber位置相反

redisTemplate的相关api:
redisTemplate.opsForZSet().add(K key, V value, double score)
具体java代码的实现:

/**
   * @param uid       用户id
   * @param relatedId 粉丝id
   */
  public void fanIncrease(int uid, int relatedId, double time) {
    friendIncrease(fanKey(uid), relatedId, time);
  }
 
 private Boolean friendIncrease(String key, int relatedId, double time) {
    Boolean success = redisTemplate.opsForZSet().add(key, String.valueOf(relatedId), time);
    redisTemplate.expire(key, 10L, TimeUnit.DAYS);
    return success;
  }

利用redis的zset，设置添加时间为score

利用zset会好些，各类操做的时间复杂度，占用cpu都好过list。

/**
   * 查询集合中指定顺序的值， 0 -1 表示获取所有的集合内容  zrange
   * <p>
   * 返回有序的集合，score小的在前面
   *
   * @param key
   * @param start
   * @param end
   * @return
   */
  public Set<String> range(String key, int start, int end) {
    return redisTemplate.opsForZSet().range(key, start, end);
  }
 
  Set<String> _set = redisComponent.range(followKey(uid), 0, -1);
 
/**
   * @param uid 关注人id
   */
  public Set<String> getAllFollows(int uid) {
    Set<String> _set = redisComponent.range(followKey(uid), 0, -1);
    //集size为0 查询数据库是否为0 为0返回，不为0查询并插入
    if (CollectionUtils.isEmpty(_set)) {
      Integer count = friendMapper.selectCount(Wrappers.<Friend>lambdaQuery().eq(Friend::getUid, uid));
      if (count == 0) {
        return _set;
      } else {
        List<Friend> friends = friendMapper.selectList(Wrappers.<Friend>lambdaQuery()
          .eq(Friend::getUid, uid)
          .orderByDesc(Friend::getCreateAt));
        friends.forEach(f -> {
          followIncrease(uid, f.getFollowId(), f.getCreateAt().getTime());
        });
        return redisComponent.range(followKey(uid), 0, -1);
      }
 
    }
    return _set;
  }

利用rang方法获取全部被关注人的uid的set集

若是缓存已经失效，则从数据库中查询，并重新设置的redis中，并设置过时时间！