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中,并设置过期时间!